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
|
from twisted.internet.defer import Deferred
from twisted.internet.endpoints import TCP4ServerEndpoint
from twisted.internet.protocol import Factory
from twisted.internet.task import react
from parsley import makeProtocol
grammar = """
nonzeroDigit = digit:x ?(x != '0')
digits = <'0' | nonzeroDigit digit*>:i -> int(i)
netstring :delimiter = digits:length delimiter <anything{length}>:string ',' -> string
colon = digits:length ':' <anything{length}>:string ',' -> receiver.netstringReceived(':', string)
semicolon = digits:length ';' <anything{length}>:string ',' -> receiver.netstringReceived(';', string)
"""
class NetstringSender(object):
def __init__(self, transport):
self.transport = transport
def sendNetstring(self, string):
print 'received', repr(string)
class NetstringReceiver(object):
currentRule = 'colon'
def __init__(self, sender):
self.sender = sender
def prepareParsing(self, parser):
pass
def finishParsing(self, reason):
reason.printTraceback()
def netstringReceived(self, delimiter, string):
self.sender.sendNetstring(string)
if delimiter == ':':
self.currentRule = 'semicolon'
else:
self.currentRule = 'colon'
NetstringProtocol = makeProtocol(
grammar, NetstringSender, NetstringReceiver)
class NetstringFactory(Factory):
protocol = NetstringProtocol
def main(reactor):
server = TCP4ServerEndpoint(reactor, 1234)
d = server.listen(NetstringFactory())
d.addCallback(lambda p: Deferred()) # listen forever
return d
react(main, [])
|
