Switch branches/tags
Nothing to show
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
executable file 203 lines (166 sloc) 6.52 KB
#! /usr/bin/python
# This is a script which delivers Change events from Darcs to the buildmaster
# each time a patch is pushed into a repository. Add it to the 'apply' hook
# on your canonical "central" repository, by putting something like the
# following in the _darcs/prefs/defaults file of that repository:
# apply posthook /PATH/TO/ BUILDMASTER:PORT
# apply run-posthook
# (the second command is necessary to avoid the usual "do you really want to
# run this hook" prompt. Note that you cannot have multiple 'apply posthook'
# lines: if you need this, you must create a shell script to run all your
# desired commands, then point the posthook at that shell script.)
# Note that both Buildbot and Darcs must be installed on the repository
# machine. You will also need the Python/XML distribution installed (the
# "python2.3-xml" package under debian).
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function
import os
import subprocess
import sys
import xml
from xml.dom import minidom
from twisted.internet import defer
from twisted.internet import reactor
from buildbot.clients import sendchange
def getText(node):
return "".join([
for cn in node.childNodes
if cn.nodeType == cn.TEXT_NODE])
def getTextFromChild(parent, childtype):
children = parent.getElementsByTagName(childtype)
if not children:
return ""
return getText(children[0])
def makeChange(p):
author = p.getAttribute("author")
revision = p.getAttribute("hash")
comments = (getTextFromChild(p, "name") + "\n" +
getTextFromChild(p, "comment"))
summary = p.getElementsByTagName("summary")[0]
files = []
for filenode in summary.childNodes:
if filenode.nodeName in ("add_file", "modify_file", "remove_file"):
filename = getText(filenode).strip()
elif filenode.nodeName == "move":
to_name = filenode.getAttribute("to")
# note that these are all unicode. Because PB can't handle unicode, we
# encode them into ascii, which will blow up early if there's anything we
# can't get to the far side. When we move to something that *can* handle
# unicode (like newpb), remove this.
author = author.encode("ascii", "replace")
comments = comments.encode("ascii", "replace")
files = [f.encode("ascii", "replace") for f in files]
revision = revision.encode("ascii", "replace")
change = {
# note: this is more likely to be a full email address, which would
# make the left-hand "Changes" column kind of wide. The buildmaster
# should probably be improved to display an abbreviation of the
# username.
'username': author,
'revision': revision,
'comments': comments,
'files': files,
return change
def getChangesFromCommand(cmd, count):
out = subprocess.check_output(cmd, shell=True)
out = out.decode(sys.stdout.encoding)
doc = minidom.parseString(out)
except xml.parsers.expat.ExpatError as e:
print("failed to parse XML")
print("purported XML is:")
c = doc.getElementsByTagName("changelog")[0]
changes = []
for i, p in enumerate(c.getElementsByTagName("patch")):
if i >= count:
return changes
def getSomeChanges(count):
cmd = "darcs changes --last=%d --xml-output --summary" % count
return getChangesFromCommand(cmd, count)
LASTCHANGEFILE = ".darcs_buildbot-lastchange"
def findNewChanges():
if os.path.exists(LASTCHANGEFILE):
f = open(LASTCHANGEFILE, "r")
lastchange =
return getSomeChanges(1)
lookback = 10
while True:
changes = getSomeChanges(lookback)
# getSomeChanges returns newest-first, so changes[0] is the newest.
# we want to scan the newest first until we find the changes we sent
# last time, then deliver everything newer than that (and send them
# oldest-first).
for i, c in enumerate(changes):
if c['revision'] == lastchange:
newchanges = changes[:i]
return newchanges
if 2 * lookback > 100:
raise RuntimeError("unable to find our most recent change "
"(%s) in the last %d changes" % (lastchange,
lookback = 2 * lookback
def sendChanges(master):
changes = findNewChanges()
s = sendchange.Sender(master)
d = defer.Deferred()
reactor.callLater(0, d.callback, None)
if not changes:
print(" weird, no changes to send")
elif len(changes) == 1:
print("sending 1 change to buildmaster:")
print("sending %d changes to buildmaster:" % len(changes))
# the Darcs Source class expects revision to be a context, not a
# hash of a patch (which is what we have in c['revision']). For
# the moment, we send None for everything but the most recent, because getting
# contexts is Hard.
# get the context for the most recent change
latestcontext = subprocess.check_output("darcs changes --context", shell=True)
latestcontext = latestcontext.decode(sys.stdout.encoding)
changes[-1]['context'] = latestcontext
def _send(res, c):
branch = None
print(" %s" % c['revision'])
return s.send(branch, c.get('context'), c['comments'], c['files'],
c['username'], vc='darcs')
for c in changes:
d.addCallback(_send, c)
def printSuccess(res):
num_changes = len(changes)
if num_changes > 1:
print("%d changes sent successfully" % num_changes)
elif num_changes == 1:
print("change sent successfully")
print("no changes to send")
def printFailure(why):
print("change(s) NOT sent, something went wrong: " + str(why))
d.addCallbacks(printSuccess, printFailure)
d.addBoth(lambda _: reactor.stop)
if changes:
lastchange = changes[-1]['revision']
f = open(LASTCHANGEFILE, "w")
if __name__ == '__main__':
MASTER = sys.argv[1]