. */ if (!defined('LACONICA')) { exit(1); } require_once('XMPPHP/XMPP.php'); /* Subscribe $user to nickname $other_nickname Returns true or an error message. */ function subs_subscribe_user($user,$other_nickname) { $other = User::staticGet('nickname', $other_nickname); if (!$other) { return _('No such user.'); } if ($user->isSubscribed($other)) { return _('Already subscribed!.'); } if (!$user->subscribeTo($other)) { return _('Could not subscribe.'); return; } subs_notify($other, $user); if ($other->autosubscribe && !$other->isSubscribed($user)) { if (!$other->subscribeTo($user)) { return _('Could not subscribe other to you.'); } subs_notify($user, $other); } return true; } function subs_notify($listenee, $listener) { # XXX: add other notifications (Jabber, SMS) here # XXX: queue this and handle it offline # XXX: Whatever happens, do it in Twitter-like API, too subs_notify_email($listenee, $listener); } function subs_notify_email($listenee, $listener) { mail_subscribe_notify($listenee, $listener); } /* Unsubscribe $user from nickname $other_nickname Returns true or an error message. */ function subs_unsubscribe_user($user, $other_nickname) { $other = User::staticGet('nickname', $other_nickname); if (!$other) return _('No such user.'); if (!$user->isSubscribed($other)) return _('Not subscribed!.'); $sub = DB_DataObject::factory('subscription'); $sub->subscriber = $user->id; $sub->subscribed = $other->id; $sub->find(true); // note we checked for existence above if (!$sub->delete()) return _('Couldn\'t delete subscription.'); return true; }