Second import.

[people/jschlag/pbs.git] / hub / __init__.py

#!/usr/bin/python

import logging
import os.path
import tornado.httpserver
import tornado.locale
import tornado.options
import tornado.web

import backend
import handlers

BASEDIR = os.path.join(os.path.dirname(__file__), "..", "data")

# Enable logging
tornado.options.parse_command_line()

class Application(tornado.web.Application):
	def __init__(self):
		self.__pakfire = None

		settings = dict(
			debug = False,
			gzip  = True,
		)

		# Load translations.
		tornado.locale.load_gettext_translations(
			os.path.join(BASEDIR, "translations"), "pakfire")

		tornado.web.Application.__init__(self, **settings)

		self.add_handlers(r"pakfirehub.ipfire.org", [
			# Redirect strayed users.
			(r"/", handlers.RedirectHandler),

			# API
			(r"/builder", handlers.BuilderHandler),
			(r"/user",    handlers.UserHandler),
		])

		# This is the deprecated version. It will be removed some time.
		self.add_handlers(r"pakfire.ipfire.org", [
			# API
			(r"/pakfirehub/builder", handlers.BuilderHandler),
			(r"/pakfirehub/user",    handlers.UserHandler),
		])

		logging.info("Successfully initialied application")

	@property
	def pakfire(self):
		if self.__pakfire is None:
			self.__pakfire = backend.Pakfire()

		return self.__pakfire

	def __del__(self):
		logging.info("Shutting down application")

	@property
	def ioloop(self):
		return tornado.ioloop.IOLoop.instance()

	def shutdown(self, *args):
		logging.debug("Caught shutdown signal")
		self.ioloop.stop()

	def run(self, port=81):
		logging.debug("Going to background")

		http_server = tornado.httpserver.HTTPServer(self, xheaders=True)

		# If we are not running in debug mode, we can actually run multiple
		# frontends to get best performance out of our service.
		if not self.settings["debug"]:
			http_server.bind(port)
			http_server.start(num_processes=4)
		else:
			http_server.listen(port)

		# All requests should be done after 30 seconds or they will be killed.
		self.ioloop.set_blocking_log_threshold(30)

		self.ioloop.start()

	def reload(self):
		logging.debug("Caught reload signal")