OSCTest/restMulti.py at main · Estudio-Guto-Requena/OSCTest · 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
72
73
74
75
76
from http.server import HTTPServer, BaseHTTPRequestHandler
import json
import random
import sys
import time
from threading import Thread
PORT = 9000
HOST = '0.0.0.0'

start = False;
n = 0

def getkey():
    global start
    while (True):
        key = input()
        if(key == 'f' and not start):
            start = True
            print("[+] Start Event")
        elif(key == 's' and start):
            start = False
            print("[-] Stop Event")
        time.sleep(0.5)

class TestHandler(BaseHTTPRequestHandler):
    def do_GET(self):
        self.send_response(200)
        self.send_header('Content-type', 'application/json')
        self.end_headers()
        if ('/' in self.path):
            outJson = {}
            sensorsMock = {}
            outJson['start'] = start

            for i in range(0, n):
                sensorsMock[i] = {'bpm': random.randint(80, 90), 'ip': "192.168.0.1"+str(i), 'pos': str(i), 'onFinger': True,  'Accessing': True, 'battery': 3.3}

            for i in range(0, 15-n):
                sensorsMock[15-i] = {'bpm': random.randint(80, 90), 'ip': "192.168.0.2"+str(i), 'pos': str(i), 'onFinger': False,  'Accessing': False, 'battery': -1}

            outJson['online'] = sensorsMock
            outJson['actives'] = n

        self.wfile.write(json.dumps(outJson).encode())

    def do_POST(self):
        self.send_response(200)
        self.send_header('Content-type', 'application/json')
        self.end_headers()
        if ('/' in self.path):
            outJson = {}
            sensorsMock = {}
            outJson['start'] = start
            for i in range(0, n):
                sensorsMock[i] = {'bpm': random.randint(80, 90), 'onFinger': True}
            outJson['online'] = sensorsMock

        self.wfile.write(json.dumps(outJson).encode())

def startHTTP_server():
    """Start the server."""
    server_address = ('', PORT)
    server_HTTP = HTTPServer(server_address, TestHandler)
    server_HTTP.serve_forever()

if __name__ == "__main__":
    print("Press f + Enter to simulate start event")
    print("Press s + Enter to stop event")
    try:
        Thread(target=getkey).start()
        if(len(sys.argv) > 1):
            n = int(sys.argv[1])
        print("The server has been planted! Running...")
        startHTTP_server()
    except KeyboardInterrupt:
        print("Exiting")