Class BitBucketCloudAPI

source/platforms/bitbucket_cloud/BitBucketCloudAPI.ts:84–411

}

export class BitBucketCloudAPI implements BitBucketCloudAPIDSL {
  fetch: typeof fetch
  accessToken: string | undefined
  uuid: string | undefined

  private readonly d = debug("BitBucketCloudAPI")
  private pr: BitBucketCloudPRDSL | undefined
  private commits: BitBucketCloudCommit[] | undefined
  private baseURL = "https://api.bitbucket.org/2.0"
  private oauthURL = "https://bitbucket.org/site/oauth2/access_token"

  constructor(public readonly repoMetadata: RepoMetaData, public readonly credentials: BitBucketCloudCredentials) {
    // This allows Peril to DI in a new Fetch function
    // which can handle unique API edge-cases around integrations
    this.fetch = fetch

    // Backward compatible,
    this.uuid = credentials.uuid
  }

  getBaseRepoURL() {
    const { repoSlug } = this.repoMetadata
    return `${this.baseURL}/repositories/${repoSlug}`
  }

  getPRURL() {
    const { pullRequestID } = this.repoMetadata
    return `${this.getBaseRepoURL()}/pullrequests/${pullRequestID}`
  }

  getPullRequestsFromBranch = async (branch: string): Promise<BitBucketCloudPRDSL[]> => {
    // Need to encode URI here because it used special characters in query params.
    // https://developer.atlassian.com/bitbucket/api/2/reference/resource/repositories/%7Busername%7D/%7Brepo_slug%7D/pullrequests
    let nextPageURL: string | undefined = encodeURI(
      `${this.getBaseRepoURL()}/pullrequests?q=source.branch.name = "${branch}"`
    )
    let values: BitBucketCloudPRDSL[] = []

    do {
      const res = await this.get(nextPageURL)
      throwIfNotOk(res)

      const data = (await res.json()) as BitBucketCloudPagedResponse<BitBucketCloudPRDSL>

      values = values.concat(data.values)

      nextPageURL = data.next
    } while (nextPageURL != null)

    return values
  }

  getPullRequestInfo = async (): Promise<BitBucketCloudPRDSL> => {
    if (this.pr) {
      return this.pr
    }
    const res = await this.get(this.getPRURL())
    throwIfNotOk(res)