plugins/Favorite/FavoritePlugin.php

   1 <?php
   2 /*
   3  * GNU Social - a federating social network
   4  * Copyright (C) 2014, Free Software Foundation, 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('GNUSOCIAL')) { exit(1); }
  21
  22 /**
  23  * @package     Activity
  24  * @maintainer  Mikael Nordfeldth <mmn@hethane.se>
  25  */
  26 class FavoritePlugin extends ActivityHandlerPlugin
  27 {
  28     protected $notify_email_fave = 1;
  29
  30     public function tag()
  31     {
  32         return 'favorite';
  33     }
  34
  35     public function types()
  36     {
  37         return array();
  38     }
  39
  40     public function verbs()
  41     {
  42         return array(ActivityVerb::FAVORITE);
  43     }
  44
  45     public function onCheckSchema()
  46     {
  47         $schema = Schema::get();
  48         $schema->ensureTable('fave', Fave::schemaDef());
  49         return true;
  50     }
  51
  52     public function onStartUpgrade()
  53     {
  54         // This is a migration feature that will make sure we move
  55         // certain User preferences to the Profile_prefs table.
  56         // Introduced after commit b5fd2a048fc621ea05d756caba17275ab3dd0af4
  57         // on Sun Jul 13 16:30:37 2014 +0200
  58         $user = new User();
  59         $user->whereAdd('emailnotifyfav IS NOT NULL');
  60         if ($user->find()) {
  61             printfnq("Detected old User table (emailnotifyfav IS NOT NULL). Moving 'emailnotifyfav' property to Profile_prefs...");
  62             // Make sure we have our own tables setup properly
  63             while ($user->fetch()) {
  64                 $user->setPref('email', 'notify_fave', $user->emailnotifyfav);
  65                 $orig = clone($user);
  66                 $user->emailnotifyfav = 'null';   // flag this preference as migrated
  67                 $user->update($orig);
  68             }
  69             printfnq("DONE.\n");
  70         }
  71     }
  72
  73     public function onEndUpgrade()
  74     {
  75         printfnq("Ensuring all faves have a URI...");
  76
  77         $fave = new Fave();
  78         $fave->whereAdd('uri IS NULL');
  79
  80         if ($fave->find()) {
  81             while ($fave->fetch()) {
  82                 try {
  83                     $fave->decache();
  84                     $fave->query(sprintf('UPDATE fave '.
  85                                          'SET uri = "%s", '.
  86                                          '    modified = "%s" '.
  87                                          'WHERE user_id = %d '.
  88                                          'AND notice_id = %d',
  89                                          Fave::newUri($fave->user_id, $fave->notice_id, $fave->modified),
  90                                          common_sql_date(strtotime($fave->modified)),
  91                                          $fave->user_id,
  92                                          $fave->notice_id));
  93                 } catch (Exception $e) {
  94                     common_log(LOG_ERR, "Error updating fave URI: " . $e->getMessage());
  95                 }
  96             }
  97         }
  98
  99         printfnq("DONE.\n");
 100     }
 101
 102     public function onRouterInitialized(URLMapper $m)
 103     {
 104         // Web UI actions
 105         $m->connect('main/favor', array('action' => 'favor'));
 106         $m->connect('main/disfavor', array('action' => 'disfavor'));
 107
 108         if (common_config('singleuser', 'enabled')) {
 109             $nickname = User::singleUserNickname();
 110
 111             $m->connect('favorites',
 112                         array('action' => 'showfavorites',
 113                               'nickname' => $nickname));
 114             $m->connect('favoritesrss',
 115                         array('action' => 'favoritesrss',
 116                               'nickname' => $nickname));
 117         } else {
 118             $m->connect('favoritedrss', array('action' => 'favoritedrss'));
 119             $m->connect('favorited/', array('action' => 'favorited'));
 120             $m->connect('favorited', array('action' => 'favorited'));
 121
 122             $m->connect(':nickname/favorites',
 123                         array('action' => 'showfavorites'),
 124                         array('nickname' => Nickname::DISPLAY_FMT));
 125             $m->connect(':nickname/favorites/rss',
 126                         array('action' => 'favoritesrss'),
 127                         array('nickname' => Nickname::DISPLAY_FMT));
 128         }
 129
 130         // Favorites for API
 131         $m->connect('api/favorites/create.:format',
 132                     array('action' => 'ApiFavoriteCreate',
 133                           'format' => '(xml|json)'));
 134         $m->connect('api/favorites/destroy.:format',
 135                     array('action' => 'ApiFavoriteDestroy',
 136                           'format' => '(xml|json)'));
 137         $m->connect('api/favorites/list.:format',
 138                     array('action' => 'ApiTimelineFavorites',
 139                           'format' => '(xml|json|rss|atom|as)'));
 140         $m->connect('api/favorites/:id.:format',
 141                     array('action' => 'ApiTimelineFavorites',
 142                           'id' => Nickname::INPUT_FMT,
 143                           'format' => '(xml|json|rss|atom|as)'));
 144         $m->connect('api/favorites.:format',
 145                     array('action' => 'ApiTimelineFavorites',
 146                           'format' => '(xml|json|rss|atom|as)'));
 147         $m->connect('api/favorites/create/:id.:format',
 148                     array('action' => 'ApiFavoriteCreate',
 149                           'id' => '[0-9]+',
 150                           'format' => '(xml|json)'));
 151         $m->connect('api/favorites/destroy/:id.:format',
 152                     array('action' => 'ApiFavoriteDestroy',
 153                           'id' => '[0-9]+',
 154                           'format' => '(xml|json)'));
 155
 156         // AtomPub API
 157         $m->connect('api/statusnet/app/favorites/:profile/:notice.atom',
 158                     array('action' => 'AtomPubShowFavorite'),
 159                     array('profile' => '[0-9]+',
 160                           'notice' => '[0-9]+'));
 161
 162         $m->connect('api/statusnet/app/favorites/:profile.atom',
 163                     array('action' => 'AtomPubFavoriteFeed'),
 164                     array('profile' => '[0-9]+'));
 165
 166         // Required for qvitter API
 167         $m->connect('api/statuses/favs/:id.:format',
 168                     array('action' => 'ApiStatusesFavs',
 169                           'id' => '[0-9]+',
 170                           'format' => '(xml|json)'));
 171     }
 172
 173     // FIXME: Set this to abstract public in lib/activityhandlerplugin.php ddwhen all plugins have migrated!
 174     protected function saveObjectFromActivity(Activity $act, Notice $stored, array $options=array())
 175     {
 176         assert($this->isMyActivity($act));
 177
 178         // If empty, we should've created it ourselves on our node.
 179         if (!isset($options['created'])) {
 180             $options['created'] = !empty($act->time) ? common_sql_date($act->time) : common_sql_now();
 181         }
 182         if (!isset($options['uri'])) {
 183             $options['uri'] = !empty($act->id) ? $act->id : $act->selfLink;
 184         }
 185
 186         // We must have an objects[0] here because in isMyActivity we require the count to be == 1
 187         $actobj = $act->objects[0];
 188
 189         try {
 190             $object = Fave::saveActivityObject($actobj, $stored);
 191         } catch (ServerException $e) {
 192             // Probably that the favored notice doesn't exist in our local database
 193             // but may also be some missing profile or so, which we could catch in a
 194             // more explicit catch-statement.
 195             return null;
 196         }
 197         return $object;
 198     }
 199
 200
 201     public function activityObjectFromNotice(Notice $notice)
 202     {
 203         $fave = Fave::fromStored($notice);
 204         return $fave->asActivityObject();
 205     }
 206
 207     public function deleteRelated(Notice $notice)
 208     {
 209         try {
 210             $fave = Fave::fromStored($notice);
 211             $fave->delete();
 212         } catch (NoResultException $e) {
 213             // Cool, no problem. We wanted to get rid of it anyway.
 214         }
 215     }
 216
 217     protected function notifyMentioned(Notice $stored, array &$mentioned_ids)
 218     {
 219         require_once INSTALLDIR.'/lib/mail.php';
 220
 221         foreach ($mentioned_ids as $id) {
 222             $mentioned = User::getKV('id', $id);
 223             if ($mentioned instanceof User && $mentioned->id != $stored->profile_id
 224                     && $mentioned->email && $mentioned->getPref('email', 'notify_fave', $this->notify_email_fave)) {   // do we have an email, and does user want it?
 225                 mail_notify_fave($mentioned, $stored->getProfile(), $stored->getParent());
 226             }
 227         }
 228     }
 229
 230     // API stuff
 231
 232     /**
 233      * Typically just used to fill out Twitter-compatible API status data.
 234      *
 235      * FIXME: Make all the calls before this end up with a Notice instead of ArrayWrapper please...
 236      */
 237     public function onNoticeSimpleStatusArray($notice, array &$status, Profile $scoped=null, array $args=array())
 238     {
 239         if ($scoped instanceof Profile) {
 240             $status['favorited'] = Fave::existsForProfile($notice, $scoped);
 241         } else {
 242             $status['favorited'] = false;
 243         }
 244         return true;
 245     }
 246
 247     public function onTwitterUserArray(Profile $profile, array &$userdata, Profile $scoped=null, array $args=array())
 248     {
 249         $userdata['favourites_count'] = Fave::countByProfile($profile);
 250     }
 251
 252     /**
 253      * Typically just used to fill out StatusNet specific data in API calls in the referenced $info array.
 254      */
 255     public function onStatusNetApiNoticeInfo(Notice $notice, array &$info, Profile $scoped=null, array $args=array())
 256     {
 257         if ($scoped instanceof Profile) {
 258             $info['favorite'] = Fave::existsForProfile($notice, $scoped) ? 'true' : 'false';
 259         }
 260         return true;
 261     }
 262
 263     public function onNoticeDeleteRelated(Notice $notice)
 264     {
 265         parent::onNoticeDeleteRelated($notice);
 266
 267         // The below algorithm is because we want to delete fave
 268         // activities on any notice which _has_ faves, and not as
 269         // in the parent function only ones that _are_ faves.
 270
 271         $fave = new Fave();
 272         $fave->notice_id = $notice->id;
 273
 274         if ($fave->find()) {
 275             while ($fave->fetch()) {
 276                 $fave->delete();
 277             }
 278         }
 279
 280         $fave->free();
 281     }
 282
 283     public function onUserDeleteRelated(User $user, array &$related)
 284     {
 285         $fave = new Fave();
 286         $fave->user_id = $user->id;
 287         $fave->delete();    // Will perform a DELETE matching "user_id = {$user->id}"
 288
 289         Fave::blowCacheForProfileId($user->id);
 290         return true;
 291     }
 292
 293     public function onStartNoticeListPrefill(array &$notices, array $notice_ids, Profile $scoped=null)
 294     {
 295         // prefill array of objects, before pluginfication it was Notice::fillFaves($notices)
 296         Fave::fillFaves($notice_ids);
 297
 298         // DB caching
 299         if ($scoped instanceof Profile) {
 300             Fave::pivotGet('notice_id', $notice_ids, array('user_id' => $scoped->id));
 301         }
 302     }
 303
 304     /**
 305      * show the "favorite" form in the notice options element
 306      * FIXME: Don't let a NoticeListItemAdapter slip in here (or extend that from NoticeListItem)
 307      *
 308      * @return void
 309      */
 310     public function onStartShowNoticeOptionItems($nli)
 311     {
 312         if (Event::handle('StartShowFaveForm', array($nli))) {
 313             $scoped = Profile::current();
 314             if ($scoped instanceof Profile) {
 315                 if (Fave::existsForProfile($nli->notice, $scoped)) {
 316                     $disfavor = new DisfavorForm($nli->out, $nli->notice);
 317                     $disfavor->show();
 318                 } else {
 319                     $favor = new FavorForm($nli->out, $nli->notice);
 320                     $favor->show();
 321                 }
 322             }
 323             Event::handle('EndShowFaveForm', array($nli));
 324         }
 325     }
 326
 327     public function showNoticeListItem(NoticeListItem $nli)
 328     {
 329         // pass
 330     }
 331     public function openNoticeListItemElement(NoticeListItem $nli)
 332     {
 333         // pass
 334     }
 335     public function closeNoticeListItemElement(NoticeListItem $nli)
 336     {
 337         // pass
 338     }
 339
 340     public function onAppendUserActivityStreamObjects(UserActivityStream $uas, array &$objs)
 341     {
 342         $faves = array();
 343         $fave = new Fave();
 344         $fave->user_id = $uas->user->id;
 345
 346         if (!empty($uas->after)) {
 347             $fave->whereAdd("modified > '" . common_sql_date($uas->after) . "'");
 348         }
 349
 350         if ($fave->find()) {
 351             while ($fave->fetch()) {
 352                 $faves[] = clone($fave);
 353             }
 354         }
 355
 356         return $faves;
 357     }
 358
 359     public function onStartShowThreadedNoticeTailItems(NoticeListItem $nli, Notice $notice, &$threadActive)
 360     {
 361         if ($nli instanceof ThreadedNoticeListSubItem) {
 362             // The sub-items are replies to a conversation, thus we use different HTML elements etc.
 363             $item = new ThreadedNoticeListInlineFavesItem($notice, $nli->out);
 364         } else {
 365             $item = new ThreadedNoticeListFavesItem($notice, $nli->out);
 366         }
 367         $threadActive = $item->show() || $threadActive;
 368         return true;
 369     }
 370
 371     /**
 372      * EndInterpretCommand for FavoritePlugin will handle the 'fav' command
 373      * using the class FavCommand.
 374      *
 375      * @param string  $cmd     Command being run
 376      * @param string  $arg     Rest of the message (including address)
 377      * @param User    $user    User sending the message
 378      * @param Command &$result The resulting command object to be run.
 379      *
 380      * @return boolean hook value
 381      */
 382     public function onStartInterpretCommand($cmd, $arg, $user, &$result)
 383     {
 384         if ($result === false && $cmd == 'fav') {
 385             if (empty($arg)) {
 386                 $result = null;
 387             } else {
 388                 list($other, $extra) = $this->split_arg($arg);
 389                 if (!empty($extra)) {
 390                     $result = null;
 391                 } else {
 392                     $result = new FavCommand($user, $other);
 393                 }
 394             }
 395             return false;
 396         }
 397         return true;
 398     }
 399
 400     public function onHelpCommandMessages(HelpCommand $help, array &$commands)
 401     {
 402         // TRANS: Help message for IM/SMS command "fav <nickname>".
 403         $commands['fav <nickname>'] = _m('COMMANDHELP', "add user's last notice as a 'fave'");
 404         // TRANS: Help message for IM/SMS command "fav #<notice_id>".
 405         $commands['fav #<notice_id>'] = _m('COMMANDHELP', "add notice with the given id as a 'fave'");
 406     }
 407
 408     /**
 409      * Are we allowed to perform a certain command over the API?
 410      */
 411     public function onCommandSupportedAPI(Command $cmd, array &$supported)
 412     {
 413         $supported = $supported || $cmd instanceof FavCommand;
 414     }
 415
 416     // Form stuff (settings etc.)
 417
 418     public function onEndEmailFormData(Action $action, Profile $scoped)
 419     {
 420         // getConfigData will fall back on systemwide default
 421         // and we only wish to save numerical true or false.
 422         $emailfave = $scoped->getPref('email', 'notify_fave', $this->notify_email_fave) ? 1 : 0;
 423
 424         $action->elementStart('li');
 425         $action->checkbox('email-notify_fave',
 426                         // TRANS: Checkbox label in e-mail preferences form.
 427                         _('Send me email when someone adds my notice as a favorite.'),
 428                         $emailfave);
 429         $action->elementEnd('li');
 430
 431         return true;
 432     }
 433
 434     public function onStartEmailSaveForm(Action $action, Profile $scoped)
 435     {
 436         $emailfave = $action->boolean('email-notify_fave') ? 1 : 0;
 437         try {
 438             if ($emailfave == $scoped->getPref('email', 'notify_fave')) {
 439                 // No need to update setting
 440                 return true;
 441             }
 442         } catch (NoResultException $e) {
 443             // Apparently there's no previously stored setting, then continue to save it as it is now.
 444         }
 445
 446         $scoped->setPref('email', 'notify_fave', $emailfave);
 447
 448         return true;
 449     }
 450
 451     // Layout stuff
 452
 453     public function onEndPersonalGroupNav(Menu $menu, Profile $target, Profile $scoped=null)
 454     {
 455         $menu->out->menuItem(common_local_url('showfavorites', array('nickname' => $target->getNickname())),
 456                              // TRANS: Menu item in personal group navigation menu.
 457                              _m('MENU','Favorites'),
 458                              // @todo i18n FIXME: Need to make this two messages.
 459                              // TRANS: Menu item title in personal group navigation menu.
 460                              // TRANS: %s is a username.
 461                              sprintf(_('%s\'s favorite notices'), $target->getBestName()),
 462                              $scoped instanceof Profile && $target->id === $scoped->id && $menu->actionName =='showfavorites',
 463                             'nav_timeline_favorites');
 464     }
 465
 466     public function onEndPublicGroupNav(Menu $menu)
 467     {
 468         if (!common_config('singleuser', 'enabled')) {
 469             // TRANS: Menu item in search group navigation panel.
 470             $menu->out->menuItem(common_local_url('favorited'), _m('MENU','Popular'),
 471                                  // TRANS: Menu item title in search group navigation panel.
 472                                  _('Popular notices'), $menu->actionName == 'favorited', 'nav_timeline_favorited');
 473         }
 474     }
 475
 476     public function onEndShowSections(Action $action)
 477     {
 478         if (!$action->isAction(array('all', 'public'))) {
 479             return true;
 480         }
 481
 482         if (!common_config('performance', 'high')) {
 483             $section = new PopularNoticeSection($action, $action->getScoped());
 484             $section->show();
 485         }
 486     }
 487
 488     public function onPluginVersion(array &$versions)
 489     {
 490         $versions[] = array('name' => 'Favorite',
 491                             'version' => GNUSOCIAL_VERSION,
 492                             'author' => 'Mikael Nordfeldth',
 493                             'homepage' => 'http://gnu.io/',
 494                             'rawdescription' =>
 495                             // TRANS: Plugin description.
 496                             _m('Favorites (likes) using ActivityStreams.'));
 497
 498         return true;
 499     }
 500 }