IssueMigrator.scala

@main def main() = {
  val token = os.read(os.home / "IdeaProjects" / "Hands-On Scala" / "resources" / "github_token.txt" ).trim

  def fetchPaginated(url: String, params: (String, String)*) = {
    var done = false
    var page = 1
    var responses = collection.mutable.Buffer.empty[ujson.Value]
    while (!done) {
      println("page " + page + "...")
      val resp = requests.get(
        url,
        params = Map("page" -> page.toString) ++ params,
        headers = Map("Authorization" -> s"token $token")
      )
      val parsed = ujson.read(resp).arr
      if (parsed.isEmpty) done = true
      else responses.appendAll(parsed)
      page += 1
    }
    responses
  }

  val issues = fetchPaginated(s"https://api.github.com/repos/$srcRepo/issues", "state" -> "all")

  val nonPullRequests = issues.filter(!_.obj.contains("pull_request"))

  val issueData = for (issue <- nonPullRequests) yield (
    issue("number").num.toInt,
    issue("title").str,
    issue("body").str,
    issue("user")("login").str
  )

  val comments = fetchPaginated(s"https://api.github.com/repos/$srcRepo/issues/comments")

  val commentData = for (comment <- comments) yield (
    comment("issue_url").str match {
      case s"https://api.github.com/repos/lihaoyi/$repo/issues/$id" => id.toInt
    },
    comment("user")("login").str,
    comment("body").str
  )

  val issueNums = for ((number, title, body, user) <- issueData.sortBy(_._1)) yield {
    println(s"Creating issue $number")
    val resp = requests.post(
      s"https://api.github.com/repos/$destRepo/issues",
      data = ujson.Obj(
        "title" -> title,
        "body" -> s"$body\nID: $number\nOriginal Author: $user"
      ),
      headers = Map("Authorization" -> s"token $token")
    )
    println(resp.statusCode)
    val newIssueNumber = ujson.read(resp)("number").num.toInt
    (number, newIssueNumber)
  }

  val issueNumMap = issueNums.toMap

  for ((issueId, user, body) <- commentData; newIssueId <- issueNumMap.get(issueId)) {
    println(s"Commenting on issue old_id=$issueId new_id=$newIssueId")
    val resp = requests.post(
      s"https://api.github.com/repos/lihaoyi/test/issues/$newIssueId/comments",
      data = ujson.Obj("body" -> s"$body\nOriginal Author:$user"),
      headers = Map("Authorization" -> s"token $token")
    )
    println(resp.statusCode)
  }
}