return response
def create_session(self):
- session_id = random_string(10)
- session = HttpSession(session_id)
- self.dispatcher.add_session(session)
+ session_id = random_string(20)
+ session = HttpSession(self.dispatcher, session_id)
return session_id
def poll_session(self, session):
self.send_response(200)
self.send_header('Allow', 'GET, POST, OPTIONS')
self.send_header('Access-Control-Allow-Origin', '*')
- self.send_header('Access-Control-Allow-Headers', '*')
+ self.send_header('Access-Control-Allow-Headers', 'Cache-Control, Content-Language, Content-Type, Expires, Last-Modified, Pragma, Accept-Language, Accept, Origin')
self.send_header('Content-Length', '0')
self.end_headers()
class HttpSession(Session):
- def __init__(self, session_id):
- Session.__init__(self)
+ def __init__(self, dispatcher, session_id):
+ Session.__init__(self, dispatcher)
self.pending_responses = Queue.Queue()
self.address = session_id
self.name = "HTTP"
+ self.timeout = 60
+ self.dispatcher.add_session(self)
def send_response(self, response):
raw_response = json.dumps(response)
self.pending_responses.put(response)
- def stopped(self):
- with self.lock:
- if time.time() - self.time > 60:
- self._stopped = True
- return self._stopped
class HttpServer(threading.Thread):