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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
from __future__ import print_function
from socket import socket, AF_INET, SOCK_STREAM
import json
import time
server = ('127.0.0.1', 2442)
def from_message(content):
try:
return json.loads(content)
except ValueError:
return {}
def to_message(typ, value='', params=None):
if params is None:
params = {}
return json.dumps({'type': typ, 'value': value, 'params': params})
class Client(object):
first = True
def process(self, message):
typ = message.get('type', '')
value = message.get('value', '')
params = message.get('params', {})
if not typ:
return
if typ in ('RX.ACTIVITY',):
# skip
return
print('->', typ)
if value:
print('-> value', value)
if params:
print('-> params: ', params)
def send(self, *args, **kwargs):
params = kwargs.get('params', {})
if '_ID' not in params:
params['_ID'] = '{}'.format(int(time.time()*1000))
kwargs['params'] = params
message = to_message(*args, **kwargs)
print('outgoing message:', message)
self.sock.send(message + '\n') # remember to send the newline at the end :)
def connect(self):
print('connecting to', ':'.join(map(str, server)))
self.sock = socket(AF_INET, SOCK_STREAM)
self.sock.connect(server)
self.connected = True
try:
# send a simple example query after connected
self.send("STATION.GET_STATUS")
while self.connected:
content = self.sock.recv(65500)
if not content:
break
print('incoming message')
try:
message = json.loads(content)
except ValueError:
message = {}
if not message:
continue
self.process(message)
finally:
self.sock.close()
def close(self):
self.connected = False
def main():
s = Client()
s.connect()
if __name__ == '__main__':
main()
|
