2008-05-28 05:07:21 +09:00
|
|
|
|
<?php
|
|
|
|
|
/*
|
2009-08-26 07:14:12 +09:00
|
|
|
|
* StatusNet - the distributed open-source microblogging tool
|
2011-07-16 04:13:57 +09:00
|
|
|
|
* Copyright (C) 2008-2011 StatusNet, Inc.
|
2008-05-28 05:07:21 +09:00
|
|
|
|
*
|
|
|
|
|
* This program is free software: you can redistribute it and/or modify
|
|
|
|
|
* it under the terms of the GNU Affero General Public License as published by
|
|
|
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
|
|
|
* (at your option) any later version.
|
|
|
|
|
*
|
|
|
|
|
* This program is distributed in the hope that it will be useful,
|
|
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
|
* GNU Affero General Public License for more details.
|
|
|
|
|
*
|
|
|
|
|
* You should have received a copy of the GNU Affero General Public License
|
|
|
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
*/
|
|
|
|
|
|
2009-08-26 23:41:36 +09:00
|
|
|
|
if (!defined('STATUSNET') && !defined('LACONICA')) { exit(1); }
|
2008-05-28 05:07:21 +09:00
|
|
|
|
|
2011-07-16 04:13:57 +09:00
|
|
|
|
require_once dirname(__FILE__) . '/../extlib/libomb/datastore.php';
|
2008-05-28 05:07:21 +09:00
|
|
|
|
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// @todo FIXME: Class documentation missing.
|
2011-07-16 04:13:57 +09:00
|
|
|
|
class OMBOAuthDataStore extends OAuthDataStore
|
2008-12-24 04:49:23 +09:00
|
|
|
|
{
|
|
|
|
|
// We keep a record of who's contacted us
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function lookup_consumer($consumer_key)
|
|
|
|
|
{
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$con = Consumer::getKV('consumer_key', $consumer_key);
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$con) {
|
|
|
|
|
$con = new Consumer();
|
|
|
|
|
$con->consumer_key = $consumer_key;
|
|
|
|
|
$con->seed = common_good_rand(16);
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$con->created = common_sql_now();
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$con->insert()) {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return new OAuthConsumer($con->consumer_key, '');
|
|
|
|
|
}
|
2008-07-10 07:46:30 +09:00
|
|
|
|
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function lookup_token($consumer, $token_type, $token_key)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$t = new Token();
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!is_null($consumer)) {
|
|
|
|
|
$t->consumer_key = $consumer->key;
|
|
|
|
|
}
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$t->tok = $token_key;
|
|
|
|
|
$t->type = ($token_type == 'access') ? 1 : 0;
|
|
|
|
|
if ($t->find(true)) {
|
|
|
|
|
return new OAuthToken($t->tok, $t->secret);
|
|
|
|
|
} else {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
2008-07-10 07:46:30 +09:00
|
|
|
|
|
2009-03-08 06:00:13 +09:00
|
|
|
|
// http://oauth.net/core/1.0/#nonce
|
|
|
|
|
// "The Consumer SHALL then generate a Nonce value that is unique for
|
|
|
|
|
// all requests with that timestamp."
|
|
|
|
|
// XXX: It's not clear why the token is here
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function lookup_nonce($consumer, $token, $nonce, $timestamp)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$n = new Nonce();
|
|
|
|
|
$n->consumer_key = $consumer->key;
|
2010-02-05 10:38:29 +09:00
|
|
|
|
$n->ts = common_sql_date($timestamp);
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$n->nonce = $nonce;
|
2008-12-24 04:44:28 +09:00
|
|
|
|
if ($n->find(true)) {
|
|
|
|
|
return true;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
} else {
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$n->created = common_sql_now();
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$n->insert();
|
2008-12-24 04:44:28 +09:00
|
|
|
|
return false;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
2008-07-10 07:46:30 +09:00
|
|
|
|
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function new_request_token($consumer)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$t = new Token();
|
|
|
|
|
$t->consumer_key = $consumer->key;
|
|
|
|
|
$t->tok = common_good_rand(16);
|
|
|
|
|
$t->secret = common_good_rand(16);
|
2008-12-24 04:49:23 +09:00
|
|
|
|
$t->type = 0; // request
|
|
|
|
|
$t->state = 0; // unauthorized
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$t->created = common_sql_now();
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$t->insert()) {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
} else {
|
|
|
|
|
return new OAuthToken($t->tok, $t->secret);
|
|
|
|
|
}
|
|
|
|
|
}
|
2008-05-28 05:07:21 +09:00
|
|
|
|
|
2008-12-24 04:49:23 +09:00
|
|
|
|
// defined in OAuthDataStore, but not implemented anywhere
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function fetch_request_token($consumer)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
return $this->new_request_token($consumer);
|
|
|
|
|
}
|
2008-07-10 07:46:30 +09:00
|
|
|
|
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function new_access_token($token, $consumer)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
common_debug('new_access_token("'.$token->key.'","'.$consumer->key.'")', __FILE__);
|
|
|
|
|
$rt = new Token();
|
|
|
|
|
$rt->consumer_key = $consumer->key;
|
|
|
|
|
$rt->tok = $token->key;
|
2008-12-24 04:49:23 +09:00
|
|
|
|
$rt->type = 0; // request
|
|
|
|
|
if ($rt->find(true) && $rt->state == 1) { // authorized
|
2008-12-24 04:19:07 +09:00
|
|
|
|
common_debug('request token found.', __FILE__);
|
|
|
|
|
$at = new Token();
|
|
|
|
|
$at->consumer_key = $consumer->key;
|
|
|
|
|
$at->tok = common_good_rand(16);
|
|
|
|
|
$at->secret = common_good_rand(16);
|
2008-12-24 04:49:23 +09:00
|
|
|
|
$at->type = 1; // access
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$at->created = common_sql_now();
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$at->insert()) {
|
|
|
|
|
$e = $at->_lastError;
|
|
|
|
|
common_debug('access token "'.$at->tok.'" not inserted: "'.$e->message.'"', __FILE__);
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
} else {
|
|
|
|
|
common_debug('access token "'.$at->tok.'" inserted', __FILE__);
|
2008-12-24 04:49:23 +09:00
|
|
|
|
// burn the old one
|
2008-12-24 04:19:07 +09:00
|
|
|
|
$orig_rt = clone($rt);
|
2008-12-24 04:49:23 +09:00
|
|
|
|
$rt->state = 2; // used
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$rt->update($orig_rt)) {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
common_debug('request token "'.$rt->tok.'" updated', __FILE__);
|
2008-12-24 04:49:23 +09:00
|
|
|
|
// Update subscription
|
|
|
|
|
// XXX: mixing levels here
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$sub = Subscription::getKV('token', $rt->tok);
|
2008-12-24 04:19:07 +09:00
|
|
|
|
if (!$sub) {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
common_debug('subscription for request token found', __FILE__);
|
|
|
|
|
$orig_sub = clone($sub);
|
|
|
|
|
$sub->token = $at->tok;
|
|
|
|
|
$sub->secret = $at->secret;
|
|
|
|
|
if (!$sub->update($orig_sub)) {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
} else {
|
|
|
|
|
common_debug('subscription updated to use access token', __FILE__);
|
|
|
|
|
return new OAuthToken($at->tok, $at->secret);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
} else {
|
2008-12-24 04:21:29 +09:00
|
|
|
|
return null;
|
2008-12-24 04:19:07 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
2008-07-10 07:46:30 +09:00
|
|
|
|
|
2008-12-24 04:49:23 +09:00
|
|
|
|
// defined in OAuthDataStore, but not implemented anywhere
|
2008-12-24 04:33:23 +09:00
|
|
|
|
function fetch_access_token($consumer)
|
|
|
|
|
{
|
2008-12-24 04:19:07 +09:00
|
|
|
|
return $this->new_access_token($consumer);
|
|
|
|
|
}
|
2009-08-10 21:48:50 +09:00
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Revoke specified OAuth token
|
|
|
|
|
*
|
|
|
|
|
* Revokes the authorization token specified by $token_key.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $token_key The token to be revoked
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function revoke_token($token_key) {
|
|
|
|
|
$rt = new Token();
|
|
|
|
|
$rt->tok = $token_key;
|
|
|
|
|
$rt->type = 0;
|
|
|
|
|
$rt->state = 0;
|
|
|
|
|
if (!$rt->find(true)) {
|
|
|
|
|
throw new Exception('Tried to revoke unknown token');
|
|
|
|
|
}
|
|
|
|
|
if (!$rt->delete()) {
|
|
|
|
|
throw new Exception('Failed to delete revoked token');
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Authorize specified OAuth token
|
|
|
|
|
*
|
|
|
|
|
* Authorizes the authorization token specified by $token_key.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $token_key The token to be authorized
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function authorize_token($token_key) {
|
|
|
|
|
$rt = new Token();
|
|
|
|
|
$rt->tok = $token_key;
|
|
|
|
|
$rt->type = 0;
|
|
|
|
|
$rt->state = 0;
|
|
|
|
|
if (!$rt->find(true)) {
|
|
|
|
|
throw new Exception('Tried to authorize unknown token');
|
|
|
|
|
}
|
|
|
|
|
$orig_rt = clone($rt);
|
|
|
|
|
$rt->state = 1; # Authorized but not used
|
|
|
|
|
if (!$rt->update($orig_rt)) {
|
|
|
|
|
throw new Exception('Failed to authorize token');
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Get profile by identifying URI
|
|
|
|
|
*
|
|
|
|
|
* Returns an OMB_Profile object representing the OMB profile identified by
|
|
|
|
|
* $identifier_uri.
|
|
|
|
|
* Returns null if there is no such OMB profile.
|
|
|
|
|
* Throws exceptions in case of other error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $identifier_uri The OMB identifier URI specifying the
|
|
|
|
|
* requested profile
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
*
|
|
|
|
|
* @return OMB_Profile The corresponding profile
|
|
|
|
|
**/
|
|
|
|
|
public function getProfile($identifier_uri) {
|
|
|
|
|
/* getProfile is only used for remote profiles by libomb.
|
2011-04-03 21:24:55 +09:00
|
|
|
|
@TODO: Make it work with local ones anyway. */
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$remote = Remote_profile::getKV('uri', $identifier_uri);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!$remote) throw new Exception('No such remote profile');
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$profile = Profile::getKV('id', $remote->id);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!$profile) throw new Exception('No profile for remote user');
|
|
|
|
|
|
2011-07-16 04:13:57 +09:00
|
|
|
|
require_once dirname(__FILE__) . '/omb.php';
|
2009-08-10 21:48:50 +09:00
|
|
|
|
return profile_to_omb_profile($identifier_uri, $profile);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Save passed profile
|
|
|
|
|
*
|
|
|
|
|
* Stores the OMB profile $profile. Overwrites an existing entry.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param OMB_Profile $profile The OMB profile which should be saved
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function saveProfile($omb_profile) {
|
|
|
|
|
if (common_profile_url($omb_profile->getNickname()) ==
|
|
|
|
|
$omb_profile->getProfileURL()) {
|
|
|
|
|
throw new Exception('Not implemented');
|
|
|
|
|
} else {
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$remote = Remote_profile::getKV('uri', $omb_profile->getIdentifierURI());
|
2009-08-10 21:48:50 +09:00
|
|
|
|
|
|
|
|
|
if ($remote) {
|
|
|
|
|
$exists = true;
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$profile = Profile::getKV($remote->id);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
$orig_remote = clone($remote);
|
|
|
|
|
$orig_profile = clone($profile);
|
2011-03-23 00:54:23 +09:00
|
|
|
|
// XXX: compare current postNotice and updateProfile URLs to the ones
|
|
|
|
|
// stored in the DB to avoid (possibly...) above attack
|
2009-08-10 21:48:50 +09:00
|
|
|
|
} else {
|
|
|
|
|
$exists = false;
|
|
|
|
|
$remote = new Remote_profile();
|
|
|
|
|
$remote->uri = $omb_profile->getIdentifierURI();
|
|
|
|
|
$profile = new Profile();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$profile->nickname = $omb_profile->getNickname();
|
|
|
|
|
$profile->profileurl = $omb_profile->getProfileURL();
|
|
|
|
|
|
|
|
|
|
$fullname = $omb_profile->getFullname();
|
|
|
|
|
$profile->fullname = is_null($fullname) ? '' : $fullname;
|
|
|
|
|
$homepage = $omb_profile->getHomepage();
|
|
|
|
|
$profile->homepage = is_null($homepage) ? '' : $homepage;
|
|
|
|
|
$bio = $omb_profile->getBio();
|
|
|
|
|
$profile->bio = is_null($bio) ? '' : $bio;
|
|
|
|
|
$location = $omb_profile->getLocation();
|
|
|
|
|
$profile->location = is_null($location) ? '' : $location;
|
|
|
|
|
|
|
|
|
|
if ($exists) {
|
|
|
|
|
$profile->update($orig_profile);
|
|
|
|
|
} else {
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$profile->created = common_sql_now(); # current time
|
2009-08-10 21:48:50 +09:00
|
|
|
|
$id = $profile->insert();
|
|
|
|
|
if (!$id) {
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Exception thrown when creating a new profile fails in OAuth store.
|
2010-09-13 01:24:44 +09:00
|
|
|
|
throw new Exception(_('Error inserting new profile.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
$remote->id = $id;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$avatar_url = $omb_profile->getAvatarURL();
|
|
|
|
|
if ($avatar_url) {
|
|
|
|
|
if (!$this->add_avatar($profile, $avatar_url)) {
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Exception thrown when creating a new avatar fails in OAuth store.
|
2010-09-13 01:24:44 +09:00
|
|
|
|
throw new Exception(_('Error inserting avatar.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
} else {
|
2013-10-01 05:13:37 +09:00
|
|
|
|
Avatar::deleteFromProfile($profile);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if ($exists) {
|
|
|
|
|
if (!$remote->update($orig_remote)) {
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Exception thrown when updating a remote profile fails in OAuth store.
|
2010-09-13 01:24:44 +09:00
|
|
|
|
throw new Exception(_('Error updating remote profile.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
} else {
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$remote->created = common_sql_now(); # current time
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!$remote->insert()) {
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Exception thrown when creating a remote profile fails in OAuth store.
|
2010-09-13 01:24:44 +09:00
|
|
|
|
throw new Exception(_('Error inserting remote profile.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function add_avatar($profile, $url)
|
|
|
|
|
{
|
|
|
|
|
$temp_filename = tempnam(sys_get_temp_dir(), 'listener_avatar');
|
2010-10-14 03:04:41 +09:00
|
|
|
|
try {
|
|
|
|
|
copy($url, $temp_filename);
|
|
|
|
|
$imagefile = new ImageFile($profile->id, $temp_filename);
|
|
|
|
|
$filename = Avatar::filename($profile->id,
|
|
|
|
|
image_type_to_extension($imagefile->type),
|
|
|
|
|
null,
|
|
|
|
|
common_timestamp());
|
|
|
|
|
rename($temp_filename, Avatar::path($filename));
|
|
|
|
|
} catch (Exception $e) {
|
|
|
|
|
unlink($temp_filename);
|
|
|
|
|
throw $e;
|
|
|
|
|
}
|
2009-08-10 21:48:50 +09:00
|
|
|
|
return $profile->setOriginal($filename);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Save passed notice
|
|
|
|
|
*
|
|
|
|
|
* Stores the OMB notice $notice. The datastore may change the passed notice.
|
|
|
|
|
* This might by neccessary for URIs depending on a database key. Note that
|
|
|
|
|
* it is the user’s duty to present a mechanism for his OMB_Datastore to
|
|
|
|
|
* appropriately change his OMB_Notice.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param OMB_Notice $notice The OMB notice which should be saved
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function saveNotice(&$omb_notice) {
|
2013-08-18 20:04:58 +09:00
|
|
|
|
if (Notice::getKV('uri', $omb_notice->getIdentifierURI())) {
|
2010-09-13 01:24:44 +09:00
|
|
|
|
// TRANS: Exception thrown when a notice is denied because it has been sent before.
|
|
|
|
|
throw new Exception(_('Duplicate notice.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
$author_uri = $omb_notice->getAuthor()->getIdentifierURI();
|
|
|
|
|
common_log(LOG_DEBUG, $author_uri, __FILE__);
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$author = Remote_profile::getKV('uri', $author_uri);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!$author) {
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$author = User::getKV('uri', $author_uri);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
if (!$author) {
|
2009-11-09 07:10:44 +09:00
|
|
|
|
throw new Exception('No such user.');
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
common_log(LOG_DEBUG, print_r($author, true), __FILE__);
|
|
|
|
|
|
|
|
|
|
$notice = Notice::saveNew($author->id,
|
|
|
|
|
$omb_notice->getContent(),
|
|
|
|
|
'omb',
|
2011-07-16 04:13:57 +09:00
|
|
|
|
array('is_local' => Notice::REMOTE,
|
2009-12-12 01:29:51 +09:00
|
|
|
|
'uri' => $omb_notice->getIdentifierURI()));
|
2009-09-30 06:25:52 +09:00
|
|
|
|
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Get subscriptions of a given profile
|
|
|
|
|
*
|
|
|
|
|
* Returns an array containing subscription informations for the specified
|
|
|
|
|
* profile. Every array entry should in turn be an array with keys
|
|
|
|
|
* 'uri´: The identifier URI of the subscriber
|
|
|
|
|
* 'token´: The subscribe token
|
|
|
|
|
* 'secret´: The secret token
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $subscribed_user_uri The OMB identifier URI specifying the
|
|
|
|
|
* subscribed profile
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
*
|
|
|
|
|
* @return mixed An array containing the subscriptions or 0 if no
|
|
|
|
|
* subscription has been found.
|
|
|
|
|
**/
|
|
|
|
|
public function getSubscriptions($subscribed_user_uri) {
|
|
|
|
|
$sub = new Subscription();
|
|
|
|
|
|
|
|
|
|
$user = $this->_getAnyProfile($subscribed_user_uri);
|
|
|
|
|
|
|
|
|
|
$sub->subscribed = $user->id;
|
|
|
|
|
|
|
|
|
|
if (!$sub->find(true)) {
|
2010-03-02 04:17:25 +09:00
|
|
|
|
return array();
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Since we do not use OMB_Service_Provider’s action methods, there
|
|
|
|
|
is no need to actually return the subscriptions. */
|
|
|
|
|
return 1;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private function _getAnyProfile($uri)
|
|
|
|
|
{
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$user = Remote_profile::getKV('uri', $uri);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
if (!$user) {
|
2013-08-18 20:04:58 +09:00
|
|
|
|
$user = User::getKV('uri', $uri);
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
if (!$user) {
|
2009-11-09 07:10:44 +09:00
|
|
|
|
throw new Exception('No such user.');
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
return $user;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Delete a subscription
|
|
|
|
|
*
|
|
|
|
|
* Deletes the subscription from $subscriber_uri to $subscribed_user_uri.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $subscriber_uri The OMB identifier URI specifying the
|
|
|
|
|
* subscribing profile
|
|
|
|
|
*
|
|
|
|
|
* @param string $subscribed_user_uri The OMB identifier URI specifying the
|
|
|
|
|
* subscribed profile
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function deleteSubscription($subscriber_uri, $subscribed_user_uri)
|
|
|
|
|
{
|
|
|
|
|
$sub = new Subscription();
|
|
|
|
|
|
|
|
|
|
$subscribed = $this->_getAnyProfile($subscribed_user_uri);
|
|
|
|
|
$subscriber = $this->_getAnyProfile($subscriber_uri);
|
|
|
|
|
|
|
|
|
|
$sub->subscribed = $subscribed->id;
|
|
|
|
|
$sub->subscriber = $subscriber->id;
|
|
|
|
|
|
|
|
|
|
$sub->delete();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Save a subscription
|
|
|
|
|
*
|
|
|
|
|
* Saves the subscription from $subscriber_uri to $subscribed_user_uri.
|
|
|
|
|
* Throws exceptions in case of error.
|
|
|
|
|
*
|
|
|
|
|
* @param string $subscriber_uri The OMB identifier URI specifying
|
|
|
|
|
* the subscribing profile
|
|
|
|
|
*
|
|
|
|
|
* @param string $subscribed_user_uri The OMB identifier URI specifying
|
|
|
|
|
* the subscribed profile
|
|
|
|
|
* @param OAuthToken $token The access token
|
|
|
|
|
*
|
|
|
|
|
* @access public
|
|
|
|
|
**/
|
|
|
|
|
public function saveSubscription($subscriber_uri, $subscribed_user_uri,
|
|
|
|
|
$token)
|
|
|
|
|
{
|
|
|
|
|
$sub = new Subscription();
|
|
|
|
|
|
|
|
|
|
$subscribed = $this->_getAnyProfile($subscribed_user_uri);
|
|
|
|
|
$subscriber = $this->_getAnyProfile($subscriber_uri);
|
|
|
|
|
|
2009-11-17 04:12:35 +09:00
|
|
|
|
if (!$subscriber->hasRight(Right::SUBSCRIBE)) {
|
2009-11-26 07:10:55 +09:00
|
|
|
|
common_log(LOG_INFO, __METHOD__ . ": remote subscriber banned ($subscriber_uri subbing to $subscribed_user_uri)");
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Error message displayed to a banned user when they try to subscribe.
|
2009-11-17 04:12:35 +09:00
|
|
|
|
return _('You have been banned from subscribing.');
|
|
|
|
|
}
|
|
|
|
|
|
2009-08-10 21:48:50 +09:00
|
|
|
|
$sub->subscribed = $subscribed->id;
|
|
|
|
|
$sub->subscriber = $subscriber->id;
|
|
|
|
|
|
|
|
|
|
$sub_exists = $sub->find(true);
|
|
|
|
|
|
|
|
|
|
if ($sub_exists) {
|
|
|
|
|
$orig_sub = clone($sub);
|
|
|
|
|
} else {
|
2013-10-14 20:42:27 +09:00
|
|
|
|
$sub->created = common_sql_now();
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$sub->token = $token->key;
|
|
|
|
|
$sub->secret = $token->secret;
|
|
|
|
|
|
|
|
|
|
if ($sub_exists) {
|
|
|
|
|
$result = $sub->update($orig_sub);
|
|
|
|
|
} else {
|
|
|
|
|
$result = $sub->insert();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!$result) {
|
|
|
|
|
common_log_db_error($sub, ($sub_exists) ? 'UPDATE' : 'INSERT', __FILE__);
|
2011-04-03 21:24:55 +09:00
|
|
|
|
// TRANS: Exception thrown when creating a new subscription fails in OAuth store.
|
|
|
|
|
throw new Exception(_('Could not insert new subscription.'));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Notify user, if necessary. */
|
|
|
|
|
|
|
|
|
|
if ($subscribed instanceof User) {
|
|
|
|
|
mail_subscribe_notify_profile($subscribed,
|
2013-08-18 20:04:58 +09:00
|
|
|
|
Profile::getKV($subscriber->id));
|
2009-08-10 21:48:50 +09:00
|
|
|
|
}
|
|
|
|
|
}
|
2008-05-28 05:07:21 +09:00
|
|
|
|
}
|