X-Git-Url: http://git.maemo.org/git/?p=theonering;a=blobdiff_plain;f=src%2Fconnection.py;h=71e39203671521425d029c3219e563ca4b742d87;hp=96808cb9b794096dc953dac0e8f735ed65feaea1;hb=17ed78514215ad8e1358e329fb2e77ad749fe777;hpb=7cdc5ab1a3dd83850275056e4c50fcb84a30586e diff --git a/src/connection.py b/src/connection.py index 96808cb..71e3920 100644 --- a/src/connection.py +++ b/src/connection.py @@ -28,6 +28,8 @@ _moduleLogger = logging.getLogger(__name__) class TheOneRingOptions(object): + ignoreDND = True + useGVContacts = True assert gvoice.session.Session._DEFAULTS["contacts"][1] == "hours" @@ -42,6 +44,7 @@ class TheOneRingOptions(object): def __init__(self, parameters = None): if parameters is None: return + self.ignoreDND = parameters["ignore-dnd"] self.useGVContacts = parameters["use-gv-contacts"] self.contactsPollPeriodInHours = parameters['contacts-poll-period-in-hours'] self.voicemailPollPeriodInMinutes = parameters['voicemail-poll-period-in-minutes'] @@ -54,9 +57,10 @@ class TheOneRingConnection( avatars.AvatarsMixin, capabilities.CapabilitiesMixin, contacts.ContactsMixin, - presence.PresenceMixin, requests.RequestsMixin, + simple_presence.TheOneRingPresence, simple_presence.SimplePresenceMixin, + presence.PresenceMixin, ): # overiding base class variable @@ -67,6 +71,7 @@ class TheOneRingConnection( # overiding base class variable _optional_parameters = { 'forward': 's', + 'ignore-dnd': 'b', 'use-gv-contacts': 'b', 'contacts-poll-period-in-hours': 'i', 'voicemail-poll-period-in-minutes': 'i', @@ -74,6 +79,7 @@ class TheOneRingConnection( } _parameter_defaults = { 'forward': '', + 'ignore-dnd': TheOneRingOptions.ignoreDND, 'use-gv-contacts': TheOneRingOptions.useGVContacts, 'contacts-poll-period-in-hours': TheOneRingOptions.contactsPollPeriodInHours, 'voicemail-poll-period-in-minutes': TheOneRingOptions.voicemailPollPeriodInMinutes, @@ -85,6 +91,8 @@ class TheOneRingConnection( @misc_utils.log_exception(_moduleLogger) def __init__(self, manager, parameters): + self._loggers = [] + self.check_parameters(parameters) account = unicode(parameters['account']) encodedAccount = parameters['account'].encode('utf-8') @@ -95,14 +103,8 @@ class TheOneRingConnection( # Connection init must come first self.__options = TheOneRingOptions(parameters) - self.__session = gvoice.session.Session( - cookiePath = None, - defaults = { - "contacts": (self.__options.contactsPollPeriodInHours, "hours"), - "voicemail": (self.__options.voicemailPollPeriodInMinutes, "minutes"), - "texts": (self.__options.textsPollPeriodInMinutes, "minutes"), - }, - ) + self.__accountName = account + self.__session = None tp.Connection.__init__( self, constants._telepathy_protocol_name_, @@ -113,9 +115,10 @@ class TheOneRingConnection( avatars.AvatarsMixin.__init__(self) capabilities.CapabilitiesMixin.__init__(self) contacts.ContactsMixin.__init__(self) - presence.PresenceMixin.__init__(self) requests.RequestsMixin.__init__(self) - simple_presence.SimplePresenceMixin.__init__(self) + simple_presence.TheOneRingPresence.__init__(self, self.__options.ignoreDND) + simple_presence.SimplePresenceMixin.__init__(self, self) + presence.PresenceMixin.__init__(self, self) self.__manager = weakref.proxy(manager) self.__credentials = ( @@ -166,6 +169,12 @@ class TheOneRingConnection( def get_handle_by_name(self, handleType, handleName): requestedHandleName = handleName.encode('utf-8') + + # We need to return an existing or create a new handle. Unfortunately + # handle init's take care of normalizing the handle name. So we have + # to create a new handle regardless and burn some handle id's and burn + # some extra memory of creating objects we throw away if the handle + # already exists. if handleType == telepathy.HANDLE_TYPE_CONTACT: h = handle.create_handle(self, 'contact', requestedHandleName) elif handleType == telepathy.HANDLE_TYPE_LIST: @@ -173,8 +182,34 @@ class TheOneRingConnection( h = handle.create_handle(self, 'list', requestedHandleName) else: raise telepathy.errors.NotAvailable('Handle type unsupported %d' % handleType) + + for candidate in self._handles.itervalues(): + if candidate.get_name() == h.get_name(): + h = candidate + _moduleLogger.debug("Re-used handle for %s, I hoped this helped" % handleName) + break + return h + def force_log_display(self): + accountNumber = misc_utils.normalize_number(self.session.backend.get_account_number()) + debugHandle = self.get_handle_by_name( + telepathy.HANDLE_TYPE_CONTACT, + accountNumber, + ) + debugPromptProps = self.generate_props(telepathy.CHANNEL_TYPE_TEXT, debugHandle, False) + self.__channelManager.channel_for_props(debugPromptProps, signal=True) + + def log_to_user(self, component, message): + for logger in self._loggers: + logger.log_message(component, message) + + def add_logger(self, logger): + self._loggers.append(logger) + + def remove_logger(self, logger): + self._loggers.remove(logger) + @property def _channel_manager(self): return self.__channelManager @@ -184,6 +219,16 @@ class TheOneRingConnection( """ For org.freedesktop.telepathy.Connection """ + if self.__session is None: + self.__session = gvoice.session.Session( + cookiePath = os.path.join(constants._data_path_, "%s.cookies" % self.__accountName), + defaults = { + "contacts": (self.__options.contactsPollPeriodInHours, "hours"), + "voicemail": (self.__options.voicemailPollPeriodInMinutes, "minutes"), + "texts": (self.__options.textsPollPeriodInMinutes, "minutes"), + }, + ) + if self._status != telepathy.CONNECTION_STATUS_DISCONNECTED: _moduleLogger.info("Attempting connect when not disconnected") return @@ -204,7 +249,7 @@ class TheOneRingConnection( def _on_login(self, *args): _moduleLogger.info("Connected, setting up...") try: - self.__session.load(self.__cachePath) + self.session.load(self.__cachePath) for plumber in self._plumbing: plumber.start() @@ -218,9 +263,6 @@ class TheOneRingConnection( subscribeHandle = self.get_handle_by_name(telepathy.HANDLE_TYPE_LIST, "subscribe") subscribeProps = self.generate_props(telepathy.CHANNEL_TYPE_CONTACT_LIST, subscribeHandle, False) self.__channelManager.channel_for_props(subscribeProps, signal=True) - publishHandle = self.get_handle_by_name(telepathy.HANDLE_TYPE_LIST, "publish") - publishProps = self.generate_props(telepathy.CHANNEL_TYPE_CONTACT_LIST, publishHandle, False) - self.__channelManager.channel_for_props(publishProps, signal=True) except Exception: _moduleLogger.exception("Setup failed") self.disconnect(telepathy.CONNECTION_STATUS_REASON_AUTHENTICATION_FAILED) @@ -235,7 +277,9 @@ class TheOneRingConnection( @misc_utils.log_exception(_moduleLogger) def _on_login_error(self, error): _moduleLogger.error(error) - if isinstance(error, gvoice.backend.NetworkError): + if isinstance(error, StopIteration): + pass + elif isinstance(error, gvoice.backend.NetworkError): self.disconnect(telepathy.CONNECTION_STATUS_REASON_NETWORK_ERROR) else: self.disconnect(telepathy.CONNECTION_STATUS_REASON_AUTHENTICATION_FAILED) @@ -304,7 +348,7 @@ class TheOneRingConnection( self.manager.disconnected(self) self.session.save(self.__cachePath) - self.session.logout() + self.session.shutdown() self.session.close() # In case one of the above items takes too long (which it should never