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
|
from twisted.internet.defer import Deferred
from twisted.internet.endpoints import TCP4ServerEndpoint
from twisted.internet.protocol import ServerFactory
from twisted.internet.task import react
from parsley import makeProtocol
from netstrings import grammar, NetstringSender
class NetstringReverserReceiver(object):
currentRule = 'receiveNetstring'
def __init__(self, sender):
self.sender = sender
def prepareParsing(self, parser):
pass
def finishParsing(self, reason):
pass
def netstringReceived(self, string):
self.sender.sendNetstring(string[::-1])
NetstringReverser = makeProtocol(
grammar, NetstringSender, NetstringReverserReceiver)
class NetstringReverserFactory(ServerFactory):
protocol = NetstringReverser
def main(reactor):
server = TCP4ServerEndpoint(reactor, 1234)
d = server.listen(NetstringReverserFactory())
d.addCallback(lambda p: Deferred())
return d
react(main, [])
|
