5
5
from twisted.protocols import basic
6
6
from twisted.web import resource, server, static, xmlrpc
8
9
class FingerProtocol(basic.LineReceiver):
9
10
def lineReceived(self, user):
10
self.factory.getUser(user
11
).addErrback(lambda _: "Internal error in server"
12
).addCallback(lambda m:
13
(self.transport.write(m+"\r\n"),
14
self.transport.loseConnection()))
15
class FingerSetterProtocol(basic.LineReceiver):
16
def connectionMade(self): self.lines = []
17
def lineReceived(self, line): self.lines.append(line)
18
def connectionLost(self,reason): self.factory.setUser(*self.lines[:2])
11
d = self.factory.getUser(user)
14
return 'Internal error in server'
17
def writeResponse(message):
18
self.transport.write(message + '\r\n')
19
self.transport.loseConnection()
20
d.addCallback(writeResponse)
19
22
class IRCReplyBot(irc.IRCClient):
20
23
def connectionMade(self):
21
24
self.nickname = self.factory.nickname
22
25
irc.IRCClient.connectionMade(self)
23
27
def privmsg(self, user, channel, msg):
24
28
user = user.split('!')[0]
25
29
if self.nickname.lower() == channel.lower():
26
self.factory.getUser(msg
27
).addErrback(lambda _: "Internal error in server"
28
).addCallback(lambda m: irc.IRCClient.msg(self, user, msg+': '+m))
30
d = self.factory.getUser(msg)
33
return 'Internal error in server'
36
def writeResponse(message):
37
irc.IRCClient.msg(self, user, msg+': '+message)
38
d.addCallback(writeResponse)
30
40
class FingerService(service.Service):
31
41
def __init__(self, filename):
32
42
self.filename = filename
36
48
for line in file(self.filename):
37
49
user, status = line.split(':', 1)
38
50
user = user.strip()
39
51
status = status.strip()
40
52
self.users[user] = status
41
53
self.call = reactor.callLater(30, self._read)
42
55
def getUser(self, user):
43
56
return defer.succeed(self.users.get(user, "No such user"))
44
58
def getFingerFactory(self):
45
59
f = protocol.ServerFactory()
46
f.protocol, f.getUser = FingerProtocol, self.getUser
60
f.protocol = FingerProtocol
61
f.getUser = self.getUser
48
64
def getResource(self):
49
65
r = resource.Resource()
50
66
r.getChild = (lambda path, request:
56
72
x.xmlrpc_getUser = self.getUser
57
73
r.putChild('RPC2', x)
59
76
def getIRCBot(self, nickname):
60
77
f = protocol.ReconnectingClientFactory()
61
f.protocol,f.nickname,f.getUser = IRCReplyBot,nickname,self.getUser
78
f.protocol = IRCReplyBot
80
f.getUser = self.getUser
64
83
application = service.Application('finger', uid=1, gid=1)
added
removed
doc/howto/tutorial/listings/finger/finger17.tac
