override def getOpenMergeRequests()

in app/services/GithubAPI.scala [230:244]

15 lines of code
3 McCabe index (conditional complexity)


  override def getOpenMergeRequests(projectId: String, forStatus: Option[MergeRequestState]): Future[Either[circe.Error, Seq[MergeRequest]]] = {
    getHttp
      .singleRequest(makeRequest("repos",s"${URLEncoder.encode(projectId, StandardCharsets.UTF_8)}/pulls?state=open"))
      .flatMap(response=>{
        response.status match {
          case StatusCodes.OK=>
            unmarshalContent[Seq[GitHubPR]](consumeResponseContent(response)).map(_.map(_.map(_.mapToGitlab)))
          case _=>
            consumeResponseContent(response).flatMap(content=> {
              logger.error(s"Could not get pull requests for $projectId, server returned ${response.status} ${content.utf8String}")
              Future.failed(new RuntimeException("External server error"))
            })
        }
      })
  }