Mercurial > libervia-backend
diff src/core/sat_main.py @ 993:301b342c697a
core: use of the new core.log module:
/!\ this is a massive refactoring and was largely automated, it probably did bring some bugs /!\
author | Goffi <goffi@goffi.org> |
---|---|
date | Sat, 19 Apr 2014 19:19:19 +0200 |
parents | 05e02f8b7eb4 |
children | c37a24922f27 |
line wrap: on
line diff
--- a/src/core/sat_main.py Sat Apr 19 16:48:26 2014 +0200 +++ b/src/core/sat_main.py Sat Apr 19 19:19:19 2014 +0200 @@ -25,20 +25,18 @@ from twisted.internet import reactor from wokkel.xmppim import RosterItem from sat.bridge.DBus import DBusBridge -import logging -from logging import debug, info, warning, error - -import sys -import os.path - from sat.core import xmpp from sat.core import exceptions +from sat.core.log import getLogger +log = getLogger(__name__) from sat.core.constants import Const as C from sat.memory.memory import Memory from sat.tools.misc import TriggerManager from sat.stdui import ui_contact_list from glob import glob from uuid import uuid4 +import sys +import os.path try: from collections import OrderedDict # only available from python 2.7 @@ -93,7 +91,7 @@ try: self.bridge = DBusBridge() except exceptions.BridgeInitError: - print (u"Bridge can't be initialised, can't start SàT core") # reactor is not launched yet, so we can't use error log + log.error(u"Bridge can't be initialised, can't start SàT core") sys.exit(1) self.bridge.register("getVersion", lambda: C.APP_VERSION) self.bridge.register("getProfileName", self.memory.getProfileName) @@ -140,7 +138,7 @@ def _postMemoryInit(self, ignore): """Method called after memory initialization is done""" - info(_("Memory initialised")) + log.info(_("Memory initialised")) self._import_plugins() ui_contact_list.ContactList(self) @@ -169,25 +167,25 @@ """ if import_name in self.plugins: - debug('Plugin [%s] already imported, passing' % import_name) + log.debug('Plugin [%s] already imported, passing' % import_name) return if not import_name: import_name, (plugin_path, mod, plugin_info) = plugins_to_import.popitem() else: if not import_name in plugins_to_import: if optional: - warning(_("Recommended plugin not found: %s") % import_name) + log.warning(_("Recommended plugin not found: %s") % import_name) return - error(_("Dependency not found: %s") % import_name) + log.error(_("Dependency not found: %s") % import_name) raise ImportError(_('Dependency plugin not found: [%s]') % import_name) plugin_path, mod, plugin_info = plugins_to_import.pop(import_name) dependencies = plugin_info.setdefault("dependencies", []) recommendations = plugin_info.setdefault("recommendations", []) for to_import in dependencies + recommendations: if to_import not in self.plugins: - debug('Recursively import dependency of [%s]: [%s]' % (import_name, to_import)) + log.debug('Recursively import dependency of [%s]: [%s]' % (import_name, to_import)) self._import_plugins_from_dict(plugins_to_import, to_import, to_import not in dependencies) - info(_("importing plugin: %s"), plugin_info['name']) + log.info(_("importing plugin: %s") % plugin_info['name']) self.plugins[import_name] = getattr(mod, plugin_info['main'])(self) if 'handler' in plugin_info and plugin_info['handler'] == 'yes': self.plugins[import_name].is_handler = True @@ -205,11 +203,11 @@ """ profile = self.memory.getProfileName(profile_key) if not profile: - error(_('Trying to connect a non-exsitant profile')) + log.error(_('Trying to connect a non-exsitant profile')) raise exceptions.ProfileUnknownError(profile_key) if self.isConnected(profile): - info(_("already connected !")) + log.info(_("already connected !")) return defer.succeed("None") def afterMemoryInit(ignore): @@ -217,7 +215,7 @@ try: port = int(self.memory.getParamA("Port", "Connection", profile_key=profile)) except ValueError: - error(_("Can't parse port value, using default value")) + log.error(_("Can't parse port value, using default value")) port = 5222 current = self.profiles[profile] = xmpp.SatXMPPClient( self, profile, @@ -245,7 +243,7 @@ current.identityHandler = xmpp.SatIdentityHandler() current.identityHandler.setHandlerParent(current) - debug(_("setting plugins parents")) + log.debug(_("setting plugins parents")) plugin_conn_cb = [] for plugin in self.plugins.iteritems(): @@ -270,10 +268,10 @@ def logPluginResults(results): all_succeed = all([success for success, result in results]) if not all_succeed: - error(_("Plugins initialisation error")) + log.error(_("Plugins initialisation error")) for idx, (success, result) in enumerate(results): if not success: - error("Error (plugin %(name)s): %(failure)s" % {'name': plugin_conn_cb[idx][0], + log.error("error (plugin %(name)s): %(failure)s" % {'name': plugin_conn_cb[idx][0], 'failure': result}) list_d.addCallback(logPluginResults) @@ -289,10 +287,10 @@ def disconnect(self, profile_key): """disconnect from jabber server""" if not self.isConnected(profile_key): - info(_("not connected !")) + log.info(_("not connected !")) return profile = self.memory.getProfileName(profile_key) - info(_("Disconnecting...")) + log.info(_("Disconnecting...")) self.profiles[profile].stopService() for plugin in self.plugins.iteritems(): disconnected_cb = getattr(plugin[1], "profileDisconnected", None) @@ -318,23 +316,23 @@ try: del self.profiles[profile] except KeyError: - error(_("Trying to remove reference to a client not referenced")) + log.error(_("Trying to remove reference to a client not referenced")) self.memory.purgeProfileSession(profile) def startService(self): - info("Salut à toi ô mon frère !") + log.info(u"Salut à toi ô mon frère !") #TODO: manage autoconnect #self.connect() def stopService(self): - info("Salut aussi à Rantanplan") + log.info("Salut aussi à Rantanplan") def run(self): - debug(_("running app")) + log.debug(_("running app")) reactor.run() def stop(self): - debug(_("stopping app")) + log.debug(_("stopping app")) reactor.stop() ## Misc methods ## @@ -415,7 +413,7 @@ def setParam(self, name, value, category, security_limit, profile_key): """set wanted paramater and notice observers""" - info(_("setting param: %(name)s=%(value)s in category %(category)s") % {'name': name, 'value': value, 'category': category}) + log.info(_("setting param: %(name)s=%(value)s in category %(category)s") % {'name': name, 'value': value, 'category': category}) self.memory.setParam(name, value, category, security_limit, profile_key) def isConnected(self, profile_key): @@ -425,7 +423,7 @@ """ profile = self.memory.getProfileName(profile_key) if not profile: - error(_('asking connection status for a non-existant profile')) + log.error(_('asking connection status for a non-existant profile')) return if profile not in self.profiles: return False @@ -490,7 +488,7 @@ if not self.trigger.point("sendMessage", mess_data, pre_xml_treatments, post_xml_treatments, profile): return defer.succeed(None) - debug(_("Sending jabber message of type [%(type)s] to %(to)s...") % {"type": mess_data["type"], "to": to_jid.full()}) + log.debug(_("Sending jabber message of type [%(type)s] to %(to)s...") % {"type": mess_data["type"], "to": to_jid.full()}) def generateXML(mess_data): mess_data['xml'] = domish.Element((None, 'message')) @@ -507,12 +505,12 @@ def sendErrback(e): text = '%s: %s' % (e.value.__class__.__name__, e.getErrorMessage()) if e.check(MessageSentAndStored): - debug(text) + log.debug(text) elif e.check(AbortSendMessage): - warning(text) + log.warning(text) return e else: - error("Unmanaged exception: %s" % text) + log.error("Unmanaged exception: %s" % text) return e pre_xml_treatments.addCallback(generateXML) pre_xml_treatments.chainDeferred(post_xml_treatments) @@ -532,7 +530,7 @@ try: client = self.profiles[profile] except KeyError: - error(_("Trying to send a message with no profile")) + log.error(_("Trying to send a message with no profile")) return current_jid = client.jid if not skip_send: @@ -580,7 +578,7 @@ profile = self.memory.getProfileName(profile_key) assert(profile) to_jid = jid.JID(raw_jid) - debug(_('subsciption request [%(subs_type)s] for %(jid)s') % {'subs_type': subs_type, 'jid': to_jid.full()}) + log.debug(_('subsciption request [%(subs_type)s] for %(jid)s') % {'subs_type': subs_type, 'jid': to_jid.full()}) if subs_type == "subscribe": self.profiles[profile].presence.subscribe(to_jid) elif subs_type == "subscribed": @@ -664,7 +662,7 @@ @param data: dictionary of dictionaries """ if action_type != "DICT_DICT": - error(_("action_type for actionResultExt must be DICT_DICT, fixing it")) + log.error(_("action_type for actionResultExt must be DICT_DICT, fixing it")) action_type = "DICT_DICT" self.bridge.actionResultExt(action_type, action_id, data, profile) @@ -678,7 +676,7 @@ # FIXME: use XMLUI and *callback methods for dialog client = self.getClient(profile) if conf_id in client._waiting_conf: - error(_("Attempt to register two callbacks for the same confirmation")) + log.error(_("Attempt to register two callbacks for the same confirmation")) else: client._waiting_conf[conf_id] = (conf_type, data, cb) self.bridge.askConfirmation(conf_id, conf_type, data, profile) @@ -686,9 +684,9 @@ def confirmationAnswer(self, conf_id, accepted, data, profile): """Called by frontends to answer confirmation requests""" client = self.getClient(profile) - debug(_("Received confirmation answer for conf_id [%(conf_id)s]: %(success)s") % {'conf_id': conf_id, 'success': _("accepted") if accepted else _("refused")}) + log.debug(_("Received confirmation answer for conf_id [%(conf_id)s]: %(success)s") % {'conf_id': conf_id, 'success': _("accepted") if accepted else _("refused")}) if conf_id not in client._waiting_conf: - error(_("Received an unknown confirmation (%(id)s for %(profile)s)") % {'id': conf_id, 'profile': profile}) + log.error(_("Received an unknown confirmation (%(id)s for %(profile)s)") % {'id': conf_id, 'profile': profile}) else: cb = client._waiting_conf[conf_id][-1] del client._waiting_conf[conf_id] @@ -703,7 +701,7 @@ """Remove a progress callback""" client = self.getClient(profile) if progress_id not in client._progress_cb_map: - error(_("Trying to remove an unknow progress callback")) + log.error(_("Trying to remove an unknow progress callback")) else: del client._progress_cb_map[progress_id] @@ -718,7 +716,7 @@ client._progress_cb_map[progress_id](progress_id, data, profile) except KeyError: pass - #debug("Requested progress for unknown progress_id") + #log.debug("Requested progress for unknown progress_id") return data def registerCallback(self, callback, *args, **kwargs): @@ -750,7 +748,7 @@ def removeCallback(self, callback_id): """ Remove a previously registered callback @param callback_id: id returned by [registerCallback] """ - debug("Removing callback [%s]" % callback_id) + log.debug("Removing callback [%s]" % callback_id) del self._cb_map[callback_id] def launchCallback(self, callback_id, data=None, profile_key=C.PROF_KEY_NONE):