X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;f=dak%2Fdak.py;h=f9839ea0052d9f4d4fab1b0a846555b40734a5db;hb=5ec91ac106aa190844c6b6bc3ba62c12f7d4ce7c;hp=981a31a95d0d52e6408c458218c012726a8229bd;hpb=dbab5f6dd3fda53a5b6015dfdcae96c325d74bac;p=dak.git diff --git a/dak/dak.py b/dak/dak.py index 981a31a9..f9839ea0 100755 --- a/dak/dak.py +++ b/dak/dak.py @@ -33,48 +33,13 @@ G{importgraph} ################################################################################ -import sys, imp -import daklib.utils, daklib.extensions +import sys +import traceback +import daklib.utils -################################################################################ - -class UserExtension: - def __init__(self, user_extension = None): - if user_extension: - m = imp.load_source("dak_userext", user_extension) - d = m.__dict__ - else: - m, d = None, {} - self.__dict__["_module"] = m - self.__dict__["_d"] = d - - def __getattr__(self, a): - if a in self.__dict__: return self.__dict__[a] - if a[0] == "_": raise AttributeError, a - return self._d.get(a, None) - - def __setattr__(self, a, v): - self._d[a] = v - -################################################################################ - -class UserExtension: - def __init__(self, user_extension = None): - if user_extension: - m = imp.load_source("dak_userext", user_extension) - d = m.__dict__ - else: - m, d = None, {} - self.__dict__["_module"] = m - self.__dict__["_d"] = d - - def __getattr__(self, a): - if a in self.__dict__: return self.__dict__[a] - if a[0] == "_": raise AttributeError, a - return self._d.get(a, None) - - def __setattr__(self, a, v): - self._d[a] = v +from daklib.daklog import Logger +from daklib.config import Config +from daklib.dak_exceptions import CantOpenError ################################################################################ @@ -112,6 +77,8 @@ def init(): "Generate package <-> file mapping"), ("generate-releases", "Generate Release files"), + ("contents", + "Generate content files"), ("generate-index-diffs", "Generate .diff/Index files"), ("clean-suites", @@ -127,8 +94,6 @@ def init(): "Override cruft checks"), ("check-proposed-updates", "Dependency checking for proposed-updates"), - ("compare-suites", - "Show fixable discrepencies between suites"), ("control-overrides", "Manipulate/list override entries in bulk"), ("control-suite", @@ -141,14 +106,14 @@ def init(): "Show information useful for NEW processing"), ("find-null-maintainers", "Check for users with no packages in the archive"), - ("import-archive", - "Populate SQL database based from an archive tree"), ("import-keyring", "Populate fingerprint/uid table based on a new/updated keyring"), ("import-ldap-fingerprints", "Syncs fingerprint and uid tables with Debian LDAP db"), ("import-users-from-passwd", "Sync PostgreSQL users with passwd file"), + ("admin", + "Perform administration on the dak database"), ("init-db", "Update the database to match the conf file"), ("update-db", @@ -161,8 +126,6 @@ def init(): "Generates override files"), ("poolize", "Move packages from dists/ to pool/"), - ("reject-proposed-updates", - "Manually reject from proposed-updates"), ("new-security-install", "New way to install a security upload into the archive"), ("split-done", @@ -194,12 +157,11 @@ Available commands:""" def main(): """Launch dak functionality.""" - Cnf = daklib.utils.get_conf() - if Cnf.has_key("Dinstall::UserExtensions"): - userext = UserExtension(Cnf["Dinstall::UserExtensions"]) - else: - userext = UserExtension() + try: + logger = Logger(Config(), 'dak top-level', print_starting=False) + except CantOpenError: + logger = None functionality = init() modules = [ command for (command, _) in functionality ] @@ -238,13 +200,21 @@ def main(): # Invoke the module module = __import__(cmdname.replace("-","_")) - module.dak_userext = userext - userext.dak_module = module - - daklib.extensions.init(cmdname, module, userext) - if userext.init is not None: userext.init(cmdname) - - module.main() + try: + module.main() + except KeyboardInterrupt: + msg = 'KeyboardInterrupt caught; exiting' + print msg + if logger: + logger.log([msg]) + sys.exit(1) + except SystemExit: + pass + except: + if logger: + for line in traceback.format_exc().split('\n')[:-1]: + logger.log(['exception', line]) + raise ################################################################################