From e19be085ca673504e9e0b481eeafaaaf02e45f3f Mon Sep 17 00:00:00 2001 From: Duda Dornelles Date: Thu, 18 Dec 2014 11:46:24 -0200 Subject: Running functional tests behind tornado proxy: breaking the build :) --- service/test/support/dispatcher/__init__.py | 105 ---------------------------- 1 file changed, 105 deletions(-) (limited to 'service/test/support/dispatcher/__init__.py') diff --git a/service/test/support/dispatcher/__init__.py b/service/test/support/dispatcher/__init__.py index f1045042..3407b019 100644 --- a/service/test/support/dispatcher/__init__.py +++ b/service/test/support/dispatcher/__init__.py @@ -13,110 +13,5 @@ # # You should have received a copy of the GNU Affero General Public License # along with Pixelated. If not, see . -from __future__ import print_function -import traceback -import sys -from tornado.httpclient import AsyncHTTPClient -from tornado.httpserver import HTTPServer -import tornado.ioloop -import tornado.web -import tornado.escape -from tornado import gen - -class MainHandler(tornado.web.RequestHandler): - - @tornado.web.asynchronous - @gen.engine - def get(self): - self.forward('3333', '127.0.0.1') - - @tornado.web.asynchronous - @gen.engine - def post(self): - self.get() - - @tornado.web.asynchronous - @gen.engine - def put(self): - self.get() - - @tornado.web.asynchronous - @gen.engine - def delete(self): - self.get() - - def handle_response(self, response): - if response.error and not isinstance(response.error, tornado.httpclient.HTTPError): - print(self.request.uri) - print(response.error) - self.set_status(500) - self.write("Internal server error:\n" + str(response.error)) - self.finish() - else: - self.set_status(response.code) - for header in ("Date", "Cache-Control", "Server", "Content-Type", "Location"): - v = response.headers.get(header) - if v: - self.set_header(header, v) - if response.body: - self.write(response.body) - self.finish() - - def forward(self, port=None, host=None): - url = "%s://%s:%s%s" % ( - 'http', host or "127.0.0.1", port or 80, self.request.uri) - try: - tornado.httpclient.AsyncHTTPClient().fetch( - tornado.httpclient.HTTPRequest( - url=url, - method=self.request.method, - body=None if not self.request.body else self.request.body, - headers=self.request.headers, - follow_redirects=False, - request_timeout=10), - self.handle_response) - except tornado.httpclient.HTTPError, x: - if hasattr(x, 'response') and x.response: - self.handle_response(x.response) - except Exception, e: - self.set_status(500) - self.write("Internal server error:\n" + ''.join(traceback.format_exception(*sys.exc_info()))) - self.finish() - - -def _create_app(): - app = tornado.web.Application( - [ - (r"/.*", MainHandler) - ], - xsrf_cookies=False, - debug=True) - return app - - -class Proxy: - - def __init__(self): - pass - - def serve_forever(self): - app = _create_app() - self._server = HTTPServer(app) - self._server.listen(port='8888', address='127.0.0.1') - self._ioloop = tornado.ioloop.IOLoop.instance() - self._ioloop.start() # this is a blocking call, server has stopped on next line - self._ioloop = None - - def shutdown(self): - if self._ioloop: - self._server.stop() - self._ioloop.stop() - - -proxy = Proxy() -try: - proxy.serve_forever() -except Exception: - proxy.shutdown() -- cgit v1.2.3