lib/subs.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 /* Subscribe user $user to other user $other.
  23  * Note: $other must be a local user, not a remote profile.
  24  * Because the other way is quite a bit more complicated.
  25  */
  26
  27 function subs_subscribe_to($user, $other)
  28 {
  29     try {
  30         Subscription::start($user->getProfile(), $other);
  31         return true;
  32     } catch (Exception $e) {
  33         return $e->getMessage();
  34     }
  35 }
  36
  37 function subs_unsubscribe_to($user, $other)
  38 {
  39     try {
  40         Subscription::cancel($user->getProfile(), $other);
  41         return true;
  42     } catch (Exception $e) {
  43         return $e->getMessage();
  44     }
  45 }
  46
  47 function subs_unsubscribe_from($user, $other){
  48    $local = User::staticGet("nickname",$other);
  49    if($local){
  50      return subs_unsubscribe_to($local,$user);
  51    } else {
  52     try {
  53         $remote = Profile::staticGet("nickname",$other);
  54         if(is_string($remote)){
  55           return $remote;
  56         }
  57         if (Event::handle('StartUnsubscribe', array($remote,$user))) {
  58
  59             $sub = DB_DataObject::factory('subscription');
  60
  61             $sub->subscriber = $remote->id;
  62             $sub->subscribed = $user->id;
  63
  64             $sub->find(true);
  65
  66             // note we checked for existence above
  67
  68             if (!$sub->delete())
  69               return _('Couldn\'t delete subscription.');
  70
  71             $cache = common_memcache();
  72
  73             if ($cache) {
  74                 $cache->delete(common_cache_key('user:notices_with_friends:' . $remote->id));
  75             }
  76
  77
  78             $user->blowSubscribersCount();
  79             $remote->blowSubscribersCount();
  80
  81             Event::handle('EndUnsubscribe', array($remote, $user));
  82         }
  83     } catch (Exception $e) {
  84         return $e->getMessage();
  85     }
  86    }
  87 }
  88