3 * StatusNet - the distributed open-source microblogging tool
4 * Copyright (C) 2010, StatusNet, Inc.
10 * This program is free software: you can redistribute it and/or modify
11 * it under the terms of the GNU Affero General Public License as published by
12 * the Free Software Foundation, either version 3 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU Affero General Public License for more details.
20 * You should have received a copy of the GNU Affero General Public License
21 * along with this program. If not, see <http://www.gnu.org/licenses/>.
25 * @author Evan Prodromou <evan@status.net>
26 * @copyright 2010 StatusNet, Inc.
27 * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
28 * @link http://status.net/
31 if (!defined('STATUSNET')) {
32 // This check helps protect against security problems;
33 // your code file can't be executed directly from the web.
42 * @author Evan Prodromou <evan@status.net>
43 * @copyright 2010 StatusNet, Inc.
44 * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0
45 * @link http://status.net/
47 class ActivityMover extends QueueHandler
54 function handle($data)
56 list ($act, $sink, $userURI, $remoteURI) = $data;
58 $user = User::getKV('uri', $userURI);
60 $remote = Profile::fromUri($remoteURI);
61 } catch (UnknownUriException $e) {
62 // Don't retry. It's hard to tell whether it's because of
63 // lookup failures or because the URI is permanently gone.
64 // If we knew it was temporary, we'd return false here.
69 $this->moveActivity($act, $sink, $user, $remote);
70 } catch (ClientException $cex) {
71 $this->log(LOG_WARNING,
75 } catch (ServerException $sex) {
76 $this->log(LOG_WARNING,
78 // "retry me" (because we think the server might handle it next time)
80 } catch (Exception $ex) {
81 $this->log(LOG_WARNING,
88 function moveActivity($act, $sink, $user, $remote)
91 // TRANS: Exception thrown if a non-existing user is provided. %s is a user ID.
92 throw new Exception(sprintf(_('No such user "%s".'),$act->actor->id));
96 /* case ActivityVerb::FAVORITE:
98 "Moving favorite of {$act->objects[0]->id} by ".
99 "{$act->actor->id} to {$remote->nickname}.");
100 // push it, then delete local
101 $sink->postActivity($act);
102 $notice = Notice::getKV('uri', $act->objects[0]->id);
103 if (!empty($notice)) {
104 $fave = Fave::pkeyGet(array('user_id' => $user->id,
105 'notice_id' => $notice->id));
109 case ActivityVerb::POST:
111 "Moving notice {$act->objects[0]->id} by ".
112 "{$act->actor->id} to {$remote->nickname}.");
113 // XXX: send a reshare, not a post
114 $sink->postActivity($act);
115 $notice = Notice::getKV('uri', $act->objects[0]->id);
116 if (!empty($notice)) {
120 case ActivityVerb::JOIN:
122 "Moving group join of {$act->objects[0]->id} by ".
123 "{$act->actor->id} to {$remote->nickname}.");
124 $sink->postActivity($act);
125 $group = User_group::getKV('uri', $act->objects[0]->id);
126 if (!empty($group)) {
127 $user->leaveGroup($group);
130 case ActivityVerb::FOLLOW:
131 if ($act->actor->id === $user->getUri()) {
133 "Moving subscription to {$act->objects[0]->id} by ".
134 "{$act->actor->id} to {$remote->nickname}.");
135 $sink->postActivity($act);
137 $other = Profile::fromUri($act->objects[0]->id);
138 Subscription::cancel($user->getProfile(), $other);
139 } catch (UnknownUriException $e) {
140 // Can't cancel subscription if we don't know who to alert
143 $otherUser = User::getKV('uri', $act->actor->id);
144 if (!empty($otherUser)) {
146 "Changing sub to {$act->objects[0]->id}".
147 "by {$act->actor->id} to {$remote->nickname}.");
148 $otherProfile = $otherUser->getProfile();
149 Subscription::start($otherProfile, $remote);
150 Subscription::cancel($otherProfile, $user->getProfile());
152 $this->log(LOG_NOTICE,
153 "Not changing sub to {$act->objects[0]->id}".
154 "by remote {$act->actor->id} ".
155 "to {$remote->nickname}.");
165 * Add a header for our class so we know who did it.
167 * @param int $level Log level, like LOG_ERR or LOG_INFO
168 * @param string $message Message to log
172 protected function log($level, $message)
174 common_log($level, "ActivityMover: " . $message);