← Back to branch summary

~justin-fathomdb/nova/justinsb-openstack-api-volumes

« back to all changes in this revision

Viewing changes to vendor/Twisted-10.0.0/doc/core/howto/tutorial/listings/finger/finger14.tac

  • Committer: Jesse Andrews
  • Date: 2010-05-28 06:05:26 UTC
  • Revision ID: git-v1:bf6e6e718cdc7488e2da87b21e258ccc065fe499
initial commit

Show diffs side-by-side

added added

removed removed

Lines of Context:
vendor/Twisted-10.0.0/doc/core/howto/tutorial/listings/finger/finger14.tac
 
1
# Read from file
 
2
from twisted.application import internet, service
 
3
from twisted.internet import protocol, reactor, defer
 
4
from twisted.protocols import basic
 
5
 
 
6
class FingerProtocol(basic.LineReceiver):
 
7
    def lineReceived(self, user):
 
8
        d = self.factory.getUser(user)
 
9
 
 
10
        def onError(err):
 
11
            return 'Internal error in server'
 
12
        d.addErrback(onError)
 
13
 
 
14
        def writeResponse(message):
 
15
            self.transport.write(message + '\r\n')
 
16
            self.transport.loseConnection()
 
17
        d.addCallback(writeResponse)
 
18
 
 
19
class FingerService(service.Service):
 
20
    def __init__(self, filename):
 
21
        self.users = {}
 
22
        self.filename = filename
 
23
        self._read()
 
24
 
 
25
    def _read(self):
 
26
        for line in file(self.filename):
 
27
            user, status = line.split(':', 1)
 
28
            user = user.strip()
 
29
            status = status.strip()
 
30
            self.users[user] = status
 
31
        self.call = reactor.callLater(30, self._read)
 
32
 
 
33
    def startService(self):
 
34
        self._read()
 
35
        service.Service.startService(self)
 
36
 
 
37
    def stopService(self):
 
38
        service.Service.stopService(self)
 
39
        self.call.cancel()
 
40
 
 
41
    def getUser(self, user):
 
42
        return defer.succeed(self.users.get(user, "No such user"))
 
43
 
 
44
    def getFingerFactory(self):
 
45
        f = protocol.ServerFactory()
 
46
        f.protocol = FingerProtocol
 
47
        f.getUser = self.getUser
 
48
        return f
 
49
 
 
50
application = service.Application('finger', uid=1, gid=1)
 
51
f = FingerService('/etc/users')
 
52
finger = internet.TCPServer(79, f.getFingerFactory())
 
53
 
 
54
finger.setServiceParent(service.IServiceCollection(application))
 
55
f.setServiceParent(service.IServiceCollection(application))