-
Notifications
You must be signed in to change notification settings - Fork 2
/
emitter.py
44 lines (32 loc) · 928 Bytes
/
emitter.py
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
#!/usr/bin/env python
from flask import Flask
import socket
__author__ = 'Wolfrax'
app = Flask(__name__)
cfg_server_address = 'localhost'
cfg_server_port = 5051
def get_msg(message):
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect((cfg_server_address, cfg_server_port))
data = []
try:
sock.sendall(message)
while True:
stream = sock.recv(1024)
if not stream:
break
else:
data.append(stream)
data = ''.join(data)
finally:
sock.close()
return data
@app.route("/spots/data")
def spots_data():
return get_msg("GET DATA STR")
@app.route("/spots/statistics")
def spots_statistics():
return get_msg("GET STATISTICS STR")
if __name__ == "__main__":
print "Will listen on {}:{}".format(cfg_server_address, cfg_server_port)
app.run(host='0.0.0.0', debug=True)