fix path for python3 and add a requirements.txt file

Readme.md

@@ -6,7 +6,11 @@ and their imdb rating when use chats with the server.
 
 ### How To Use It
 
-Just run `make runserver` and it will start running the server on http://localhost:8888
+```sh
+mkvirtualenv chat -p $(which pythpn3)
+pip install -r requirements.txt
+python server.py
+```
 
 ### Contact
 

handlers/buffer.py

@@ -6,7 +6,7 @@ class MessageBuffer(object):
     def __init__(self):
         self.waiters = set()
         self.cache = []
-        self.cache_size = 200
+        self.cache_size = 100000
 
     def wait_for_messages(self, cursor=None):
         result_future = Future()

handlers/mainhandler.py

@@ -1,5 +1,5 @@
 import tornado.web
-from buffer import MessageBuffer
+from .buffer import MessageBuffer
 
 global_message_buffer = MessageBuffer()
 

handlers/newmessage.py

@@ -1,7 +1,7 @@
 import tornado.web
 import uuid
 import json
-from buffer import MessageBuffer
+from .buffer import MessageBuffer
 
 global_message_buffer = MessageBuffer()
 

handlers/routes.py

@@ -1,9 +1,10 @@
 from handlers.mainhandler import MainHandler
 from handlers.newmessage import MessageNewHandler
-from handlers.updatemessage import MessageUpdatesHandler
+from handlers.updatemessage import MessageUpdatesHandler, EchoWebSocket
 
 route = [
             (r"/", MainHandler),
             (r"/a/message/new", MessageNewHandler),
+            (r"/websocket", EchoWebSocket),
             (r"/a/message/updates", MessageUpdatesHandler),
         ]

handlers/updatemessage.py

@@ -1,7 +1,7 @@
 import tornado.web
-from buffer import MessageBuffer
+from .buffer import MessageBuffer
 from tornado import gen
-
+from tornado.websocket import WebSocketHandler
 global_message_buffer = MessageBuffer()
 
 
@@ -19,3 +19,14 @@ def post(self):
 
     def on_connection_close(self):
         global_message_buffer.cancel_wait(self.future)
+
+
+class EchoWebSocket(tornado.websocket.WebSocketHandler):
+    def open(self):
+        print("WebSocket opened")
+
+    def on_message(self, message):
+        self.write_message(u"You said: " + message)
+
+    def on_close(self):
+        print("WebSocket closed")

requirements.txt

@@ -0,0 +1 @@
+tornado==4.5.3

serve.py

@@ -25,6 +25,7 @@ def main():
         xsrf_cookies=False,
         debug=options.debug,
     )
+    print("Server running at http://localhost:8888")
     app.listen(options.port)
     tornado.ioloop.IOLoop.current().start()