1 files changed, 91 insertions, 0 deletions
diff --git a/src/main/scala/gh/Issues.scala b/src/main/scala/gh/Issues.scala
new file mode 100644
index 0000000..6187d2d
--- /dev/null
+++ b/src/main/scala/gh/Issues.scala
@@ -0,0 +1,91 @@
+package gh
+
+import akka.NotUsed
+import akka.stream.scaladsl.Source
+import scala.concurrent.Future
+import spray.json.{ DefaultJsonProtocol, JsonFormat }
+
+trait Issues { self: HttpClient =>
+  import self._
+  case class Issue(
+    id: Int,
+    number: Int,
+    state: String,
+    title: String,
+    body: String,
+    user: User,
+    labels: Seq[Label],
+    assignee: Option[User],
+    milestone: Option[Milestone],
+    locked: Boolean,
+    comments: Int,
+    closedAt: Option[String],
+    createdAt: String,
+    updatedAt: String
+  )
+
+  case class User(
+    login: String,
+    id: Int,
+    avatarUrl: String,
+    gravatarId: String,
+    `type`: String,
+    siteAdmin: Boolean
+  )
+
+  case class Label(
+    name: String,
+    color: String
+  )
+
+  case class Milestone(
+    id: Int,
+    state: String,
+    title: String,
+    description: String,
+    creator: User,
+    openIssues: Int,
+    closedIssues: Int,
+    createdAt: String,
+    updatedAt: String,
+    closedAt: String,
+    dueOn: String
+  )
+
+  case class Comment(
+    id: Int,
+    body: String,
+    user: User,
+    createdAt: String,
+    updatedAt: String
+  )
+
+  private object JsonSupport extends DefaultJsonProtocol with SnakifiedSprayJsonSupport {
+    implicit val userFormat = jsonFormat6(User)
+    implicit val commentFormat = jsonFormat5(Comment)
+    implicit val milestoneFormat = jsonFormat11(Milestone)
+    implicit val labelFormat = jsonFormat2(Label)
+    implicit val itemFormat = jsonFormat14(Issue)
+  }
+  import JsonSupport._
+
+  object issues {
+    def get(
+      owner: String,
+      repo: String,
+      milestone: String = "*",
+      state: String = "all",
+      assignee: String = "*",
+      creator: String = "*",
+      mentioned: String = "*",
+      labels: String = "*",
+      sort: String = "created",
+      direction: String = "desc",
+      since: String = "1970-01-01T00:00:00"
+    ): Source[Issue, NotUsed] = {
+      client.get[collection.immutable.Seq[Issue]]("/repos/" + owner + "/" + repo + "/issues").mapConcat(x => x)
+    }
+
+  }
+
+}