server/blinken_handler.py

   1 from __future__ import with_statement
   2 from SocketServer import BaseRequestHandler
   3
   4 M_OKAY = 'okay\r\n'
   5 M_NOPE = 'nope\r\n'
   6
   7 class BlinkenHandler(BaseRequestHandler):
   8     def handle(self):
   9         self.server.close_request = lambda request : None
  10
  11         send = self.request.send
  12         recv = self.request.recv
  13         data = recv(4096)
  14         coords = tuple(int(i) for i in data.split(':'))
  15         if len(coords) == 2:
  16             with self.server.lock:
  17                 self.server.connections[coords] = self.request
  18             send(M_OKAY)
  19         else:
  20             send(M_NOPE)
  21             self.request.close()
  22
  23     def finish(self):
  24         pass
  25