1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
import os.path
from zope.interface import implements
from twisted.cred import credentials
from twisted.spread import pb
from twisted.application.internet import TCPClient
from twisted.python import log
import cvstoys.common # to make sure VersionedPatch gets registered
from buildbot.interfaces import IChangeSource
from buildbot.pbutil import ReconnectingPBClientFactory
from buildbot.changes.changes import Change
from buildbot import util
class FreshCVSListener(pb.Referenceable):
def remote_notify(self, root, files, message, user):
try:
self.source.notify(root, files, message, user)
except Exception, e:
print "notify failed"
log.err()
def remote_goodbye(self, message):
pass
class FreshCVSConnectionFactory(ReconnectingPBClientFactory):
def gotPerspective(self, perspective):
log.msg("connected to FreshCVS daemon")
ReconnectingPBClientFactory.gotPerspective(self, perspective)
self.source.connected = True
# TODO: freshcvs-1.0.10 doesn't handle setFilter correctly, it will
# be fixed in the upcoming 1.0.11 . I haven't been able to test it
# to make sure the failure mode is survivable, so I'll just leave
# this out for now.
return
if self.source.prefix is not None:
pathfilter = "^%s" % self.source.prefix
d = perspective.callRemote("setFilter",
None, pathfilter, None)
# ignore failures, setFilter didn't work in 1.0.10 and this is
# just an optimization anyway
d.addErrback(lambda f: None)
def clientConnectionLost(self, connector, reason):
ReconnectingPBClientFactory.clientConnectionLost(self, connector,
reason)
self.source.connected = False
class FreshCVSSourceNewcred(TCPClient, util.ComparableMixin):
"""This source will connect to a FreshCVS server associated with one or
more CVS repositories. Each time a change is committed to a repository,
the server will send us a message describing the change. This message is
used to build a Change object, which is then submitted to the
ChangeMaster.
This class handles freshcvs daemons which use newcred. CVSToys-1.0.9
does not, later versions might.
"""
implements(IChangeSource)
compare_attrs = ["host", "port", "username", "password", "prefix"]
changemaster = None # filled in when we're added
connected = False
def __init__(self, host, port, user, passwd, prefix=None):
self.host = host
self.port = port
self.username = user
self.password = passwd
if prefix is not None and not prefix.endswith("/"):
log.msg("WARNING: prefix '%s' should probably end with a slash" \
% prefix)
self.prefix = prefix
self.listener = l = FreshCVSListener()
l.source = self
self.factory = f = FreshCVSConnectionFactory()
f.source = self
self.creds = credentials.UsernamePassword(user, passwd)
f.startLogin(self.creds, client=l)
TCPClient.__init__(self, host, port, f)
def __repr__(self):
return "<FreshCVSSource where=%s, prefix=%s>" % \
((self.host, self.port), self.prefix)
def describe(self):
online = ""
if not self.connected:
online = " [OFFLINE]"
return "freshcvs %s:%s%s" % (self.host, self.port, online)
def notify(self, root, files, message, user):
pathnames = []
isdir = 0
for f in files:
if not isinstance(f, (cvstoys.common.VersionedPatch,
cvstoys.common.Directory)):
continue
pathname, filename = f.pathname, f.filename
#r1, r2 = getattr(f, 'r1', None), getattr(f, 'r2', None)
if isinstance(f, cvstoys.common.Directory):
isdir = 1
path = os.path.join(pathname, filename)
log.msg("FreshCVS notify '%s'" % path)
if self.prefix:
if path.startswith(self.prefix):
path = path[len(self.prefix):]
else:
continue
pathnames.append(path)
if pathnames:
# now() is close enough: FreshCVS *is* realtime, after all
when=util.now()
c = Change(user, pathnames, message, isdir, when=when)
self.parent.addChange(c)
class FreshCVSSourceOldcred(FreshCVSSourceNewcred):
"""This is for older freshcvs daemons (from CVSToys-1.0.9 and earlier).
"""
def __init__(self, host, port, user, passwd,
serviceName="cvstoys.notify", prefix=None):
self.host = host
self.port = port
self.prefix = prefix
self.listener = l = FreshCVSListener()
l.source = self
self.factory = f = FreshCVSConnectionFactory()
f.source = self
f.startGettingPerspective(user, passwd, serviceName, client=l)
TCPClient.__init__(self, host, port, f)
def __repr__(self):
return "<FreshCVSSourceOldcred where=%s, prefix=%s>" % \
((self.host, self.port), self.prefix)
# this is suitable for CVSToys-1.0.10 and later. If you run CVSToys-1.0.9 or
# earlier, use FreshCVSSourceOldcred instead.
FreshCVSSource = FreshCVSSourceNewcred
|
