Update SpaceFace.py

SpaceFace.py

@@ -8,6 +8,7 @@ global conn
 global projectid
 global endpoint
 global users
+
 projectid = os.getenv("ProjectID")
 users = {}
 session = scratch3.login(os.getenv("Username"), os.getenv("Password"))
@@ -86,12 +87,16 @@ class ConnectionEndpoint:
         users[r] = User(message, r)
         responder.respond(r)
         responder.close()
+class HeartbeatEndpoint:
+    def receivedMessage(self, message, user, responder):
+        responder.close()
 
 def thread(n):
     global users
     global conn
     global projectid
     global endpoint
+    heartbeater = HeartbeatEndpoint()
     conn.set_var("channel "+str(n), "0")
     while True:
         
@@ -118,7 +123,10 @@ def thread(n):
             else:
                 user = UserStartup()
             respond = Responder(projectid, n, acceptstaticpayload, acceptstreamingpayload, value, user)
-            endpoint[reqendpoint].receivedMessage(payload, user, respond)
+            if reqendpoint == 31:
+                heartbeater.receivedMessage(payload, user, respond)
+            else:
+                endpoint[reqendpoint].receivedMessage(payload, user, respond)
 
 
 def start_server(endpoints):
@@ -129,6 +137,8 @@ def start_server(endpoints):
     endpoint = endpoints
     conn = session.connect_cloud(projectid)
     threads = [threading.Thread(target=thread, args=(i+1,)) for i in range(10)]
-    for t in threads:
-        t.start()
-    return t
+    while True:
+        time.sleep(1)
+        for k, v in users:
+            if time.time() - v.last_request >= 300:
+                del users[k]