feat: Add _getOpenedPRs for BitBucket

Author: jerryzhang222

index.js

@@ -645,6 +645,35 @@ class BitbucketScm extends Scm {
         return Promise.resolve({ name: 'sd-checkout-code', command: command.join(' && ') });
     }
 
+    /**
+    * Get list of objects (each consists of opened PR name and ref (branch)) of a pipeline
+    * @method getOpenedPRs
+    * @param  {Object}   config              Configuration
+    * @param  {String}   config.scmUri       The scmUri to get opened PRs
+    * @param  {String}   config.token        The token used to authenticate to the SCM
+    * @return {Promise}
+    */
+    _getOpenedPRs(config) {
+        const repoId = getScmUriParts(config.scmUri)[1];
+
+        return this.breaker.runCommand({
+            json: true,
+            login_type: 'oauth2',
+            method: 'GET',
+            oauth_access_token: config.token,
+            url: `${API_URL_V2}/repositories/${repoId}/pullrequests`
+        }).then((response) => {
+            checkResponseError(response);
+
+            const prList = response.body.values;
+
+            return prList.map(pr => ({
+                name: `PR-${pr.id}`,
+                ref: pr.source.branch.name
+            }));
+        });
+    }
+
     /**
      * Retrieve stats for the scm
      * @method stats
@@ -653,6 +682,7 @@ class BitbucketScm extends Scm {
     stats() {
         return this.breaker.stats();
     }
+
 }
 
 module.exports = BitbucketScm;

test/index.test.js

@@ -1458,4 +1458,37 @@ describe('index', function () {
             });
         });
     });
+
+    describe('_getOpenedPRs', () => {
+        const oauthToken = 'oauthToken';
+        const scmUri = 'hostName:repoId:branchName';
+
+        it('returns response of expected format from Bitbucket', () => {
+            requestMock.yieldsAsync(null, {
+                body: {
+                    values: [{
+                        id: 1,
+                        source: {
+                            branch: {
+                                name: 'testbranch'
+                            }
+                        }
+                    }]
+                },
+                statusCode: 200
+            });
+
+            // eslint-disable-next-line no-underscore-dangle
+            return scm._getOpenedPRs({
+                scmUri,
+                token: oauthToken
+            })
+            .then(response =>
+                assert.deepEqual(response, [{
+                    name: 'PR-1',
+                    ref: 'testbranch'
+                }])
+            );
+        });
+    });
 });