no way to compare when less than two revisions

Differences

This shows you the differences between two versions of the page.

@@ Line 1: / Line 1: @@
+====== Triggering Bitbucket Server Pull Request builds ======
+The following code can be used within Jenkins job triggered every few minutes.
+It will get a list of currently open pull requests. Then get build data for every last commit in pull request. If the commit is not build then trigger Jenkins job.
+<code python>
+# -*- coding: utf-8 -*-
+import requests, re, os, json, datetime, time
+from requests.auth import HTTPBasicAuth
+JENKINS_URL   = os.environ['JENKINS_URL']
+STASH_URL     = os.environ['STASH_URL']
+JOB_NAME      = 'JOB_NAME'
+JENKINS_TRIG  = JENKINS_URL+"/job/"+JOB_NAME+"/buildWithParameters"
+CREDENTIALS   = os.environ['CREDENTIALS'].split(':') # ex user:password
+STASH_PRLIST  = STASH_URL + "/rest/api/1.0/projects/PROJECT/repos/REPO/pull-requests"
+STASH_PRLIST += r"?limit=20&withAttributes=false&withProperties=false"
+STASH_BUILDS  = STASH_URL + "/rest/build-status/1.0/commits/"
+JOB_TOKEN     = r"POOLINGISBAD"
+userAuth      = HTTPBasicAuth(CREDENTIALS[0], CREDENTIALS[1])
+pull_requests = []
+trigger       = []
+print('Fetching list of open Pull Requests',
+      STASH_PRLIST,
+      datetime.datetime.utcnow().isoformat(),
+      'UTC')
+def getPullRequestsList():
+    isLastPage    = False
+    nextPageStart = 0
+    while not isLastPage:
+        spage = '' if nextPageStart is 0 else '&start='+str(nextPageStart)
+        r     = requests.get(STASH_PRLIST + spage, auth=userAuth, timeout=10)
+        if r.status_code is not requests.codes.ok:
+            raise Exception('Failed to fetch list of open PRs',
+                            [r.status_code, r.text])
+        data          = json.loads(r.text)
+        isLastPage    = data['isLastPage']
+        nextPageStart = data.get('nextPageStart', 0)
+	pull_requests.extend(data['values'])
+    return pull_requests
+def checkAndTriggerIfRequired():
+    for PR in getPullRequestsList():
+        PR_commit = PR['fromRef']['latestCommit']
+        PR_title  = PR['title']
+        PR_id     = PR['id']
+        r         = requests.get(STASH_BUILDS + PR_commit, auth=userAuth, timeout=10)
+        PR_data   = json.loads(r.text)
+        PR_val    = PR_data['values']
+        PR_lastState = 'NULL' if len(PR_val) is 0 else PR_val[0]['state']
+        PR_doTrigger = 'trigger' if PR_lastState is 'NULL' else 'skip'
+        print('\u2022 {:<4} {:} {:<10} {:<7} {:}'.format(PR_id,
+                                                         PR_commit,
+                                                         PR_lastState,
+                                                         PR_doTrigger,
+                                                         PR_title))
+        if PR_doTrigger is 'trigger': trigger.append([PR_id, PR_title])
+    if len(trigger) is 0:
+        print('Nothing to trigger.')
+        return 0
+	print()
+    for trig in trigger:
+        URL = JENKINS_TRIG+'?token='+JOB_TOKEN+'&ID='+str(trig[0])
+        print('\u2022 Triggering:', trig[1], URL)
+        r = requests.put(URL, auth=userAuth)
+        if r.status_code is not requests.codes.ok:
+            raise Exception('Failed to trigger Jenkins job', [r.status_code, r.text])
+    return 0
+exitcode = checkAndTriggerIfRequired()
+print('Let Jenkins process, start the build and notify Stash')
+print('Doing nothing for mandatory period of 10 seconds')
+time.sleep(10)
+exit(exitcode)
+</code>