from tornado import gen
class NewMessageHandler(tornado.web.RequestHandler):
@tornado.web.asynchronous
@gen.coroutine
def post(self):
msg = self.get_argument('msg')
db = self.settings['db']
result = yield db.messages.insert({'msg': msg})
self.redirect('/')
class MessagesHandler(tornado.web.RequestHandler):
@tornado.web.asynchronous
@gen.coroutine
def get(self):
self.write('<a href="/compose">Compose a message</a><br>')
self.write('<ul>')
db = self.settings['db']
cursor = db.messages.find().sort([('_id', -1)])
while (yield cursor.fetch_next):
message = cursor.next_object()
self.write('<li>%s</li>' % message['msg'])
self.write('</ul>')
self.finish()