X-Git-Url: https://jfr.im/git/erebus.git/blobdiff_plain/6e2b575fa8dd4d48fe2f7400bb3b9180a4547bb8..9221e6f6b1e364c61812d39c73ad6ea41fd2c651:/ctlmod.py diff --git a/ctlmod.py b/ctlmod.py index 0a4c784..09ce8fa 100644 --- a/ctlmod.py +++ b/ctlmod.py @@ -1,26 +1,58 @@ # Erebus IRC bot - Author: John Runyon # module loading/unloading/tracking code -import sys +from __future__ import print_function + +import sys, time, importlib import modlib +if sys.version_info.major >= 3: + from importlib import reload +else: + importlib.invalidate_caches = lambda: None + modules = {} dependents = {} +#dependents[modname] = [list of modules which depend on modname] def isloaded(modname): return modname in modules def modhas(modname, attname): return getattr(modules[modname], attname, None) is not None -def load(parent, modname): +def load(parent, modname, dependent=False): + """Wrapper to call _load and print the return value.""" + if dependent: + print("(Loading dependency %s..." % (modname), end=' ') + else: + print("%09.3f [MOD] [?] Loading %s..." % (time.time() % 100000, modname), end=' ') + modstatus = _load(parent, modname, dependent) + if not modstatus: + if dependent: + print("failed: %s)" % (modstatus), end=' ') + else: + print("failed: %s." % (modstatus)) + elif modstatus == True: + if dependent: + print("OK)", end=' ') + else: + print("OK.") + else: + if dependent: + print("OK: %s)" % (modstatus), end=' ') + else: + print("OK: %s." % (modstatus)) + return modstatus + +def _load(parent, modname, dependent=False): + """Load and return the new status of the module.""" + successstatus = [] if not isloaded(modname): - sys.path.insert(0, 'modules') + importlib.invalidate_caches() try: - mod = __import__(modname) + mod = importlib.import_module('modules.'+modname) reload(mod) #in case it's been previously loaded. - except BaseException as e: #we don't want even sys.exit() to crash us (in case of malicious module) so use BaseException + except Exception as e: return modlib.error(e) - finally: - del sys.path[0] #remove ./modules from path, in case there's a name conflict - + if not hasattr(mod, 'modinfo'): return modlib.error('no modinfo') @@ -32,20 +64,44 @@ def load(parent, modname): dependents[modname] = [] for dep in mod.modinfo['depends']: - if dep not in modules: - depret = load(parent, dep) - if not depret: - return + if bool(int(parent.cfg.get('autoloads', dep, default=1))): + if dep not in modules: + depret = load(parent, dep, dependent=True) + if depret is not None and not depret: + return depret + else: + return modlib.error("dependent %s disabled" % (dep)) dependents[dep].append(modname) + for dep in mod.modinfo['softdeps']: + if bool(int(parent.cfg.get('autoloads', dep, default=1))): + if dep not in modules: + depret = load(parent, dep, dependent=True) + if depret is not None: + if not depret: + successstatus.append("softdep %s failed" % (dep)) + else: + successstatus.append("softdep %s disabled" % (dep)) + #swallow errors loading - softdeps are preferred, not required + ret = mod.modstart(parent) - if ret is not None and not ret: + if ret is None: + ret = True + if not ret: del modules[modname] del dependents[modname] for dep in mod.modinfo['depends']: dependents[dep].remove(modname) - return ret + + successstatus = ';'.join(successstatus) + if len(successstatus) > 0 and ret: + if ret == True: + return successstatus + else: + return "%s (%s)" % (ret, successstatus) + else: + return ret else: #if not isloaded...else: return modlib.error('already loaded') @@ -53,7 +109,7 @@ def unload(parent, modname): if isloaded(modname): for dependent in dependents[modname]: unload(parent, dependent) - for dep in dependents[modname]: + for dep in modules[modname].modinfo['depends']: dependents[dep].remove(modname) ret = modules[modname].modstop(parent) del modules[modname] @@ -85,5 +141,3 @@ def unloadall(parent, modlist): for m in modlist: unload(parent, m) def reloadall(parent, modlist): for m in modlist: reloadmod(parent, m) - -sys.path.append('modules')