pyenv_wsio/test.py at master · graphisoft-python/pyenv_wsio · GitHub

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
import pyenv_wsio
import time


ws = pyenv_wsio.Client()


def namespaceConnect(nsp):
    print 'namespace connect', nsp.name
    nsp.send(123456,'sendString')
    nsp.emit('aaaaaa', {'pop': 0000}, callback=emitAck)
    nsp.emit('bbbbbb',678967)

def namespaceDisconnect(nsp):
    print 'namespace disconnect',nsp.name

def emitAck(stri,num,obj):
  print 'emitAck'
  print stri
  print num
  print obj
  pass

def on_cccccc(num,stri):
  print 'on_cccccc'
  print num
  print stri
  pass

def on_dddddd(num,stri,ack):
  print 'on_dddddd'
  print num
  print stri
  ack('retAck',900000)


rootNsp= ws.of('/')
rootNsp.on('connect', namespaceConnect)
rootNsp.on('cccccc',on_cccccc)
rootNsp.on('dddddd',on_dddddd)
rootNsp.on('disconnect',namespaceDisconnect)

ws.of('/admin').on('connect', namespaceConnect).on('disconnect',namespaceDisconnect)

ws.connect('ws://localhost:12000/admin', header={"userid":"from_python"})

# rootNsp.emit('aaaaaa', 'abc', 456, {'pop': 0000}, callback=emitAck)
# rootNsp.emit('aaaaaa', 'abc', callback=emitAck)
# rootNsp.emit('aaaaaa', callback=emitAck)


print ws.sid
# emit=pyenv_wsio.EventEmitter()

# def aaaa(arg1,arg2):
#   print arg1,arg2

# emit.on("opened",aaaa)

# emit.emit("opened",u"a123",890)

# print "wait ws Connect"

time.sleep(5)

ws.disconnect()

while(True):
    #   # print ws.recv()
    pass
# # print ws.recv()