git.maemo.org Git - hermes/blob - package/src/org/maemo/hermes/engine/twitter/service.py

   1 from org.maemo.hermes.engine.names import canonical
   2 import org.maemo.hermes.engine.service
   3
   4 class Service(org.maemo.hermes.engine.service.Service):
   5     """Twitter backend for Hermes.
   6
   7        Copyright (c) Andrew Flegg <andrew@bleb.org> 2010.
   8        Copyright (c) Fredrik Wendt <fredrik@wendt.se> 2010.
   9        Released under the Artistic Licence."""
  10
  11
  12     # -----------------------------------------------------------------------
  13     def __init__(self, twitterApi):
  14         self._twitter = twitterApi
  15
  16         self._friends_by_name = {}
  17         self._friends_by_url = {}
  18         self._friends_by_contact = {}
  19         self._friends = []
  20         self._known_urls = set()
  21
  22
  23     # -----------------------------------------------------------------------
  24     def get_name(self):
  25         return "Twitter"
  26
  27
  28     # -----------------------------------------------------------------------
  29     def pre_process_contact(self, contact):
  30         """Registers URLs of all previous mappings, and makes sure that any Friends with those
  31            URLs don't get match by name."""
  32         for url in contact.get_urls():
  33             self._known_urls.add(url)
  34
  35
  36     # -----------------------------------------------------------------------
  37     def process_friends(self):
  38         for tweeter in self._get_tweeters():
  39             key = canonical(tweeter.name)
  40             url = 'http://twitter.com/%s' % (tweeter.screen_name)
  41             friend = self._create_friend(tweeter.name)
  42             friend.set_nickname(tweeter.screen_name)
  43             friend.add_url(url)
  44             friend.add_url(tweeter.url)
  45             if '/default_profile' not in tweeter.profile_image_url:
  46                 friend.set_photo_url(tweeter.profile_image_url)
  47
  48             self._friends.append(friend)
  49             self._friends_by_url[url] = friend
  50             if url not in self._known_urls:
  51                 self._friends_by_name[key] = friend
  52
  53
  54     # -----------------------------------------------------------------------
  55     def process_contact(self, contact):
  56         if self._friends_by_contact.has_key(contact) or \
  57             self._match_contact_to_friend_by_urls(contact) or \
  58             self._match_contact_to_friend_by_identifiers(contact):
  59             return self._get_friend_by_contact(contact)
  60
  61         return None
  62
  63
  64     # -----------------------------------------------------------------------
  65     def finalise(self, updated, overwrite=False):
  66         pass
  67
  68
  69     # -----------------------------------------------------------------------
  70     def get_contacts_with_match(self):
  71         return self._friends_by_contact
  72
  73
  74     # -----------------------------------------------------------------------
  75     def get_unmatched_friends(self):
  76         return self._friends
  77
  78
  79     # -----------------------------------------------------------------------
  80     def _get_tweeters(self):
  81         return self._twitter.GetFriends()
  82
  83
  84     # -----------------------------------------------------------------------
  85     def _get_friend_by_contact(self, contact):
  86         return self._friends_by_contact[contact]
  87
  88
  89     def _match_contact_to_friend_by_urls(self, contact):
  90         for url in contact.get_urls():
  91             if url in self._friends_by_url:
  92                 matched_friend = self._friends_by_url[url]
  93                 self._register_match(contact, matched_friend)
  94                 return True
  95
  96         return False
  97
  98
  99     def _match_contact_to_friend_by_identifiers(self, contact):
 100         for id in contact.get_identifiers():
 101             if id in self._friends_by_name:
 102                 matched_friend = self._friends_by_name[id]
 103                 self._register_match(contact, matched_friend)
 104                 return True
 105
 106         return False
 107
 108
 109     def _register_match(self, contact, friend):
 110         friend.set_contact(contact)
 111         self._friends_by_contact[contact] = friend
 112         self._friends.remove(friend)
 113