-import httplib
-import gnome.gconf
-from oauth import oauth
-from xml.dom.minidom import parseString
-
-import org.maemo.hermes.engine.service
-from org.maemo.hermes.engine.friend import Friend
+import org.maemo.hermes.engine.facebook.service
from org.maemo.hermes.engine.names import canonical
-# httplib.HTTPSConnection.debuglevel = 1
-class Service(org.maemo.hermes.engine.service.Service):
+class Service(org.maemo.hermes.engine.facebook.service.Service):
"""LinkedIn backend for Hermes.
- This sets up two gconf paths to contain LinkedIn OAuth keys:
- /apps/maemo/hermes/linkedin_oauth
- /apps/maemo/hermes/linkedin_verifier
-
Copyright (c) Fredrik Wendt <fredrik@wendt.se> 2010.
Released under the Artistic Licence."""
- LI_SERVER = "api.linkedin.com"
- LI_API_URL = "https://api.linkedin.com"
- LI_CONN_API_URL = LI_API_URL + "/v1/people/~/connections"
-
- REQUEST_TOKEN_URL = LI_API_URL + "/uas/oauth/requestToken"
- AUTHORIZE_URL = LI_API_URL + "/uas/oauth/authorize"
- ACCESS_TOKEN_URL = LI_API_URL + "/uas/oauth/accessToken"
-
-
# -----------------------------------------------------------------------
- def __init__(self, autocreate=False, gui_callback=None):
- """Initialize the LinkedIn service, finding LinkedIn API keys in gconf and
- having a gui_callback available."""
-
- self._gc = gnome.gconf.client_get_default()
- self._gui = gui_callback
- self._autocreate = autocreate
-
- # -- Check the environment is going to work...
- #
- if (self._gc.get_string('/desktop/gnome/url-handlers/http/command') == 'epiphany %s'):
- raise Exception('Browser in gconf invalid (see NB#136012). Installation error.')
-
- api_key = self._gc.get_string('/apps/maemo/hermes/linkedin_api_key')
- secret_key = self._gc.get_string('/apps/maemo/hermes/linkedin_key_secret')
-
- # FIXME: remove this
- api_key = '1et4G-VtmtqNfY7gF8PHtxMOf0KNWl9ericlTEtdKJeoA4ubk4wEQwf8lSL8AnYE'
- secret_key = 'uk--OtmWcxER-Yh6Py5p0VeLPNlDJSMaXj1xfHILoFzrK7fM9eepNo5RbwGdkRo_'
+ def __init__(self, service_id, linkedInApi):
+ org.maemo.hermes.engine.facebook.service.Service.__init__(self, service_id, None)
+ self.linkedInApi = linkedInApi
- if api_key is None or secret_key is None:
- raise Exception('No LinkedIn application keys found. Installation error.')
-
- self.api_key = api_key
- self.secret_key = secret_key
-
- # FIXME: move this
- token_str = "oauth_token_secret=60f817af-6437-4015-962f-cc3aefee0264&oauth_token=f89c2b7b-1c12-4f83-a469-838e78901716"
- self.access_token = oauth.OAuthToken.from_string(token_str)
-
- self.consumer = oauth.OAuthConsumer(api_key, secret_key)
- self.sig_method = oauth.OAuthSignatureMethod_HMAC_SHA1()
- self._friends_by_name = None
- self._friends_by_url = {}
- self._friends_by_contact = {}
-
- self.get_friends()
-
-
# -----------------------------------------------------------------------
- def get_name(self):
- return "LinkedIn"
-
-
- # -----------------------------------------------------------------------
- def get_friends(self):
- """Return a list of friends from this service, or 'None' if manual mapping
- is not supported."""
-
- if self._friends_by_name:
- return self._friends_by_name.values()
-
- # FIXME: Check the available OAuth session is still valid...
-
- # get data
- self._friends_by_name = {}
-
- xml = self._make_api_request(self.LI_CONN_API_URL)
- dom = parseString(xml)
-
- self._parse_dom(dom)
-
- print "get_friends found", len(self._friends_by_name)
- return self._friends_by_name.values()
-
-
-
- # -----------------------------------------------------------------------
- def pre_process_contact(self, contact):
- """Makes sure that if the contact has been mapped to a friend before,
- remove the friend from "new friends" list."""
-
- for url in contact.get_urls():
- if url in self._friends_by_url:
- matched_friend = self._friends_by_url[url]
- print "Contact is known as a friend on this service (by URL) %s - %s" % (url, matched_friend)
- self._friends_by_contact[contact] = matched_friend
-
-
- # -----------------------------------------------------------------------
- def process_contact(self, contact, friend):
- """Updates friend if the contact can be mapped to a friend on LinkedIn,
- either by previous mapping or by identifiers."""
-
- if self._friends_by_contact.has_key(contact):
- friend.update(self._friends_by_contact[contact])
- else:
- self._match_contact_by_identifiers(contact, friend)
-
-
- # -----------------------------------------------------------------------
- def finalise(self, updated):
- if self._autocreate or True:
- for f in self._friends_by_name.values():
- if f not in self._friends_by_contact.values():
- # FIXME: create friends as contact
- print "Could/should create contact here for %s" % f
-
-
- # -----------------------------------------------------------------------
- def _get_access_token(self, token, verifier):
- """user provides the verifier, which was displayed in the browser window"""
-
- oauth_request = oauth.OAuthRequest.from_consumer_and_token(self.consumer, token=token, verifier=verifier, http_url=self.ACCESS_TOKEN_URL)
- oauth_request.sign_request(self.sig_method, self.consumer, token)
-
- connection = httplib.HTTPSConnection(self.LI_SERVER)
- connection.request(oauth_request.http_method, self.ACCESS_TOKEN_URL, headers=oauth_request.to_header())
- response = connection.getresponse()
- return oauth.OAuthToken.from_string(response.read())
-
-
- # -----------------------------------------------------------------------
- def _get_authorize_url(self, token):
- """The URL that the user should browse to, in order to authorize the application to acess data"""
-
- oauth_request = oauth.OAuthRequest.from_token_and_callback(token=token, http_url=self.AUTHORIZE_URL)
- return oauth_request.to_url()
-
-
- # -----------------------------------------------------------------------
- def _get_request_token(self, callback):
- """Get a request token from LinkedIn"""
-
- oauth_consumer_key = self.api_key
- oauth_request = oauth.OAuthRequest.from_consumer_and_token(self.consumer, callback=callback, http_url=self.REQUEST_TOKEN_URL)
- oauth_request.sign_request(self.sig_method, self.consumer, None)
-
- connection = httplib.HTTPSConnection(self.LI_SERVER)
- connection.request(oauth_request.http_method, self.REQUEST_TOKEN_URL, headers=oauth_request.to_header())
- response = self.connection.getresponse().read()
-
- token = oauth.OAuthToken.from_string(response)
- return token
-
-
- # -----------------------------------------------------------------------
- def _make_api_request(self, url):
- print "_make_api_request", url
- oauth_request = oauth.OAuthRequest.from_consumer_and_token(self.consumer, token=self.access_token, http_url=url)
- oauth_request.sign_request(self.sig_method, self.consumer, self.access_token)
- connection = httplib.HTTPSConnection(self.LI_SERVER)
- try:
- connection.request(oauth_request.http_method, url, headers=oauth_request.to_header())
- return connection.getresponse().read()
- except:
- raise Exception("Failed to contact LinkedIn at " + url)
-
-
- # -----------------------------------------------------------------------
- def _do_li_login(self):
- """Perform authentication against LinkedIn and store the result in gconf
- for later use. Uses the 'need_auth' and 'block_for_auth' methods on
- the callback class. The former allows a message to warn the user
- about what is about to happen to be shown; the second is to wait
- for the user to confirm they have logged in."""
- # FIXME
-
-
- # -----------------------------------------------------------------------
- def _match_contact_by_identifiers(self, contact, friend):
- for id in contact.get_identifiers():
- if id in self._friends_by_name:
- matched_friend = self._friends_by_name[id]
- if matched_friend in self._friends_by_contact.values():
- print "Avoiding assigning same friend to two contacts: %s " % matched_friend
- else:
- self._friends_by_contact[contact] = matched_friend
- friend.update(matched_friend)
-
-
- # -----------------------------------------------------------------------
- def _parse_dom(self, dom):
- print "parse_dom", dom
- def get_first_tag(node, tagName):
- tags = node.getElementsByTagName(tagName)
- if tags and len(tags) > 0:
- return tags[0]
-
- def extract(node, tagName):
- tag = get_first_tag(node, tagName)
- if tag:
- return tag.firstChild.nodeValue
-
- def extract_public_url(node):
- tag = get_first_tag(node, 'site-standard-profile-request')
- if tag:
- url = extract(tag, 'url')
- return url.replace("&", "&")
-
- # FIXME: look for <error>
- people = dom.getElementsByTagName('person')
- for p in people:
- # try:
- if True:
- fn = extract(p, 'first-name')
- ln = extract(p, 'last-name')
- photo_url = extract(p, 'picture-url')
- id = extract(p, 'id')
- public_url = extract_public_url(p)
-
- name = fn + " " + ln
- friend = Friend(name)
- friend.add_url(public_url)
- if photo_url: friend.set_photo_url(photo_url)
-
- key = canonical(name)
- self._friends_by_name[key] = friend
- self._friends_by_url[public_url] = friend
-# except:
-# continue
+ def process_friends(self):
+ friends = self.linkedInApi.get_friends()
+ for friend in friends:
+ self._register_friend(friend)
projects / hermes / blobdiff