iss #22: [tmp] github client

app/hedgehog/clients/github/Client.scala

@@ -1,6 +1,8 @@
 package hedgehog.clients.github
 
 import scala.concurrent.{Future, Promise}
+import play.api.libs.ws.WS
+import play.Logger
 import hedgehog.models.{AccountSettings, Repo}
 
 
@@ -13,11 +15,29 @@ class Client(val config: Config, implicit val context: scala.concurrent.Executio
   def getRepos(accountSettings: AccountSettings): Future[Seq[Repo]] = {
     val finish = Promise[Seq[Repo]]()
 
-    finish success List(new Repo("a", accountSettings.account),
-                        new Repo("b", accountSettings.account))
+    val account = accountSettings.account
+    val url = config.replaceBaseUrl(account.apiReposUrl)
+    val httpClient = WS.url(url).withQueryString("per_page" -> "100", "page" -> "1")
 
-    // finish failure new ConfigError("ou!")
+    httpClient.get map {
+      response =>
+        Logger.debug(s"GET ${httpClient.url}")
+        Logger.debug(s"body: " + response.body.toString.substring(0, 100) + "...")
+        Logger.debug(s"headers: "+ response.getAHCResponse.getHeaders.toString)
+        response.status match {
+          case 200 => {
+            finish success List(Repo("a", accountSettings.account),
+                                Repo("b", accountSettings.account))
+
+          }
+          //TODO: custom exceptions
+          case code: Int if code >= 400 && code < 599 =>
+            finish failure new Exception("no data")
+          case _ => new Exception("unknown error")
+        }
+    }
 
     finish.future
   }
+
 }

app/hedgehog/clients/github/GithubReades.scala

@@ -0,0 +1,44 @@
+package hedgehog.clients.github
+
+import play.api.libs.functional.syntax._
+import play.api.libs.json.{Reads, __}
+
+import hedgehog.models.{GithubOrg, Account, GithubUser, Repo, ProgrammingLang}
+/**
+ * Copyright (c) Nikita Kovaliov, maizy.ru, 2014
+ * See LICENSE.txt for details.
+ */
+object GithubReades {
+
+  val accountReads: Reads[Account] = (
+    (__ \ "type").read[String] ~
+    (__ \ "login").read[String] ~
+    (__ \ "avatar_url").readNullable[String]
+  ) apply {
+    (accountType, login, avatarUrl) => accountType match {
+      case "User" => GithubUser(login, avatarUrl)
+      case "Organization" => GithubOrg(login, avatarUrl)
+      case _ => throw new FormatError(s"Unknown owner type "+ accountType)
+    }
+  }
+
+  val repoReads: Reads[Repo] = (
+    (__ \ "name").read[String] ~
+    (__ \ "owner").read[Account](accountReads) ~
+    (__ \ "description").readNullable[String] ~
+    (__ \ "private").read[Boolean] ~
+    (__ \ "language").readNullable[String]
+  ) apply {
+    (name, owner, description, isPrivate, lang) => {
+      Repo(
+        name,
+        owner,
+        description = description,
+        isPrivate = Some(isPrivate),
+        primaryLang = lang.map(l => ProgrammingLang(l.toLowerCase))
+      )
+    }
+  }
+
+  val repoSeqReads: Reads[Seq[Repo]] = Reads.seq[Repo](repoReads)
+}

app/hedgehog/clients/github/errors.scala

@@ -5,4 +5,5 @@ package hedgehog.clients.github
  * See LICENSE.txt for details.
  */
 class Error(msg: String) extends Exception(msg)
-class FetchError(msg: String) extends Exception(msg)
+class FetchError(msg: String) extends Error(msg)
+class FormatError(msg: String) extends Error(msg)

app/hedgehog/models/Account.scala

@@ -1,8 +1,9 @@
 package hedgehog.models
 
-import play.api.libs.json.{Json, JsValue, Writes}
-import hedgehog.UrlUtils.urlEncodePathSegment
+import play.api.libs.json._
+import play.api.libs.functional.syntax._
 
+import hedgehog.UrlUtils.urlEncodePathSegment
 
 /**
  * Copyright (c) Nikita Kovaliov, maizy.ru, 2014
@@ -30,6 +31,8 @@ trait Account {
 
   def getRepoUrl(repo: Repo): String =
     s"$webProfileUrl/${urlEncodePathSegment(repo.fullName)}"
+
+  def apiReposUrl: String
 }
 
 
@@ -45,15 +48,16 @@ object AccountJson {
       )
     }
   }
-}
 
+}
 
 case class GithubUser(
     name: String,
     override val avatarUrl: Option[String] = None)
   extends Account {
 
   val accountType = AccountType.User
+  val apiReposUrl = s"$GITHUB_BASE_API_URL/users/${urlEncodePathSegment(name)}/repos"
 }
 
 
@@ -63,4 +67,5 @@ case class GithubOrg(
   extends Account {
 
   val accountType = AccountType.Org
+  val apiReposUrl = s"$GITHUB_BASE_API_URL/orgs/${urlEncodePathSegment(name)}/repos"
 }

app/hedgehog/models/Repo.scala

@@ -5,25 +5,23 @@ import play.api.libs.json._
  * Copyright (c) Nikita Kovaliov, maizy.ru, 2013-2014
  * See LICENSE.txt for details.
  */
-class Repo(
-    val name: String,
-    val owner: Account,
-    val description: Option[Boolean] = None,
-    val isPrivate: Option[Boolean] = None,
-    val primaryLang: Option[ProgrammingLang] = None,
-    val langsStat: Option[Seq[ProgrammingLangStat]] = None) {
+case class Repo(
+    name: String,
+    owner: Account,
+    description: Option[String] = None,
+    isPrivate: Option[Boolean] = None,
+    primaryLang: Option[ProgrammingLang] = None,
+    langsStat: Option[Seq[ProgrammingLangStat]] = None) {
   def fullName = s"${owner.name}/$name"
   lazy val langsStatIndex = langsStat.map(seq => seq.map{stat => (stat.lang.code, stat)}.toMap)
   def url: String = owner.getRepoUrl(this)
 }
 
 
 object Repo {
-  //FIXME
-  def getCurrentRepos: Seq[Repo] = List()
 
-  implicit val writer = new Writes[Repo] {
-    def writes(r: Repo) : JsValue = {
+  implicit val repoWrites = new Writes[Repo] {
+    def writes(r: Repo): JsValue = {
       //FIXME: as documented
       Json.obj(
         "name" -> r.name,

app/hedgehog/models/package.scala

@@ -7,4 +7,5 @@ package hedgehog
 package object models {
   val GITHUB_HOST = "github.com"
   val GITHUB_BASE_WEB_URL = s"https://$GITHUB_HOST"
+  val GITHUB_BASE_API_URL = s"https://api.$GITHUB_HOST"
 }

app/hedgehog/models/programming_lang.scala

@@ -5,10 +5,10 @@ package hedgehog.models
  * See LICENSE.txt for details.
  *
  */
-class ProgrammingLang(val code: String)
+case class ProgrammingLang(code: String)
 
 
-class ProgrammingLangStat(
-    val lang: ProgrammingLang,
-    val extensions: Seq[String],
-    val bytes: Option[Long])
+case class ProgrammingLangStat(
+    lang: ProgrammingLang,
+    extensions: Seq[String],
+    bytes: Option[Long])