-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver_html.py
70 lines (55 loc) · 2.14 KB
/
server_html.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
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
from http.server import BaseHTTPRequestHandler, HTTPServer
import time
import random
from cortex2 import EmotivCortex2Client
from paho.mqtt import client as mqtt_client
hostName = "localhost"
serverPort = 8080
lc = "utf-8"
# =========================================================================
url = "wss://localhost:6868"
emotive = None
profile_name = "FakeBCI"
CLIENT_ID = "bhOr0ZmsLWZVDeFl0QHE08e05lDI36blefUxfbLX"
CLIENT_SECRET = "BL3OlfhwzzPMXcxgFYT7uxaB6LSEAlwdLfqU4OG2oRJkRbQg63h4KMpvNp3144pOsybUpNLDrPQXuDXRC18oyIQUxh6Jum9ktR3nTNwChLW1ZdCcpzcuaavycLD000wK"
STREAM = "com"
# =============================================================================
def connect_cortexAPI():
global emotive
emotive = EmotivCortex2Client(url,
client_id=CLIENT_ID,
client_secret=CLIENT_SECRET,
check_response=True,
authenticate=True,
debug=False)
def get_com_emotiv():
global emotive
emotive.request_access()
emotive.authenticate()
emotive.query_headsets()
emotive.connect_headset(0)
emotive.create_session(0)
emotive.load_profile(profile_name)
emotive.subscribe(streams=[STREAM])
emotive.mental_command_action_sensitivity("get", profile_name)
# =========================================================================
def add_element(s, str):
s.wfile.write(bytes(str, lc))
class KHKT_BCI(BaseHTTPRequestHandler):
def do_GET(seft):
seft.send_response(200)
seft.send_header("Content-type", "text/html")
seft.end_headers()
add_element(seft, "<html><head><title>BCI_KHKT</title></head>")
add_element(seft, "<body>")
add_element(seft, "<p style='font-size:35px;'>hello world</p>")
add_element(seft, "</body></html>")
if __name__ == "__main__":
server = HTTPServer((hostName, serverPort), KHKT_BCI)
print("Server started http://%s:%s" % (hostName, serverPort))
try:
server.serve_forever()
except KeyboardInterrupt:
pass
server.server_close()
print("Server stopped.")