autogv.NewGVConversations(weakref.ref(self)),
autogv.RefreshVoicemail(weakref.ref(self)),
autogv.AutoDisconnect(weakref.ref(self)),
+ autogv.DelayEnableContactIntegration(constants._telepathy_implementation_name_),
]
self._delayedConnect = gobject_utils.Async(self._delayed_connect)
_moduleLogger.info("Connection to the account %s created" % account)
+ self._timedDisconnect = autogv.TimedDisconnect(weakref.ref(self))
+ self._timedDisconnect.start()
@property
def manager(self):
def get_handle_by_name(self, handleType, handleName):
requestedHandleName = handleName.encode('utf-8')
if handleType == telepathy.HANDLE_TYPE_CONTACT:
- _moduleLogger.debug("get_handle_by_name Contact: %s" % requestedHandleName)
h = handle.create_handle(self, 'contact', requestedHandleName)
elif handleType == telepathy.HANDLE_TYPE_LIST:
# Support only server side (immutable) lists
- _moduleLogger.debug("get_handle_by_name List: %s" % requestedHandleName)
h = handle.create_handle(self, 'list', requestedHandleName)
else:
raise telepathy.errors.NotAvailable('Handle type unsupported %d' % handleType)
return
_moduleLogger.info("Kicking off connect")
self._delayedConnect.start()
+ self._timedDisconnect.stop()
@misc_utils.log_exception(_moduleLogger)
def _delayed_connect(self):
For org.freedesktop.telepathy.Connection
"""
_moduleLogger.info("Kicking off disconnect")
- self._delayed_disconnect()
+ self.disconnect(telepathy.CONNECTION_STATUS_REASON_REQUESTED)
@misc_utils.log_exception(_moduleLogger)
def RequestChannel(self, type, handleType, handleId, suppressHandler):
return props
- @gobject_utils.async
- def _delayed_disconnect(self):
- self.disconnect(telepathy.CONNECTION_STATUS_REASON_REQUESTED)
- return False
-
def disconnect(self, reason):
_moduleLogger.info("Disconnecting")
self._delayedConnect.cancel()
+ self._timedDisconnect.stop()
# Not having the disconnect first can cause weird behavior with clients
# including not being able to reconnect or even crashing
plumber.stop()
self.__channelManager.close()
+ self.manager.disconnected(self)
+
self.session.save(self.__cachePath)
self.session.logout()
self.session.close()
- self.manager.disconnected(self)
_moduleLogger.info("Disconnected")