import cgi
import hashlib
import wsgiref.handlers
import os
import urllib
import unittest
from google.appengine.ext.webapp import template
from google.appengine.api import urlfetch
from google.appengine.ext import db
from google.appengine.ext import webapp
 
class Message(db.Model):
	queue_name = db.StringProperty()
	body = db.StringProperty(multiline=True)
	date = db.DateTimeProperty(auto_now_add=True)
 
class Push(webapp.RequestHandler):
	def post(self):
		message = Message()
 
		message.queue_name = self.request.get('queue_name')
		message.body = self.request.get('message_body')
		message.put()
 
 
		message_hash = hashlib.md5()
		message_hash.update(message.body)
 
		md5_message_body = message_hash.hexdigest()
 
		self.response.out.write(md5_message_body)
 
class Pop(webapp.RequestHandler):
	def get(self):
		self.response.out.write('Popping')
 
		results = Message.gql("ORDER BY date ASC LIMIT 1")
 
		if results:
			for message in results:
				self.response.out.write(message.body)
 
			if message:
				message.delete()
 
 
class MainPage(webapp.RequestHandler):
  def get(self):
	template_values = {}	  
 
	path = os.path.join(os.path.dirname(__file__), 'index.html')
	self.response.out.write(template.render(path, template_values))
 
 
 
def main():
  application = webapp.WSGIApplication(
                                       [('/', MainPage),
					('/pop', Pop),
					('/push', Push),
					('/test', Test)],
                                       debug=True)
  wsgiref.handlers.CGIHandler().run(application)
 
if __name__ == "__main__":
  main()