lib/omb.php

   1 <?php
   2 /*
   3  * StatusNet - the distributed open-source microblogging tool
   4  * Copyright (C) 2008, 2009, StatusNet, Inc.
   5  *
   6  * This program is free software: you can redistribute it and/or modify
   7  * it under the terms of the GNU Affero General Public License as published by
   8  * the Free Software Foundation, either version 3 of the License, or
   9  * (at your option) any later version.
  10  *
  11  * This program is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  * GNU Affero General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Affero General Public License
  17  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18  */
  19
  20 if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
  21
  22 require_once INSTALLDIR.'/lib/oauthstore.php';
  23 require_once 'OAuth.php';
  24 require_once 'libomb/constants.php';
  25 require_once 'libomb/service_consumer.php';
  26 require_once 'libomb/notice.php';
  27 require_once 'libomb/profile.php';
  28 require_once 'Auth/Yadis/Yadis.php';
  29
  30 function omb_oauth_consumer()
  31 {
  32     // Don't try to make this static. Leads to issues in
  33     // multi-site setups - Z
  34     return new OAuthConsumer(common_root_url(), '');
  35 }
  36
  37 function omb_oauth_server()
  38 {
  39     static $server = null;
  40     if (is_null($server)) {
  41         $server = new OAuthServer(omb_oauth_datastore());
  42         $server->add_signature_method(omb_hmac_sha1());
  43     }
  44     return $server;
  45 }
  46
  47 function omb_oauth_datastore()
  48 {
  49     static $store = null;
  50     if (is_null($store)) {
  51         $store = new StatusNetOAuthDataStore();
  52     }
  53     return $store;
  54 }
  55
  56 function omb_hmac_sha1()
  57 {
  58     static $hmac_method = null;
  59     if (is_null($hmac_method)) {
  60         $hmac_method = new OAuthSignatureMethod_HMAC_SHA1();
  61     }
  62     return $hmac_method;
  63 }
  64
  65 function omb_broadcast_notice($notice)
  66 {
  67
  68     try {
  69         $omb_notice = notice_to_omb_notice($notice);
  70     } catch (Exception $e) {
  71         // @fixme we should clean up or highlight the problem item
  72         common_log(LOG_ERR, 'Invalid OMB outgoing notice for notice ' . $notice->id);
  73         common_log(LOG_ERR, 'Error status '.$e);
  74         return true;
  75     }
  76
  77     /* Get remote users subscribed to this profile. */
  78     $rp = new Remote_profile();
  79
  80     $rp->query('SELECT remote_profile.*, secret, token ' .
  81                'FROM subscription JOIN remote_profile ' .
  82                'ON subscription.subscriber = remote_profile.id ' .
  83                'WHERE subscription.subscribed = ' . $notice->profile_id . ' ');
  84
  85     $posted = array();
  86
  87     while ($rp->fetch()) {
  88         if (isset($posted[$rp->postnoticeurl])) {
  89             /* We already posted to this url. */
  90             continue;
  91         }
  92         common_debug('Posting to ' . $rp->postnoticeurl, __FILE__);
  93
  94         /* Post notice. */
  95         $service = new StatusNet_OMB_Service_Consumer(
  96                      array(OMB_ENDPOINT_POSTNOTICE => $rp->postnoticeurl),
  97                                                       $rp->uri);
  98         try {
  99             $service->setToken($rp->token, $rp->secret);
 100             $service->postNotice($omb_notice);
 101         } catch (Exception $e) {
 102             common_log(LOG_ERR, 'Failed posting to ' . $rp->postnoticeurl);
 103             common_log(LOG_ERR, 'Error status '.$e);
 104             continue;
 105         }
 106         $posted[$rp->postnoticeurl] = true;
 107
 108         common_debug('Finished to ' . $rp->postnoticeurl, __FILE__);
 109     }
 110
 111     return true;
 112 }
 113
 114 function omb_broadcast_profile($profile)
 115 {
 116     $user = User::staticGet('id', $profile->id);
 117
 118     if (!$user) {
 119         return false;
 120     }
 121
 122     $profile = $user->getProfile();
 123
 124     $omb_profile = profile_to_omb_profile($user->uri, $profile, true);
 125
 126     /* Get remote users subscribed to this profile. */
 127     $rp = new Remote_profile();
 128
 129     $rp->query('SELECT remote_profile.*, secret, token ' .
 130                'FROM subscription JOIN remote_profile ' .
 131                'ON subscription.subscriber = remote_profile.id ' .
 132                'WHERE subscription.subscribed = ' . $profile->id . ' ');
 133
 134     $posted = array();
 135
 136     while ($rp->fetch()) {
 137         if (isset($posted[$rp->updateprofileurl])) {
 138             /* We already posted to this url. */
 139             continue;
 140         }
 141         common_debug('Posting to ' . $rp->updateprofileurl, __FILE__);
 142
 143         /* Update profile. */
 144         $service = new StatusNet_OMB_Service_Consumer(
 145                      array(OMB_ENDPOINT_UPDATEPROFILE => $rp->updateprofileurl),
 146                                                       $rp->uri);
 147         try {
 148             $service->setToken($rp->token, $rp->secret);
 149             $service->updateProfile($omb_profile);
 150         } catch (Exception $e) {
 151             common_log(LOG_ERR, 'Failed posting to ' . $rp->updateprofileurl);
 152             common_log(LOG_ERR, 'Error status '.$e);
 153             continue;
 154         }
 155         $posted[$rp->updateprofileurl] = true;
 156
 157         common_debug('Finished to ' . $rp->updateprofileurl, __FILE__);
 158     }
 159
 160     return;
 161 }
 162
 163 class StatusNet_OMB_Service_Consumer extends OMB_Service_Consumer {
 164     public function __construct($urls, $listener_uri=null)
 165     {
 166         $this->services       = $urls;
 167         $this->datastore      = omb_oauth_datastore();
 168         $this->oauth_consumer = omb_oauth_consumer();
 169         $this->fetcher        = Auth_Yadis_Yadis::getHTTPFetcher();
 170         $this->fetcher->timeout = intval(common_config('omb', 'timeout'));
 171         $this->listener_uri   = $listener_uri;
 172     }
 173
 174 }
 175
 176 function profile_to_omb_profile($uri, $profile, $force = false)
 177 {
 178     $omb_profile = new OMB_Profile($uri);
 179     $omb_profile->setNickname($profile->nickname);
 180     $omb_profile->setLicenseURL(common_config('license', 'url'));
 181     if (!is_null($profile->fullname)) {
 182         $omb_profile->setFullname($profile->fullname);
 183     } elseif ($force) {
 184         $omb_profile->setFullname('');
 185     }
 186     if (!is_null($profile->homepage)) {
 187         $omb_profile->setHomepage($profile->homepage);
 188     } elseif ($force) {
 189         $omb_profile->setHomepage('');
 190     }
 191     if (!is_null($profile->bio)) {
 192         $omb_profile->setBio($profile->bio);
 193     } elseif ($force) {
 194         $omb_profile->setBio('');
 195     }
 196     if (!is_null($profile->location)) {
 197         $omb_profile->setLocation($profile->location);
 198     } elseif ($force) {
 199         $omb_profile->setLocation('');
 200     }
 201     if (!is_null($profile->profileurl)) {
 202         $omb_profile->setProfileURL($profile->profileurl);
 203     } elseif ($force) {
 204         $omb_profile->setProfileURL('');
 205     }
 206
 207     $avatar = $profile->getAvatar(AVATAR_PROFILE_SIZE);
 208     if ($avatar) {
 209         $omb_profile->setAvatarURL($avatar->url);
 210     } elseif ($force) {
 211         $omb_profile->setAvatarURL('');
 212     }
 213     return $omb_profile;
 214 }
 215
 216 function notice_to_omb_notice($notice)
 217 {
 218     /* Create an OMB_Notice for $notice. */
 219     $user = User::staticGet('id', $notice->profile_id);
 220
 221     if (!$user) {
 222         return null;
 223     }
 224
 225     $profile = $user->getProfile();
 226
 227     $omb_notice = new OMB_Notice(profile_to_omb_profile($user->uri, $profile),
 228                                  $notice->uri,
 229                                  $notice->content);
 230     $omb_notice->setURL(common_local_url('shownotice', array('notice' =>
 231                                                                  $notice->id)));
 232     $omb_notice->setLicenseURL(common_config('license', 'url'));
 233
 234     return $omb_notice;
 235 }
 236 ?>