wiki: Add wrapper to send emails to watchers

[ipfire.org.git] / src / backend / base.py

#!/usr/bin/python

import configparser
import io
import tornado.gen

from . import accounts
from . import database
from . import geoip
from . import fireinfo
from . import iuse
from . import memcached
from . import mirrors
from . import netboot
from . import nopaste
from . import releases
from . import settings
from . import talk

from . import blog
from . import wiki
from . import zeiterfassung

DEFAULT_CONFIG = io.StringIO("""
[global]
debug = false

data_dir      =
static_dir    = %(data_dir)s/static
templates_dir = %(data_dir)s/templates
""")

class Backend(object):
	def __init__(self, configfile, debug=False):
		# Read configuration file.
		self.config = self.read_config(configfile)

		# Enable debug logging if configured
		self.debug = debug or self.config.getboolean("global", "debug")

		# Setup database.
		self.setup_database()

		# Initialize settings first.
		self.settings = settings.Settings(self)
		self.memcache = memcached.Memcached(self)

		# Initialize backend modules.
		self.accounts = accounts.Accounts(self)
		self.geoip = geoip.GeoIP(self)
		self.fireinfo = fireinfo.Fireinfo(self)
		self.iuse = iuse.IUse(self)
		self.mirrors = mirrors.Mirrors(self)
		self.netboot = netboot.NetBoot(self)
		self.nopaste = nopaste.Nopaste(self)
		self.releases = releases.Releases(self)
		self.talk = talk.Talk(self)

		self.blog = blog.Blog(self)
		self.wiki = wiki.Wiki(self)
		self.zeiterfassung = zeiterfassung.ZeiterfassungClient(self)

	def read_config(self, configfile):
		cp = configparser.ConfigParser()

		# Initialize configuration with some sensible defaults
		cp.readfp(DEFAULT_CONFIG)

		# Parse file
		cp.read(configfile)

		return cp

	def setup_database(self):
		"""
			Sets up the database connection.
		"""
		credentials = {
			"host"     : self.config.get("database", "server"),
			"database" : self.config.get("database", "database"),
			"user"     : self.config.get("database", "username"),
			"password" : self.config.get("database", "password"),
		}

		self.db = database.Connection(**credentials)

	@tornado.gen.coroutine
	def run_task(self, task, *args, **kwargs):
		tasks = {
			"scan-files"        : self.releases.scan_files,
			"update-blog-feeds" : self.blog.update_feeds,
		}

		# Get the task from the list of all tasks
		func = tasks.get(task, None)
		if not func:
			raise ValueError("Unknown task: %s" % task)

		# Run the task
		r = yield func(*args, **kwargs)

		# If any error code has been returned,
		# we will end the program
		if r:
			raise SystemExit(r)