Tornado simple Proxy

with AsyncHTTPClient (async mode)

#Async Version with AsyncHTTPClient as url fetcher

from tornado import httpserver, ioloop
from tornado.httpclient import AsyncHTTPClient, HTTPClient

class httpProxy():
	def __init__(self, iolp):
		self.myserv = httpserver.HTTPServer(self.handle_request)
		self.myserv.listen(8080)
		self.httpclient = AsyncHTTPClient()
		self.userAgent = "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/534.30 (KHTML, like Gecko) Ubuntu/10.04 Chromium/12.0.742.112 Chrome/12.0.742.112 Safari/534.30"
		self.ioloop = iolp.start()

	def handle_request(self, req):
		print "requested url "+req.uri
		self.getPage(req)
		self.req = req

	def getPage(self, req):
		self.httpclient.fetch(req.uri, callback=self.handler, headers={"Accept-Encoding":"gzip,deflate", "Referer":"http://www.google.com", "User-Agent":self.userAgent})

	def handler(self, response):
		self.resp = ("HTTP/1.1 200 OK\r\nContent-Length: %d\r\n\r\n%s" % (len(response.body), response.body))
		self.req.write(self.resp)
		self.req.finish() # THIS IS THE INDICTED LINE


iolp = ioloop.IOLoop.instance()
server = httpProxy(iolp)

with HTTPClient (sync mode, obviously very slow))

#Sync Version with HTTPClient as url fetcher

from tornado import httpserver, ioloop
from tornado.httpclient import AsyncHTTPClient, HTTPClient

class httpProxy():
	def __init__(self, iolp):
		self.countReqs = 0
		self.myserv = httpserver.HTTPServer(self.handle_request)
		self.myserv.listen(8080)		
		self.httpclient = HTTPClient()
		self.userAgent = "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/534.30 (KHTML, like Gecko) Ubuntu/10.04 Chromium/12.0.742.112 Chrome/12.0.742.112 Safari/534.30"
		self.ioloop = iolp.start()

	def handle_request(self, req):
		print "requested url "+req.uri
		self.getPage(req)
		self.req = req

	def getPage(self, req):
		self.response = self.httpclient.fetch(req.uri, headers={"Accept-Encoding":"gzip,deflate", "Referer":"http://www.google.com", "User-Agent":self.userAgent})
		self.resp = ("HTTP/1.1 200 OK\r\nContent-Length: %d\r\n\r\n%s" % (len(self.response.body), self.response.body))
		req.write(self.resp)
		req.finish()