3 * Laconica - a distributed open-source microblogging tool
4 * Copyright (C) 2008, 2009, Control Yourself, Inc.
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.
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.
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/>.
20 if (!defined('LACONICA')) {
24 require_once INSTALLDIR.'/lib/oauthstore.php';
25 require_once 'OAuth.php';
26 require_once 'libomb/constants.php';
27 require_once 'libomb/service_consumer.php';
28 require_once 'libomb/notice.php';
29 require_once 'libomb/profile.php';
30 require_once 'Auth/Yadis/Yadis.php';
32 function omb_oauth_consumer()
36 $con = new OAuthConsumer(common_root_url(), '');
41 function omb_oauth_server()
43 static $server = null;
44 if (is_null($server)) {
45 $server = new OAuthServer(omb_oauth_datastore());
46 $server->add_signature_method(omb_hmac_sha1());
51 function omb_oauth_datastore()
54 if (is_null($store)) {
55 $store = new LaconicaDataStore();
60 function omb_hmac_sha1()
62 static $hmac_method = null;
63 if (is_null($hmac_method)) {
64 $hmac_method = new OAuthSignatureMethod_HMAC_SHA1();
69 function omb_broadcast_notice($notice)
72 $omb_notice = notice_to_omb_notice($notice);
74 /* Get remote users subscribed to this profile. */
75 $rp = new Remote_profile();
77 $rp->query('SELECT postnoticeurl, token, secret ' .
78 'FROM subscription JOIN remote_profile ' .
79 'ON subscription.subscriber = remote_profile.id ' .
80 'WHERE subscription.subscribed = ' . $notice->profile_id . ' ');
84 while ($rp->fetch()) {
85 if (isset($posted[$rp->postnoticeurl])) {
86 /* We already posted to this url. */
89 common_debug('Posting to ' . $rp->postnoticeurl, __FILE__);
92 $service = new Laconica_OMB_Service_Consumer(
93 array(OMB_ENDPOINT_POSTNOTICE => $rp->postnoticeurl));
95 $service->setToken($rp->token, $rp->secret);
96 $service->postNotice($omb_notice);
97 } catch (Exception $e) {
98 common_log(LOG_ERR, 'Failed posting to ' . $rp->postnoticeurl);
99 common_log(LOG_ERR, 'Error status '.$e);
102 $posted[$rp->postnoticeurl] = true;
104 common_debug('Finished to ' . $rp->postnoticeurl, __FILE__);
110 function omb_broadcast_profile($profile)
112 $user = User::staticGet('id', $profile->id);
118 $profile = $user->getProfile();
120 $omb_profile = profile_to_omb_profile($user->uri, $profile, true);
122 /* Get remote users subscribed to this profile. */
123 $rp = new Remote_profile();
125 $rp->query('SELECT updateprofileurl, token, secret ' .
126 'FROM subscription JOIN remote_profile ' .
127 'ON subscription.subscriber = remote_profile.id ' .
128 'WHERE subscription.subscribed = ' . $profile->id . ' ');
132 while ($rp->fetch()) {
133 if (isset($posted[$rp->updateprofileurl])) {
134 /* We already posted to this url. */
137 common_debug('Posting to ' . $rp->updateprofileurl, __FILE__);
139 /* Update profile. */
140 $service = new Laconica_OMB_Service_Consumer(
141 array(OMB_ENDPOINT_UPDATEPROFILE => $rp->updateprofileurl));
143 $service->setToken($rp->token, $rp->secret);
144 $service->updateProfile($omb_profile);
145 } catch (Exception $e) {
146 common_log(LOG_ERR, 'Failed posting to ' . $rp->updateprofileurl);
147 common_log(LOG_ERR, 'Error status '.$e);
150 $posted[$rp->updateprofileurl] = true;
152 common_debug('Finished to ' . $rp->updateprofileurl, __FILE__);
158 class Laconica_OMB_Service_Consumer extends OMB_Service_Consumer {
159 public function __construct($urls)
161 $this->services = $urls;
162 $this->datastore = omb_oauth_datastore();
163 $this->oauth_consumer = omb_oauth_consumer();
164 $this->fetcher = Auth_Yadis_Yadis::getHTTPFetcher();
169 function profile_to_omb_profile($uri, $profile, $force = false)
171 $omb_profile = new OMB_Profile($uri);
172 $omb_profile->setNickname($profile->nickname);
173 $omb_profile->setLicenseURL(common_config('license', 'url'));
174 if (!is_null($profile->fullname)) {
175 $omb_profile->setFullname($profile->fullname);
177 $omb_profile->setFullname('');
179 if (!is_null($profile->homepage)) {
180 $omb_profile->setHomepage($profile->homepage);
182 $omb_profile->setHomepage('');
184 if (!is_null($profile->bio)) {
185 $omb_profile->setBio($profile->bio);
187 $omb_profile->setBio('');
189 if (!is_null($profile->location)) {
190 $omb_profile->setLocation($profile->location);
192 $omb_profile->setLocation('');
194 if (!is_null($profile->profileurl)) {
195 $omb_profile->setProfileURL($profile->profileurl);
197 $omb_profile->setProfileURL('');
200 $avatar = $profile->getAvatar(AVATAR_PROFILE_SIZE);
202 $omb_profile->setAvatarURL($avatar->url);
204 $omb_profile->setAvatarURL('');
209 function notice_to_omb_notice($notice)
211 /* Create an OMB_Notice for $notice. */
212 $user = User::staticGet('id', $notice->profile_id);
218 $profile = $user->getProfile();
220 $omb_notice = new OMB_Notice(profile_to_omb_profile($user->uri, $profile),
223 $omb_notice->setURL(common_local_url('shownotice', array('notice' =>
225 $omb_notice->setLicenseURL(common_config('license', 'url'));