/** * Generated by API Builder - https://www.apibuilder.io * Service version: 0.4.67 * User agent: apibuilder app.apibuilder.io/flow/github/0.4.67/play_2_6 */ package io.flow.github.v0 { object Constants { val BaseUrl = "https://api.github.com" val Namespace = "io.flow.github.v0" val UserAgent = "apibuilder app.apibuilder.io/flow/github/0.4.67/play_2_6" val Version = "0.4.67" val VersionMajor = 0 } class Client( ws: play.api.libs.ws.WSClient, val baseUrl: String = "https://api.github.com", auth: scala.Option[io.flow.github.v0.Authorization] = None, defaultHeaders: Seq[(String, String)] = Nil ) extends interfaces.Client { import io.flow.github.v0.models.json._ private val logger = play.api.Logger("io.flow.github.v0.Client") logger.info(s"Initializing io.flow.github.v0.Client for url $baseUrl") def blobs: Blobs = Blobs def commits: Commits = Commits def contents: Contents = Contents def hooks: Hooks = Hooks def pullRequests: PullRequests = PullRequests def refs: Refs = Refs def repositories: Repositories = Repositories def tags: Tags = Tags def trees: Trees = Trees def userEmails: UserEmails = UserEmails def users: Users = Users object Blobs extends Blobs { override def getBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Blob] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/blobs/${play.utils.UriEncoding.encodePathSegment(sha, "UTF-8")}", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Blob", r, _.validate[io.flow.github.v0.models.Blob]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def post( owner: String, repo: String, blobForm: io.flow.github.v0.models.BlobForm, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[io.flow.github.v0.models.BlobCreated] = { val payload = play.api.libs.json.Json.toJson(blobForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/blobs", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.BlobCreated", r, _.validate[io.flow.github.v0.models.BlobCreated]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } } object Commits extends Commits { override def getBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Commit] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/commits/${play.utils.UriEncoding.encodePathSegment(sha, "UTF-8")}", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Commit", r, _.validate[io.flow.github.v0.models.Commit]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404, 422") } } override def post( owner: String, repo: String, commitForm: io.flow.github.v0.models.CommitForm, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[io.flow.github.v0.models.CommitResponse] = { val payload = play.api.libs.json.Json.toJson(commitForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/commits", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client.parseJson( "io.flow.github.v0.models.CommitResponse", r, _.validate[io.flow.github.v0.models.CommitResponse] ) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } } object Contents extends Contents { override def getReadme( owner: String, repo: String, ref: String = "main", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Contents] = { val queryParameters = Seq( Some("ref" -> ref) ).flatten _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/readme", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Contents", r, _.validate[io.flow.github.v0.models.Contents]) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401, 404") } } override def getContentsByPath( owner: String, repo: String, path: String, ref: String = "main", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Contents] = { val queryParameters = Seq( Some("ref" -> ref) ).flatten _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/contents/${play.utils.UriEncoding.encodePathSegment(path, "UTF-8")}", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Contents", r, _.validate[io.flow.github.v0.models.Contents]) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401, 404") } } } object Hooks extends Hooks { override def get( owner: String, repo: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Hook]] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/hooks", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("Seq[io.flow.github.v0.models.Hook]", r, _.validate[Seq[io.flow.github.v0.models.Hook]]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def getById( owner: String, repo: String, id: Long, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Hook] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/hooks/${id}", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Hook", r, _.validate[io.flow.github.v0.models.Hook]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def post( owner: String, repo: String, hookForm: io.flow.github.v0.models.HookForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Hook] = { val payload = play.api.libs.json.Json.toJson(hookForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/hooks", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Hook", r, _.validate[io.flow.github.v0.models.Hook]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } override def deleteById( owner: String, repo: String, id: Long, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] = { _executeRequest( "DELETE", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/hooks/${id}", requestHeaders = requestHeaders ).map { case r if r.status == 204 => () case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 204, 404") } } } object PullRequests extends PullRequests { override def post( owner: String, repo: String, pullRequestForm: io.flow.github.v0.models.PullRequestForm, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[io.flow.github.v0.models.PullRequest] = { val payload = play.api.libs.json.Json.toJson(pullRequestForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/pulls", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.PullRequest", r, _.validate[io.flow.github.v0.models.PullRequest]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } override def get( owner: String, repo: String, page: Long = 1L, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.PullRequest]] = { val queryParameters = Seq( Some("page" -> page.toString) ).flatten _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/pulls", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.PullRequest]", r, _.validate[Seq[io.flow.github.v0.models.PullRequest]] ) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } } object Refs extends Refs { override def get( owner: String, repo: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Ref]] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/refs", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("Seq[io.flow.github.v0.models.Ref]", r, _.validate[Seq[io.flow.github.v0.models.Ref]]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def getByRef( owner: String, repo: String, ref: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/refs/${play.utils.UriEncoding.encodePathSegment(ref, "UTF-8")}", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Ref", r, _.validate[io.flow.github.v0.models.Ref]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def post( owner: String, repo: String, refForm: io.flow.github.v0.models.RefForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] = { val payload = play.api.libs.json.Json.toJson(refForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/refs", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Ref", r, _.validate[io.flow.github.v0.models.Ref]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } override def putByRef( owner: String, repo: String, ref: String, refUpdateForm: io.flow.github.v0.models.RefUpdateForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] = { val payload = play.api.libs.json.Json.toJson(refUpdateForm) _executeRequest( "PUT", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/refs/${play.utils.UriEncoding.encodePathSegment(ref, "UTF-8")}", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Ref", r, _.validate[io.flow.github.v0.models.Ref]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } } object Repositories extends Repositories { override def getUserAndRepos( page: Long = 1L, visibility: io.flow.github.v0.models.Visibility = io.flow.github.v0.models.Visibility.All, affiliation: _root_.scala.Option[String] = None, `type`: _root_.scala.Option[String] = None, sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] = { val queryParameters = Seq( Some("page" -> page.toString), Some("visibility" -> visibility.toString), affiliation.map("affiliation" -> _), `type`.map("type" -> _), Some("sort" -> sort), Some("direction" -> direction) ).flatten _executeRequest("GET", s"/user/repos", queryParameters = queryParameters, requestHeaders = requestHeaders).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.Repository]", r, _.validate[Seq[io.flow.github.v0.models.Repository]] ) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } override def getUsersAndReposByUsername( username: String, page: Long = 1L, `type`: String = "owner", sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] = { val queryParameters = Seq( Some("page" -> page.toString), Some("type" -> `type`), Some("sort" -> sort), Some("direction" -> direction) ).flatten _executeRequest( "GET", s"/users/${play.utils.UriEncoding.encodePathSegment(username, "UTF-8")}/repos", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.Repository]", r, _.validate[Seq[io.flow.github.v0.models.Repository]] ) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } override def getOrgsAndReposByOrg( org: String, page: Long = 1L, `type`: String = "all", sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] = { val queryParameters = Seq( Some("page" -> page.toString), Some("type" -> `type`), Some("sort" -> sort), Some("direction" -> direction) ).flatten _executeRequest( "GET", s"/orgs/${play.utils.UriEncoding.encodePathSegment(org, "UTF-8")}/repos", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.Repository]", r, _.validate[Seq[io.flow.github.v0.models.Repository]] ) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } } object Tags extends Tags { override def getTags( owner: String, repo: String, page: Long = 1L, perPage: Long = 30L, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.TagSummary]] = { val queryParameters = Seq( Some("page" -> page.toString), Some("per_page" -> perPage.toString) ).flatten _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/tags", queryParameters = queryParameters, requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.TagSummary]", r, _.validate[Seq[io.flow.github.v0.models.TagSummary]] ) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def getTagsBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Tag] = { _executeRequest( "GET", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/tags/${play.utils.UriEncoding.encodePathSegment(sha, "UTF-8")}", requestHeaders = requestHeaders ).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Tag", r, _.validate[io.flow.github.v0.models.Tag]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 404") } } override def postGitAndTags( owner: String, repo: String, tagForm: io.flow.github.v0.models.TagForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Tag] = { val payload = play.api.libs.json.Json.toJson(tagForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/tags", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.Tag", r, _.validate[io.flow.github.v0.models.Tag]) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } } object Trees extends Trees { override def post( owner: String, repo: String, createTreeForm: io.flow.github.v0.models.CreateTreeForm, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[io.flow.github.v0.models.CreateTreeResponse] = { val payload = play.api.libs.json.Json.toJson(createTreeForm) _executeRequest( "POST", s"/repos/${play.utils.UriEncoding.encodePathSegment(owner, "UTF-8")}/${play.utils.UriEncoding .encodePathSegment(repo, "UTF-8")}/git/trees", body = Some(payload), requestHeaders = requestHeaders ).map { case r if r.status == 201 => _root_.io.flow.github.v0.Client.parseJson( "io.flow.github.v0.models.CreateTreeResponse", r, _.validate[io.flow.github.v0.models.CreateTreeResponse] ) case r if r.status == 404 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r if r.status == 422 => throw io.flow.github.v0.errors.UnprocessableEntityResponse(r) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 201, 404, 422") } } } object UserEmails extends UserEmails { override def get( requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.UserEmail]] = { _executeRequest("GET", s"/user/emails", requestHeaders = requestHeaders).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client.parseJson( "Seq[io.flow.github.v0.models.UserEmail]", r, _.validate[Seq[io.flow.github.v0.models.UserEmail]] ) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } } object Users extends Users { override def getUser( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.User] = { _executeRequest("GET", s"/user", requestHeaders = requestHeaders).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("io.flow.github.v0.models.User", r, _.validate[io.flow.github.v0.models.User]) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } override def getUserAndOrgs( page: Long = 1L, perPage: _root_.scala.Option[Long] = None, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.UserOrg]] = { val queryParameters = Seq( Some("page" -> page.toString), perPage.map("per_page" -> _.toString) ).flatten _executeRequest("GET", s"/user/orgs", queryParameters = queryParameters, requestHeaders = requestHeaders).map { case r if r.status == 200 => _root_.io.flow.github.v0.Client .parseJson("Seq[io.flow.github.v0.models.UserOrg]", r, _.validate[Seq[io.flow.github.v0.models.UserOrg]]) case r if r.status == 401 => throw io.flow.github.v0.errors.UnitResponse(r.status) case r => throw io.flow.github.v0.errors .FailedRequest(r.status, s"Unsupported response code[${r.status}]. Expected: 200, 401") } } } def _requestHolder(path: String): play.api.libs.ws.WSRequest = { val holder = ws .url(baseUrl + path) .addHttpHeaders( "User-Agent" -> Constants.UserAgent, "X-Apidoc-Version" -> Constants.Version, "X-Apidoc-Version-Major" -> Constants.VersionMajor.toString ) .addHttpHeaders(defaultHeaders: _*) auth.fold(holder) { case Authorization.Basic(username, password) => { holder.withAuth(username, password.getOrElse(""), play.api.libs.ws.WSAuthScheme.BASIC) } } } def _logRequest(method: String, req: play.api.libs.ws.WSRequest): play.api.libs.ws.WSRequest = { val queryComponents = for { (name, values) <- req.queryString value <- values } yield s"$name=$value" val url = s"${req.url}${queryComponents.mkString("?", "&", "")}" auth.fold(logger.info(s"curl -X $method '$url'")) { _ => logger.info(s"curl -X $method -u '[REDACTED]:' '$url'") } req } def _executeRequest( method: String, path: String, queryParameters: Seq[(String, String)] = Nil, requestHeaders: Seq[(String, String)] = Nil, body: Option[play.api.libs.json.JsValue] = None ): scala.concurrent.Future[play.api.libs.ws.WSResponse] = { method.toUpperCase match { case "GET" => { _logRequest( "GET", _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ).get() } case "POST" => { _logRequest( "POST", _requestHolder(path) .addHttpHeaders(_withJsonContentType(requestHeaders): _*) .addQueryStringParameters(queryParameters: _*) ).post(body.getOrElse(play.api.libs.json.Json.obj())) } case "PUT" => { _logRequest( "PUT", _requestHolder(path) .addHttpHeaders(_withJsonContentType(requestHeaders): _*) .addQueryStringParameters(queryParameters: _*) ).put(body.getOrElse(play.api.libs.json.Json.obj())) } case "PATCH" => { _logRequest( "PATCH", _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ).patch(body.getOrElse(play.api.libs.json.Json.obj())) } case "DELETE" => { _logRequest( "DELETE", _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ).delete() } case "HEAD" => { _logRequest( "HEAD", _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ).head() } case "OPTIONS" => { _logRequest( "OPTIONS", _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ).options() } case _ => { _logRequest( method, _requestHolder(path).addHttpHeaders(requestHeaders: _*).addQueryStringParameters(queryParameters: _*) ) sys.error("Unsupported method[%s]".format(method)) } } } /** * Adds a Content-Type: application/json header unless the specified requestHeaders * already contain a Content-Type header */ def _withJsonContentType(headers: Seq[(String, String)]): Seq[(String, String)] = { headers.find { _._1.toUpperCase == "CONTENT-TYPE" } match { case None => headers ++ Seq("Content-Type" -> "application/json; charset=UTF-8") case Some(_) => headers } } } object Client { def parseJson[T]( className: String, r: play.api.libs.ws.WSResponse, f: (play.api.libs.json.JsValue => play.api.libs.json.JsResult[T]) ): T = { f(play.api.libs.json.Json.parse(r.body)) match { case play.api.libs.json.JsSuccess(x, _) => x case play.api.libs.json.JsError(errors) => { throw io.flow.github.v0.errors .FailedRequest(r.status, s"Invalid json for class[" + className + "]: " + errors.mkString(" ")) } } } } sealed trait Authorization extends _root_.scala.Product with _root_.scala.Serializable object Authorization { final case class Basic(username: String, password: Option[String] = None) extends Authorization } package interfaces { trait Client { def baseUrl: String def blobs: io.flow.github.v0.Blobs def commits: io.flow.github.v0.Commits def contents: io.flow.github.v0.Contents def hooks: io.flow.github.v0.Hooks def pullRequests: io.flow.github.v0.PullRequests def refs: io.flow.github.v0.Refs def repositories: io.flow.github.v0.Repositories def tags: io.flow.github.v0.Tags def trees: io.flow.github.v0.Trees def userEmails: io.flow.github.v0.UserEmails def users: io.flow.github.v0.Users } } trait Blobs { def getBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Blob] def post( owner: String, repo: String, blobForm: io.flow.github.v0.models.BlobForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.BlobCreated] } trait Commits { def getBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Commit] def post( owner: String, repo: String, commitForm: io.flow.github.v0.models.CommitForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.CommitResponse] } trait Contents { def getReadme( owner: String, repo: String, ref: String = "main", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Contents] def getContentsByPath( owner: String, repo: String, path: String, ref: String = "main", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Contents] } trait Hooks { def get( owner: String, repo: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Hook]] def getById( owner: String, repo: String, id: Long, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Hook] def post( owner: String, repo: String, hookForm: io.flow.github.v0.models.HookForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Hook] def deleteById( owner: String, repo: String, id: Long, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Unit] } trait PullRequests { def post( owner: String, repo: String, pullRequestForm: io.flow.github.v0.models.PullRequestForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.PullRequest] def get( owner: String, repo: String, page: Long = 1L, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[Seq[io.flow.github.v0.models.PullRequest]] } trait Refs { def get( owner: String, repo: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Ref]] def getByRef( owner: String, repo: String, ref: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] def post( owner: String, repo: String, refForm: io.flow.github.v0.models.RefForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] def putByRef( owner: String, repo: String, ref: String, refUpdateForm: io.flow.github.v0.models.RefUpdateForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Ref] } trait Repositories { def getUserAndRepos( page: Long = 1L, visibility: io.flow.github.v0.models.Visibility = io.flow.github.v0.models.Visibility.All, affiliation: _root_.scala.Option[String] = None, `type`: _root_.scala.Option[String] = None, sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] /** * List public repositories for the specified user. */ def getUsersAndReposByUsername( username: String, page: Long = 1L, `type`: String = "owner", sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] /** * List repositories for the specified org. */ def getOrgsAndReposByOrg( org: String, page: Long = 1L, `type`: String = "all", sort: String = "full_name", direction: String = "asc", requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.Repository]] } trait Tags { def getTags( owner: String, repo: String, page: Long = 1L, perPage: Long = 30L, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.TagSummary]] def getTagsBySha( owner: String, repo: String, sha: String, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Tag] def postGitAndTags( owner: String, repo: String, tagForm: io.flow.github.v0.models.TagForm, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.Tag] } trait Trees { def post( owner: String, repo: String, createTreeForm: io.flow.github.v0.models.CreateTreeForm, requestHeaders: Seq[(String, String)] = Nil )( implicit ec: scala.concurrent.ExecutionContext ): scala.concurrent.Future[io.flow.github.v0.models.CreateTreeResponse] } trait UserEmails { def get( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.UserEmail]] } trait Users { def getUser( requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[io.flow.github.v0.models.User] def getUserAndOrgs( page: Long = 1L, perPage: _root_.scala.Option[Long] = None, requestHeaders: Seq[(String, String)] = Nil )(implicit ec: scala.concurrent.ExecutionContext): scala.concurrent.Future[Seq[io.flow.github.v0.models.UserOrg]] } package errors { import io.flow.github.v0.models.json._ final case class UnitResponse(status: Int) extends Exception(s"HTTP $status") final case class UnprocessableEntityResponse( response: play.api.libs.ws.WSResponse, message: Option[String] = None ) extends Exception(message.getOrElse(s"${response.status}: ${response.body}")) { lazy val unprocessableEntity = _root_.io.flow.github.v0.Client.parseJson( "io.flow.github.v0.models.UnprocessableEntity", response, _.validate[io.flow.github.v0.models.UnprocessableEntity] ) } final case class FailedRequest(responseCode: Int, message: String, requestUri: Option[_root_.java.net.URI] = None) extends _root_.java.lang.Exception(s"HTTP $responseCode: $message") } }