sugarlabs/sugar-toolkit-gtk3
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

services/presence/server_plugin: remove trailing whitespace

Browse Source
This commit is contained in:
Simon McVittie 2007-05-24 11:29:22 +01:00
parent 2d76475682
commit 55c0d9cb07
1 changed files with 61 additions and 60 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

121
services/presence/server_plugin.py
View File

@ -79,7 +79,8 @@ def _get_buddy_icon_at_size(icon, maxw, maxh, maxsize):
while img_size > maxsize: while img_size > maxsize:
del data del data
data = [""] data = [""]
pixbuf.save_to_callback(_buddy_icon_save_cb, "jpeg", {"quality":"%d" % quality}, data) pixbuf.save_to_callback(_buddy_icon_save_cb, "jpeg",
{"quality":"%d" % quality}, data)
quality -= 10 quality -= 10
img_size = len(data[0]) img_size = len(data[0])
del pixbuf del pixbuf
@ -89,14 +90,14 @@ def _get_buddy_icon_at_size(icon, maxw, maxh, maxsize):
raise RuntimeError("could not size image less than %d bytes" % maxsize) raise RuntimeError("could not size image less than %d bytes" % maxsize)
return str(data[0]) return str(data[0])
class ServerPlugin(gobject.GObject): class ServerPlugin(gobject.GObject):
"""Telepathy-python-based presence server interface """Telepathy-python-based presence server interface
The ServerPlugin instance translates network events from The ServerPlugin instance translates network events from
Telepathy Python into GObject events. It provides direct Telepathy Python into GObject events. It provides direct
python calls to perform the required network operations python calls to perform the required network operations
to implement the PresenceService. to implement the PresenceService.
""" """
__gsignals__ = { __gsignals__ = {
@ -125,14 +126,14 @@ class ServerPlugin(gobject.GObject):
([gobject.TYPE_PYOBJECT, gobject.TYPE_PYOBJECT, ([gobject.TYPE_PYOBJECT, gobject.TYPE_PYOBJECT,
gobject.TYPE_PYOBJECT, gobject.TYPE_PYOBJECT])) gobject.TYPE_PYOBJECT, gobject.TYPE_PYOBJECT]))
} }
def __init__(self, registry, owner): def __init__(self, registry, owner):
"""Initialize the ServerPlugin instance """Initialize the ServerPlugin instance
registry -- telepathy.client.ManagerRegistry from the registry -- telepathy.client.ManagerRegistry from the
PresenceService, used to find the "gabble" connection PresenceService, used to find the "gabble" connection
manager in this case... manager in this case...
owner -- presence.buddy.GenericOwner instance (normally a owner -- presence.buddy.GenericOwner instance (normally a
presence.buddy.ShellOwner instance) presence.buddy.ShellOwner instance)
""" """
gobject.GObject.__init__(self) gobject.GObject.__init__(self)
@ -177,18 +178,18 @@ class ServerPlugin(gobject.GObject):
self.cleanup() self.cleanup()
def _owner_property_changed_cb(self, owner, properties): def _owner_property_changed_cb(self, owner, properties):
"""Local user's configuration properties have changed """Local user's configuration properties have changed
owner -- the Buddy object for the local user owner -- the Buddy object for the local user
properties -- set of updated properties properties -- set of updated properties
calls: calls:
_set_self_current_activity current-activity _set_self_current_activity current-activity
_set_self_alias nick _set_self_alias nick
_set_self_olpc_properties color _set_self_olpc_properties color
depending on which properties are present in the depending on which properties are present in the
set of properties. set of properties.
""" """
_logger.debug("Owner properties changed: %s" % properties) _logger.debug("Owner properties changed: %s" % properties)
@ -211,18 +212,18 @@ class ServerPlugin(gobject.GObject):
self._set_self_avatar(icon) self._set_self_avatar(icon)
def _get_account_info(self): def _get_account_info(self):
"""Retrieve metadata dictionary describing this account """Retrieve metadata dictionary describing this account
returns dictionary with: returns dictionary with:
server : server url from owner server : server url from owner
account : printable-ssh-key-hash@server account : printable-ssh-key-hash@server
password : ssh-key-hash password : ssh-key-hash
register : whether to register (i.e. whether not yet register : whether to register (i.e. whether not yet
registered) registered)
""" """
account_info = {} account_info = {}
account_info['server'] = self._owner.get_server() account_info['server'] = self._owner.get_server()
khash = util.printable_hash(util._sha_data(self._owner.props.key)) khash = util.printable_hash(util._sha_data(self._owner.props.key))
@ -235,14 +236,14 @@ class ServerPlugin(gobject.GObject):
return account_info return account_info
def _find_existing_connection(self): def _find_existing_connection(self):
"""Try to find an existing Telepathy connection to this server """Try to find an existing Telepathy connection to this server
filters the set of connections from filters the set of connections from
telepathy.client.Connection.get_connections telepathy.client.Connection.get_connections
to find a connection using our protocol with the to find a connection using our protocol with the
"self handle" of that connection being a handle "self handle" of that connection being a handle
which matches our account (see _get_account_info) which matches our account (see _get_account_info)
returns connection or None returns connection or None
""" """
our_name = self._account['account'] our_name = self._account['account']
@ -275,14 +276,14 @@ class ServerPlugin(gobject.GObject):
_logger.debug("Connect error: %s" % exception) _logger.debug("Connect error: %s" % exception)
def _init_connection(self): def _init_connection(self):
"""Set up our connection """Set up our connection
if there is no existing connection if there is no existing connection
(_find_existing_connection returns None) (_find_existing_connection returns None)
produce a new connection with our protocol for our produce a new connection with our protocol for our
account. account.
if there is an existing connection, reuse it by if there is an existing connection, reuse it by
registering for various of events on it. registering for various of events on it.
""" """
conn = self._find_existing_connection() conn = self._find_existing_connection()
@ -317,7 +318,7 @@ class ServerPlugin(gobject.GObject):
def _request_list_channel(self, name): def _request_list_channel(self, name):
"""Request a contact-list channel from Telepathy """Request a contact-list channel from Telepathy
name -- publish/subscribe, for the type of channel name -- publish/subscribe, for the type of channel
""" """
handle = self._conn[CONN_INTERFACE].RequestHandles( handle = self._conn[CONN_INTERFACE].RequestHandles(
@ -331,7 +332,7 @@ class ServerPlugin(gobject.GObject):
return channel return channel
def _connected_cb(self): def _connected_cb(self):
"""Callback on successful connection to a server """Callback on successful connection to a server
""" """
if self._account['register']: if self._account['register']:
@ -494,29 +495,29 @@ class ServerPlugin(gobject.GObject):
error_handler=lambda e: self._join_error_cb(activity_id, signal, userdata, 'RequestHandles([%u])' % room_jid, e)) error_handler=lambda e: self._join_error_cb(activity_id, signal, userdata, 'RequestHandles([%u])' % room_jid, e))
else: else:
self._join_activity_get_channel_cb(activity_id, signal, userdata, [handle]) self._join_activity_get_channel_cb(activity_id, signal, userdata, [handle])
def share_activity(self, activity_id, userdata): def share_activity(self, activity_id, userdata):
"""Share activity with the network """Share activity with the network
activity_id -- unique ID for the activity activity_id -- unique ID for the activity
userdata -- opaque token to be passed in the resulting event userdata -- opaque token to be passed in the resulting event
(id, callback, errback) normally (id, callback, errback) normally
Asks the Telepathy server to create a "conference" channel Asks the Telepathy server to create a "conference" channel
for the activity or return a handle to an already created for the activity or return a handle to an already created
conference channel for the activity. conference channel for the activity.
""" """
self._internal_join_activity(activity_id, "activity-shared", userdata) self._internal_join_activity(activity_id, "activity-shared", userdata)
def join_activity(self, activity_id, userdata): def join_activity(self, activity_id, userdata):
"""Join an activity on the network (or locally) """Join an activity on the network (or locally)
activity_id -- unique ID for the activity activity_id -- unique ID for the activity
userdata -- opaque token to be passed in the resulting event userdata -- opaque token to be passed in the resulting event
(id, callback, errback) normally (id, callback, errback) normally
Asks the Telepathy server to create a "conference" channel Asks the Telepathy server to create a "conference" channel
for the activity or return a handle to an already created for the activity or return a handle to an already created
conference channel for the activity. conference channel for the activity.
""" """
self._internal_join_activity(activity_id, "activity-joined", userdata) self._internal_join_activity(activity_id, "activity-joined", userdata)
@ -552,8 +553,8 @@ class ServerPlugin(gobject.GObject):
return False return False
def _set_self_activities(self): def _set_self_activities(self):
"""Forward set of joined activities to network """Forward set of joined activities to network
uses SetActivities on BuddyInfo channel uses SetActivities on BuddyInfo channel
""" """
self._conn[CONN_INTERFACE_BUDDY_INFO].SetActivities(self._joined_activities, self._conn[CONN_INTERFACE_BUDDY_INFO].SetActivities(self._joined_activities,
@ -562,7 +563,7 @@ class ServerPlugin(gobject.GObject):
def _set_self_current_activity(self): def _set_self_current_activity(self):
"""Forward our current activity (or "") to network """Forward our current activity (or "") to network
uses SetCurrentActivity on BuddyInfo channel uses SetCurrentActivity on BuddyInfo channel
""" """
cur_activity = self._owner.props.current_activity cur_activity = self._owner.props.current_activity
@ -632,7 +633,7 @@ class ServerPlugin(gobject.GObject):
def _status_changed_cb(self, status, reason): def _status_changed_cb(self, status, reason):
"""Handle notification of connection-status change """Handle notification of connection-status change
status -- CONNECTION_STATUS_* status -- CONNECTION_STATUS_*
reason -- integer code describing the reason... reason -- integer code describing the reason...
""" """
@ -641,13 +642,13 @@ class ServerPlugin(gobject.GObject):
def start(self): def start(self):
"""Start up the Telepathy networking connections """Start up the Telepathy networking connections
if we are already connected, query for the initial contact if we are already connected, query for the initial contact
information. information.
if we are already connecting, do nothing if we are already connecting, do nothing
otherwise initiate a connection and transfer control to otherwise initiate a connection and transfer control to
_connect_reply_cb or _connect_error_cb _connect_reply_cb or _connect_error_cb
""" """
_logger.debug("Starting up...") _logger.debug("Starting up...")
@ -751,7 +752,7 @@ class ServerPlugin(gobject.GObject):
return False return False
def _contact_online_properties_error_cb(self, handle, tries, err): def _contact_online_properties_error_cb(self, handle, tries, err):
"""Handle error retrieving property-set for a user (handle)""" """Handle error retrieving property-set for a user (handle)"""
if tries <= 3: if tries <= 3:
_logger.debug("Handle %s - Error getting properties (will retry): %s" % (handle, err)) _logger.debug("Handle %s - Error getting properties (will retry): %s" % (handle, err))
tries += 1 tries += 1
@ -892,7 +893,7 @@ class ServerPlugin(gobject.GObject):
def _buddy_current_activity_changed_cb(self, handle, activity, channel): def _buddy_current_activity_changed_cb(self, handle, activity, channel):
"""Handle update of given user (handle)'s current activity""" """Handle update of given user (handle)'s current activity"""
if handle == self._conn[CONN_INTERFACE].GetSelfHandle(): if handle == self._conn[CONN_INTERFACE].GetSelfHandle():
# ignore network events for Owner current activity changes since those # ignore network events for Owner current activity changes since those
# are handled locally # are handled locally