wip gitlab: get organizations

Author: Juan José Vázquez

core/src/main/scala/Config.scala

@@ -141,10 +141,10 @@ object ScmConfig {
       s"$api/user"
 
     val userOrgsEndpoint: String =
-      s"$userEndpoint/orgs"
+      s"$api/groups"
 
     def orgEndpoint(login: String): String =
-      s"$api/orgs/$login"
+      s"$api/groups/$login"
 
     def repoEndpoint(page: Int = 1): String =
       s"$api/user/repos?affiliation=owner,organization_member&visibility=all&direction=asc&page=$page"

core/src/main/scala/Gitlab.scala

@@ -1,16 +1,16 @@
 package nelson
 
-import argonaut.Argonaut.{ casecodec1, casecodec4 }
+import argonaut.Argonaut.{casecodec1, casecodec2, casecodec4}
 import argonaut.{CodecJson, DecodeJson, EncodeJson}
 import nelson.Github._
 import org.http4s
 import org.http4s._
 import org.http4s.argonaut._
 import org.http4s.client.Client
 import org.http4s.headers.Authorization
+import scalaz._, Scalaz._
 import scalaz.concurrent.Task
-import scalaz.~>
-import java.net.{ MalformedURLException, URI }
+import java.net.{MalformedURLException, URI}
 
 object Gitlab {
 
@@ -31,11 +31,25 @@ object Gitlab {
       case GetUser(token: AccessToken) =>
         fetch[Github.User](cfg.userEndpoint) { uri =>
             http4s.Request(
-            headers = Headers(Authorization(OAuth2BearerToken(token.value))),
+            headers = Headers(Header("PRIVATE-TOKEN", token.value)),
+//            headers = Headers(Authorization(OAuth2BearerToken(token.value))),
             uri = uri)
         }
-      case GetUserOrgKeys(token: AccessToken) => ???
-      case GetOrganizations(keys: List[Github.OrgKey], t: AccessToken) => ???
+      case GetUserOrgKeys(token: AccessToken) =>
+        fetch[List[Github.OrgKey]](cfg.userOrgsEndpoint) { uri =>
+          http4s.Request(
+            headers = Headers(Header("PRIVATE-TOKEN", token.value)),
+            uri = uri)
+        }
+      case GetOrganizations(keys: List[Github.OrgKey], t: AccessToken) =>
+        Nondeterminism[Task].gatherUnordered(
+          keys.map(key => fetch[Organization](cfg.orgEndpoint(key.slug)) { uri =>
+            http4s.Request(
+              headers = Headers(Header("PRIVATE-TOKEN", t.value)),
+              uri = uri)
+          })
+        )
+        //fetch[List[Organization]](cfg.orgEndpoint())
       case GetReleaseAssetContent(asset: Github.Asset, t: AccessToken) => ???
       case GetRelease(slug: Slug, releaseId: ID, t: AccessToken) => ???
       case GetUserRepositories(t: AccessToken) => ???
@@ -55,6 +69,21 @@ object Gitlab {
     casecodec4(Github.User.apply, Github.User.unapply
     )("username", "avatar_url", "name", "email")
 
+  implicit lazy val GithubOrg: CodecJson[Github.OrgKey] =
+    casecodec2(Github.OrgKey.apply, Github.OrgKey.unapply)("id", "full_path")
+
+//  implicit lazy val OrganizationCodec: CodecJson[Organization] =
+//    casecodec4(Organization.apply, Organization.unapply)("id", "name", "full_path", "avatar_url")
+
+  implicit lazy val OrganizationDecoder: DecodeJson[Organization] =
+    DecodeJson(c =>
+      ((c --\ "id").as[Long] |@|
+        (c --\ "name").as[Option[String]] |@|
+        (c --\ "full_path").as[String]
+        //(c --\ "avatar_url").as[URI]
+        ) { case (id, name, login) => Organization(id, name, login, new URI("https://localhost:8080")) } // TODO
+    )
+
   implicit lazy val AccessTokenCodec: CodecJson[AccessToken] =
     casecodec1(AccessToken.apply, AccessToken.unapply)("access_token")