12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610 |
- <?php
- if (!defined('GNUSOCIAL')) { exit(1); }
- class OStatusPlugin extends Plugin
- {
- const PLUGIN_VERSION = '2.0.1';
-
- public function onRouterInitialized(URLMapper $m)
- {
-
- $m->connect('main/ostatustag',
- array('action' => 'ostatustag'));
- $m->connect('main/ostatustag?nickname=:nickname',
- array('action' => 'ostatustag'), array('nickname' => '[A-Za-z0-9_-]+'));
- $m->connect('main/ostatus/nickname/:nickname',
- array('action' => 'ostatusinit'), array('nickname' => '[A-Za-z0-9_-]+'));
- $m->connect('main/ostatus/group/:group',
- array('action' => 'ostatusinit'), array('group' => '[A-Za-z0-9_-]+'));
- $m->connect('main/ostatus/peopletag/:peopletag/tagger/:tagger',
- array('action' => 'ostatusinit'), array('tagger' => '[A-Za-z0-9_-]+',
- 'peopletag' => '[A-Za-z0-9_-]+'));
- $m->connect('main/ostatus',
- array('action' => 'ostatusinit'));
-
- $m->connect('main/ostatussub',
- array('action' => 'ostatussub'));
- $m->connect('main/ostatusgroup',
- array('action' => 'ostatusgroup'));
- $m->connect('main/ostatuspeopletag',
- array('action' => 'ostatuspeopletag'));
-
- $m->connect('main/push/hub', array('action' => 'pushhub'));
- $m->connect('main/push/callback/:feed',
- array('action' => 'pushcallback'),
- array('feed' => '[0-9]+'));
-
- $m->connect('main/salmon/user/:id',
- array('action' => 'usersalmon'),
- array('id' => '[0-9]+'));
- $m->connect('main/salmon/group/:id',
- array('action' => 'groupsalmon'),
- array('id' => '[0-9]+'));
- $m->connect('main/salmon/peopletag/:id',
- array('action' => 'peopletagsalmon'),
- array('id' => '[0-9]+'));
- return true;
- }
-
- function onEndInitializeQueueManager(QueueManager $qm)
- {
-
- $qm->connect('ostatus', 'OStatusQueueHandler');
-
- $qm->connect('hubconf', 'HubConfQueueHandler');
- $qm->connect('hubprep', 'HubPrepQueueHandler');
- $qm->connect('hubout', 'HubOutQueueHandler');
-
- $qm->connect('salmon', 'SalmonQueueHandler');
-
- $qm->connect('pushin', 'PushInQueueHandler');
-
- $qm->connect('pushrenew', 'PushRenewQueueHandler');
- return true;
- }
-
- function onStartEnqueueNotice($notice, &$transports)
- {
- if ($notice->inScope(null) && $notice->getProfile()->hasRight(Right::PUBLICNOTICE)) {
-
- array_unshift($transports, 'ostatus');
- $this->log(LOG_INFO, "OSTATUS [{$notice->getID()}]: queued for OStatus processing");
- } else {
-
-
- $this->log(LOG_NOTICE, "OSTATUS [{$notice->getID()}]: Not queueing because of privacy; scope = {$notice->scope}");
- }
- return true;
- }
-
- function onStartApiAtom($feed)
- {
- $id = null;
- if ($feed instanceof AtomUserNoticeFeed) {
- $salmonAction = 'usersalmon';
- $user = $feed->getUser();
- $id = $user->id;
- $profile = $user->getProfile();
- } else if ($feed instanceof AtomGroupNoticeFeed) {
- $salmonAction = 'groupsalmon';
- $group = $feed->getGroup();
- $id = $group->id;
- } else if ($feed instanceof AtomListNoticeFeed) {
- $salmonAction = 'peopletagsalmon';
- $peopletag = $feed->getList();
- $id = $peopletag->id;
- } else {
- return true;
- }
- if (!empty($id)) {
- $hub = common_config('ostatus', 'hub');
- if (empty($hub)) {
-
- $hub = common_local_url('pushhub');
- }
- $feed->addLink($hub, array('rel' => 'hub'));
-
- $salmon = common_local_url($salmonAction, array('id' => $id));
- $feed->addLink($salmon, array('rel' => Salmon::REL_SALMON));
-
- $feed->addLink($salmon, array('rel' => Salmon::NS_REPLIES));
- $feed->addLink($salmon, array('rel' => Salmon::NS_MENTIONS));
- }
- return true;
- }
-
- function onStartProfileRemoteSubscribe($output, $profile)
- {
- $this->onStartProfileListItemActionElements($output, $profile);
- return false;
- }
- function onStartGroupSubscribe($widget, $group)
- {
- $cur = common_current_user();
- if (empty($cur)) {
- $widget->out->elementStart('li', 'entity_subscribe');
- $url = common_local_url('ostatusinit',
- array('group' => $group->nickname));
- $widget->out->element('a', array('href' => $url,
- 'class' => 'entity_remote_subscribe'),
-
- _m('Subscribe'));
- $widget->out->elementEnd('li');
- return false;
- }
- return true;
- }
- function onStartSubscribePeopletagForm($output, $peopletag)
- {
- $cur = common_current_user();
- if (empty($cur)) {
- $output->elementStart('li', 'entity_subscribe');
- $profile = $peopletag->getTagger();
- $url = common_local_url('ostatusinit',
- array('tagger' => $profile->nickname, 'peopletag' => $peopletag->tag));
- $output->element('a', array('href' => $url,
- 'class' => 'entity_remote_subscribe'),
-
- _m('Subscribe'));
- $output->elementEnd('li');
- return false;
- }
- return true;
- }
-
- function onStartProfileCompletionSearch($action, $profile, $search_engine) {
- if ($action->field == 'uri') {
- $profile->joinAdd(array('id', 'user:id'));
- $profile->whereAdd('uri LIKE "%' . $profile->escape($q) . '%"');
- $profile->query();
- $validate = new Validate();
- if ($profile->N == 0) {
- try {
- if ($validate->email($q)) {
- $oprofile = Ostatus_profile::ensureWebfinger($q);
- } else if ($validate->uri($q)) {
- $oprofile = Ostatus_profile::ensureProfileURL($q);
- } else {
-
- throw new Exception(_m('Invalid URI.'));
- }
- return $this->filter(array($oprofile->localProfile()));
- } catch (Exception $e) {
-
-
- $this->msg = _m("Sorry, we could not reach that address. Please make sure that the OStatus address is like nickname@example.com or http://example.net/nickname.");
- return array();
- }
- }
- return false;
- }
- return true;
- }
-
- static function extractWebfingerIds($text, $preMention='@')
- {
- $wmatches = array();
- $result = preg_match_all('/(?<!\S)'.preg_quote($preMention, '/').'('.Nickname::WEBFINGER_FMT.')/',
- $text,
- $wmatches,
- PREG_OFFSET_CAPTURE);
- if ($result === false) {
- common_log(LOG_ERR, __METHOD__ . ': Error parsing webfinger IDs from text (preg_last_error=='.preg_last_error().').');
- } elseif (count($wmatches)) {
- common_debug(sprintf('Found %d matches for WebFinger IDs: %s', count($wmatches), _ve($wmatches)));
- }
- return $wmatches[1];
- }
-
- static function extractUrlMentions($text, $preMention='@')
- {
- $wmatches = array();
-
-
- $result = preg_match_all('/(?:^|\s+)'.preg_quote($preMention, '/').'('.URL_REGEX_DOMAIN_NAME.'(?:\/['.URL_REGEX_VALID_PATH_CHARS.']*)*)/',
- $text,
- $wmatches,
- PREG_OFFSET_CAPTURE);
- if ($result === false) {
- common_log(LOG_ERR, __METHOD__ . ': Error parsing profile URL mentions from text (preg_last_error=='.preg_last_error().').');
- } elseif (count($wmatches)) {
- common_debug(sprintf('Found %d matches for profile URL mentions: %s', count($wmatches), _ve($wmatches)));
- }
- return $wmatches[1];
- }
-
- function onEndFindMentions(Profile $sender, $text, &$mentions)
- {
- $matches = array();
- foreach (self::extractWebfingerIds($text, '@') as $wmatch) {
- list($target, $pos) = $wmatch;
- $this->log(LOG_INFO, "Checking webfinger person '$target'");
- $profile = null;
- try {
- $oprofile = Ostatus_profile::ensureWebfinger($target);
- if (!$oprofile instanceof Ostatus_profile || !$oprofile->isPerson()) {
- continue;
- }
- $profile = $oprofile->localProfile();
- } catch (OStatusShadowException $e) {
-
- $profile = $e->profile;
- } catch (Exception $e) {
- $this->log(LOG_ERR, "Webfinger check failed: " . $e->getMessage());
- continue;
- }
- assert($profile instanceof Profile);
- $displayName = !empty($profile->nickname) && mb_strlen($profile->nickname) < mb_strlen($target)
- ? $profile->getNickname()
- : $target;
- $url = $profile->getUri();
- if (!common_valid_http_url($url)) {
- $url = $profile->getUrl();
- }
- $matches[$pos] = array('mentioned' => array($profile),
- 'type' => 'mention',
- 'text' => $displayName,
- 'position' => $pos,
- 'length' => mb_strlen($target),
- 'url' => $url);
- }
-
-
- foreach (self::extractWebfingerIds($text, '!') as $wmatch) {
- list($target, $pos) = $wmatch;
- list($target_nickname, $target_hostname) = explode('@', parse_url($target, PHP_URL_PATH));
- $this->log(LOG_INFO, sprintf('Checking webfinger group %s as user %s on server %s', $target, $target_nickname, $target_hostname));
- $profile = null;
- if ($target_hostname === mb_strtolower(common_config('site', 'server'))) {
- try {
- $profile = Local_group::getKV('nickname', $target_nickname)->getProfile();
- } catch (NoSuchGroupException $e) {
-
- $this->log(LOG_ERR, "Local group lookup failed: " . _ve($e->getMessage()));
- continue;
- }
- } else {
-
-
-
-
- $possible_groups = new User_group();
- $possible_groups->nickname = $target_nickname;
- if (!$possible_groups->find()) {
- common_debug('No groups at all found with nickname: '._ve($target_nickname));
- continue;
- }
- while ($possible_groups->fetch()) {
- if (!$sender->isMember($possible_groups)) {
- continue;
- }
- $group_hostname = mb_strtolower(parse_url($possible_groups->mainpage, PHP_URL_HOST));
- if ($target_hostname === $group_hostname) {
- common_debug(sprintf('Found group with nick@host (%s@%s) matching %s', _ve($possible_groups->nickname), _ve($group_hostname), _ve($target)));
- $profile = $possible_groups->getProfile();
- break;
- }
- }
- $possible_groups->free();
- if (!$profile instanceof Profile) {
- common_debug('Found groups with correct nickname but not hostname for: '._ve($target));
- continue;
- }
- }
- assert($profile instanceof Profile);
- $displayName = !empty($profile->nickname) && mb_strlen($profile->nickname) < mb_strlen($target)
- ? $profile->getNickname()
- : $target;
- $url = $profile->getUri();
- if (!common_valid_http_url($url)) {
- $url = $profile->getUrl();
- }
- $matches[$pos] = array('mentioned' => array($profile),
- 'type' => 'group',
- 'text' => $displayName,
- 'position' => $pos,
- 'length' => mb_strlen($target),
- 'url' => $url);
- }
- foreach (self::extractUrlMentions($text) as $wmatch) {
- list($target, $pos) = $wmatch;
- $schemes = array('https', 'http');
- foreach ($schemes as $scheme) {
- $url = "$scheme://$target";
- $this->log(LOG_INFO, "Checking profile address '$url'");
- try {
- $oprofile = Ostatus_profile::ensureProfileURL($url);
- if ($oprofile instanceof Ostatus_profile && !$oprofile->isGroup()) {
- $profile = $oprofile->localProfile();
- $displayName = !empty($profile->nickname) && mb_strlen($profile->nickname) < mb_strlen($target) ?
- $profile->nickname : $target;
- $matches[$pos] = array('mentioned' => array($profile),
- 'type' => 'mention',
- 'text' => $displayName,
- 'position' => $pos,
- 'length' => mb_strlen($target),
- 'url' => $profile->getUrl());
- break;
- }
- } catch (Exception $e) {
- $this->log(LOG_ERR, "Profile check failed: " . $e->getMessage());
- }
- }
- }
- foreach ($mentions as $i => $other) {
-
- $pos = $other['position'];
- if (isset($matches[$pos])) {
- $mentions[$i] = $matches[$pos];
- unset($matches[$pos]);
- }
- }
- foreach ($matches as $mention) {
- $mentions[] = $mention;
- }
- return true;
- }
-
- function onStartCommandGetProfile($command, $arg, &$profile)
- {
- $oprofile = $this->pullRemoteProfile($arg);
- if ($oprofile instanceof Ostatus_profile && !$oprofile->isGroup()) {
- try {
- $profile = $oprofile->localProfile();
- } catch (NoProfileException $e) {
-
- return true;
- }
- return false;
- } else {
- return true;
- }
- }
-
- function onStartCommandGetGroup($command, $arg, &$group)
- {
- $oprofile = $this->pullRemoteProfile($arg);
- if ($oprofile instanceof Ostatus_profile && $oprofile->isGroup()) {
- $group = $oprofile->localGroup();
- return false;
- } else {
- return true;
- }
- }
- protected function pullRemoteProfile($arg)
- {
- $oprofile = null;
- if (preg_match('!^((?:\w+\.)*\w+@(?:\w+\.)*\w+(?:\w+\-\w+)*\.\w+)$!', $arg)) {
-
- try {
- return Ostatus_profile::ensureWebfinger($arg);
- } catch (Exception $e) {
- common_log(LOG_ERR, 'Webfinger lookup failed for ' .
- $arg . ': ' . $e->getMessage());
- }
- }
-
- $urls = array();
- if (preg_match('!^https?://((?:\w+\.)*\w+(?:\w+\-\w+)*\.\w+(?:/\w+)+)$!', $arg)) {
- $urls[] = $arg;
- }
- if (preg_match('!^((?:\w+\.)*\w+(?:\w+\-\w+)*\.\w+(?:/\w+)+)$!', $arg)) {
- $schemes = array('http', 'https');
- foreach ($schemes as $scheme) {
- $urls[] = "$scheme://$arg";
- }
- }
- foreach ($urls as $url) {
- try {
- return Ostatus_profile::ensureProfileURL($url);
- } catch (Exception $e) {
- common_log(LOG_ERR, 'Profile lookup failed for ' .
- $arg . ': ' . $e->getMessage());
- }
- }
- return null;
- }
- function onEndProfileSettingsActions($out) {
- $siteName = common_config('site', 'name');
- $js = 'navigator.registerContentHandler("application/vnd.mozilla.maybe.feed", "'.addslashes(common_local_url('ostatussub', null, array('profile' => '%s'))).'", "'.addslashes($siteName).'")';
- $out->elementStart('li');
- $out->element('a',
- array('href' => 'javascript:'.$js),
-
- _('Add to Firefox as feedreader'));
- $out->elementEnd('li');
- }
-
- function onCheckSchema() {
- $schema = Schema::get();
- $schema->ensureTable('ostatus_profile', Ostatus_profile::schemaDef());
- $schema->ensureTable('feedsub', FeedSub::schemaDef());
- $schema->ensureTable('hubsub', HubSub::schemaDef());
- $schema->ensureTable('magicsig', Magicsig::schemaDef());
- return true;
- }
- public function onEndShowStylesheets(Action $action) {
- $action->cssLink($this->path('theme/base/css/ostatus.css'));
- return true;
- }
- function onEndShowStatusNetScripts($action) {
- $action->script($this->path('js/ostatus.js'));
- return true;
- }
-
- function onStartNoticeSourceLink($notice, &$name, &$url, &$title)
- {
-
- if (!in_array($notice->source, array('ostatus', 'share'))) {
- return true;
- }
- try {
- $url = $notice->getUrl();
-
-
- $bits = parse_url($url);
- $domain = $bits['host'];
- if (substr($domain, 0, 4) == 'www.') {
- $name = substr($domain, 4);
- } else {
- $name = $domain;
- }
-
- $title = sprintf(_m('Sent from %s via OStatus'), $domain);
-
- return false;
- } catch (InvalidUrlException $e) {
-
- return true;
- }
- }
-
- function onStartFeedSubReceive($feedsub, $feed)
- {
- $oprofile = Ostatus_profile::getKV('feeduri', $feedsub->uri);
- if ($oprofile instanceof Ostatus_profile) {
- $oprofile->processFeed($feed, 'push');
- } else {
- common_log(LOG_DEBUG, "No ostatus profile for incoming feed $feedsub->uri");
- }
- }
-
- function onFeedSubSubscriberCount($feedsub, &$count)
- {
- $oprofile = Ostatus_profile::getKV('feeduri', $feedsub->uri);
- if ($oprofile instanceof Ostatus_profile) {
- $count += $oprofile->subscriberCount();
- }
- return true;
- }
-
- function onStartSubscribe(Profile $profile, Profile $other)
- {
- if (!$profile->isLocal()) {
- return true;
- }
- $oprofile = Ostatus_profile::getKV('profile_id', $other->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $oprofile->subscribe();
- }
-
- function onEndSubscribe(Profile $profile, Profile $other)
- {
- if (!$profile->isLocal()) {
- return true;
- }
- $oprofile = Ostatus_profile::getKV('profile_id', $other->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $sub = Subscription::pkeyGet(array('subscriber' => $profile->id,
- 'subscribed' => $other->id));
- $act = $sub->asActivity();
- $oprofile->notifyActivity($act, $profile);
- return true;
- }
-
- function onEndUnsubscribe(Profile $profile, Profile $other)
- {
- if (!$profile->isLocal()) {
- return true;
- }
- $oprofile = Ostatus_profile::getKV('profile_id', $other->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
-
- $oprofile->garbageCollect();
- $act = new Activity();
- $act->verb = ActivityVerb::UNFOLLOW;
- $act->id = TagURI::mint('unfollow:%d:%d:%s',
- $profile->id,
- $other->id,
- common_date_iso8601(time()));
- $act->time = time();
-
- $act->title = _m('TITLE','Unfollow');
-
-
- $act->content = sprintf(_m('%1$s stopped following %2$s.'),
- $profile->getBestName(),
- $other->getBestName());
- $act->actor = $profile->asActivityObject();
- $act->objects[] = $other->asActivityObject();
- $oprofile->notifyActivity($act, $profile);
- return true;
- }
-
- function onStartJoinGroup($group, $profile)
- {
- $oprofile = Ostatus_profile::getKV('group_id', $group->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $oprofile->subscribe();
-
-
- $act = new Activity();
- $act->id = TagURI::mint('join:%d:%d:%s',
- $profile->id,
- $group->id,
- common_date_iso8601(time()));
- $act->actor = $profile->asActivityObject();
- $act->verb = ActivityVerb::JOIN;
- $act->objects[] = $oprofile->asActivityObject();
- $act->time = time();
-
- $act->title = _m('TITLE','Join');
-
-
- $act->content = sprintf(_m('%1$s has joined group %2$s.'),
- $profile->getBestName(),
- $oprofile->getBestName());
- if ($oprofile->notifyActivity($act, $profile)) {
- return true;
- } else {
- $oprofile->garbageCollect();
-
- throw new Exception(_m('Failed joining remote group.'));
- }
- }
-
- function onEndLeaveGroup($group, $profile)
- {
- $oprofile = Ostatus_profile::getKV('group_id', $group->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
-
- $oprofile->garbageCollect();
- $member = $profile;
- $act = new Activity();
- $act->id = TagURI::mint('leave:%d:%d:%s',
- $member->id,
- $group->id,
- common_date_iso8601(time()));
- $act->actor = $member->asActivityObject();
- $act->verb = ActivityVerb::LEAVE;
- $act->objects[] = $oprofile->asActivityObject();
- $act->time = time();
-
- $act->title = _m('TITLE','Leave');
-
-
- $act->content = sprintf(_m('%1$s has left group %2$s.'),
- $member->getBestName(),
- $oprofile->getBestName());
- $oprofile->notifyActivity($act, $member);
- }
-
- function onStartSubscribePeopletag($peopletag, $user)
- {
- $oprofile = Ostatus_profile::getKV('peopletag_id', $peopletag->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $oprofile->subscribe();
- $sub = $user->getProfile();
- $tagger = Profile::getKV($peopletag->tagger);
- $act = new Activity();
- $act->id = TagURI::mint('subscribe_peopletag:%d:%d:%s',
- $sub->id,
- $peopletag->id,
- common_date_iso8601(time()));
- $act->actor = $sub->asActivityObject();
- $act->verb = ActivityVerb::FOLLOW;
- $act->objects[] = $oprofile->asActivityObject();
- $act->time = time();
-
- $act->title = _m('TITLE','Follow list');
-
-
- $act->content = sprintf(_m('%1$s is now following people listed in %2$s by %3$s.'),
- $sub->getBestName(),
- $oprofile->getBestName(),
- $tagger->getBestName());
- if ($oprofile->notifyActivity($act, $sub)) {
- return true;
- } else {
- $oprofile->garbageCollect();
-
- throw new Exception(_m('Failed subscribing to remote list.'));
- }
- }
-
- function onEndUnsubscribePeopletag($peopletag, $user)
- {
- $oprofile = Ostatus_profile::getKV('peopletag_id', $peopletag->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
-
- $oprofile->garbageCollect();
- $sub = Profile::getKV($user->id);
- $tagger = Profile::getKV($peopletag->tagger);
- $act = new Activity();
- $act->id = TagURI::mint('unsubscribe_peopletag:%d:%d:%s',
- $sub->id,
- $peopletag->id,
- common_date_iso8601(time()));
- $act->actor = $member->asActivityObject();
- $act->verb = ActivityVerb::UNFOLLOW;
- $act->objects[] = $oprofile->asActivityObject();
- $act->time = time();
-
- $act->title = _m('Unfollow list');
-
-
- $act->content = sprintf(_m('%1$s stopped following the list %2$s by %3$s.'),
- $sub->getBestName(),
- $oprofile->getBestName(),
- $tagger->getBestName());
- $oprofile->notifyActivity($act, $user);
- }
-
- function onEndFavorNotice(Profile $profile, Notice $notice)
- {
-
-
- if (!$profile->isLocal()) {
- return true;
- }
- $oprofile = Ostatus_profile::getKV('profile_id', $notice->profile_id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $fav = Fave::pkeyGet(array('user_id' => $profile->id,
- 'notice_id' => $notice->id));
- if (!$fav instanceof Fave) {
-
-
- return true;
- }
- $act = $fav->asActivity();
- $oprofile->notifyActivity($act, $profile);
- return true;
- }
-
- function onEndTagProfile($ptag)
- {
- $oprofile = Ostatus_profile::getKV('profile_id', $ptag->tagged);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $plist = $ptag->getMeta();
- if ($plist->private) {
- return true;
- }
- $act = new Activity();
- $tagger = $plist->getTagger();
- $tagged = Profile::getKV('id', $ptag->tagged);
- $act->verb = ActivityVerb::TAG;
- $act->id = TagURI::mint('tag_profile:%d:%d:%s',
- $plist->tagger, $plist->id,
- common_date_iso8601(time()));
- $act->time = time();
-
- $act->title = _m('TITLE','List');
-
-
- $act->content = sprintf(_m('%1$s listed %2$s in the list %3$s.'),
- $tagger->getBestName(),
- $tagged->getBestName(),
- $plist->getBestName());
- $act->actor = $tagger->asActivityObject();
- $act->objects = array($tagged->asActivityObject());
- $act->target = ActivityObject::fromPeopletag($plist);
- $oprofile->notifyDeferred($act, $tagger);
-
- $oprofile->subscribe();
- return true;
- }
-
- function onEndUntagProfile($ptag)
- {
- $oprofile = Ostatus_profile::getKV('profile_id', $ptag->tagged);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $plist = $ptag->getMeta();
- if ($plist->private) {
- return true;
- }
- $act = new Activity();
- $tagger = $plist->getTagger();
- $tagged = Profile::getKV('id', $ptag->tagged);
- $act->verb = ActivityVerb::UNTAG;
- $act->id = TagURI::mint('untag_profile:%d:%d:%s',
- $plist->tagger, $plist->id,
- common_date_iso8601(time()));
- $act->time = time();
-
- $act->title = _m('TITLE','Unlist');
-
-
- $act->content = sprintf(_m('%1$s removed %2$s from the list %3$s.'),
- $tagger->getBestName(),
- $tagged->getBestName(),
- $plist->getBestName());
- $act->actor = $tagger->asActivityObject();
- $act->objects = array($tagged->asActivityObject());
- $act->target = ActivityObject::fromPeopletag($plist);
- $oprofile->notifyDeferred($act, $tagger);
-
- $oprofile->garbageCollect();
- return true;
- }
-
- function onEndDisfavorNotice(Profile $profile, Notice $notice)
- {
-
-
- if (!$profile->isLocal()) {
- return true;
- }
- $oprofile = Ostatus_profile::getKV('profile_id', $notice->profile_id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $act = new Activity();
- $act->verb = ActivityVerb::UNFAVORITE;
- $act->id = TagURI::mint('disfavor:%d:%d:%s',
- $profile->id,
- $notice->id,
- common_date_iso8601(time()));
- $act->time = time();
-
- $act->title = _m('Unlike');
-
-
- $act->content = sprintf(_m('%1$s no longer likes %2$s.'),
- $profile->getBestName(),
- $notice->getUrl());
- $act->actor = $profile->asActivityObject();
- $act->objects[] = $notice->asActivityObject();
- $oprofile->notifyActivity($act, $profile);
- return true;
- }
- function onStartGetProfileUri($profile, &$uri)
- {
- $oprofile = Ostatus_profile::getKV('profile_id', $profile->id);
- if ($oprofile instanceof Ostatus_profile) {
- $uri = $oprofile->uri;
- return false;
- }
- return true;
- }
- function onStartUserGroupHomeUrl($group, &$url)
- {
- return $this->onStartUserGroupPermalink($group, $url);
- }
- function onStartUserGroupPermalink($group, &$url)
- {
- $oprofile = Ostatus_profile::getKV('group_id', $group->id);
- if ($oprofile instanceof Ostatus_profile) {
-
-
- $url = $oprofile->uri;
- return false;
- }
- }
- function onStartShowSubscriptionsContent($action)
- {
- $this->showEntityRemoteSubscribe($action);
- return true;
- }
- function onStartShowUserGroupsContent($action)
- {
- $this->showEntityRemoteSubscribe($action, 'ostatusgroup');
- return true;
- }
- function onEndShowSubscriptionsMiniList($action)
- {
- $this->showEntityRemoteSubscribe($action);
- return true;
- }
- function onEndShowGroupsMiniList($action)
- {
- $this->showEntityRemoteSubscribe($action, 'ostatusgroup');
- return true;
- }
- function showEntityRemoteSubscribe($action, $target='ostatussub')
- {
- if (!$action->getScoped() instanceof Profile) {
-
- return true;
- }
- if ($action->getScoped()->sameAs($action->getTarget())) {
- $action->elementStart('div', 'entity_actions');
- $action->elementStart('p', array('id' => 'entity_remote_subscribe',
- 'class' => 'entity_subscribe'));
- $action->element('a', array('href' => common_local_url($target),
- 'class' => 'entity_remote_subscribe'),
-
- _m('Remote'));
- $action->elementEnd('p');
- $action->elementEnd('div');
- }
- }
-
- function onEndBroadcastProfile(Profile $profile)
- {
- $user = User::getKV('id', $profile->id);
-
-
-
-
-
- $sql = "SELECT * FROM ostatus_profile " .
- "WHERE profile_id IN " .
- "(SELECT subscribed FROM subscription WHERE subscriber=%d) " .
- "OR group_id IN " .
- "(SELECT group_id FROM group_member WHERE profile_id=%d)";
- $oprofile = new Ostatus_profile();
- $oprofile->query(sprintf($sql, $profile->id, $profile->id));
- if ($oprofile->N == 0) {
- common_log(LOG_DEBUG, "No OStatus remote subscribees for $profile->nickname");
- return true;
- }
- $act = new Activity();
- $act->verb = ActivityVerb::UPDATE_PROFILE;
- $act->id = TagURI::mint('update-profile:%d:%s',
- $profile->id,
- common_date_iso8601(time()));
- $act->time = time();
-
- $act->title = _m('Profile update');
-
-
- $act->content = sprintf(_m('%s has updated their profile page.'),
- $profile->getBestName());
- $act->actor = $profile->asActivityObject();
- $act->objects[] = $act->actor;
- while ($oprofile->fetch()) {
- $oprofile->notifyDeferred($act, $profile);
- }
- return true;
- }
- function onEndShowAccountProfileBlock(HTMLOutputter $out, Profile $profile)
- {
- if ($profile->isLocal()) {
- return true;
- }
- try {
- $oprofile = Ostatus_profile::fromProfile($profile);
- } catch (Exception $e) {
-
-
- return true;
- }
- try {
- $feedsub = $oprofile->getFeedSub();
- } catch (NoResultException $e) {
-
-
-
- return true;
- }
- $websub_states = [
- 'subscribe' => _m('Pending'),
- 'active' => _m('Active'),
- 'nohub' => _m('Polling'),
- 'inactive' => _m('Inactive'),
- ];
- $out->elementStart('dl', 'entity_tags ostatus_profile');
- $out->element('dt', null, _m('WebSub'));
- $out->element('dd', null, $websub_states[$feedsub->sub_state]);
- $out->elementEnd('dl');
- }
-
- function onStartProfileListItemActionElements($item)
- {
- if (common_logged_in()) {
-
- return true;
- } elseif (!$item->getTarget()->isLocal()) {
-
- return true;
- }
- if ($item instanceof ProfileAction) {
- $output = $item;
- } elseif ($item instanceof Widget) {
- $output = $item->out;
- } else {
-
- throw new ServerException('Bad item type for onStartProfileListItemActionElements');
- }
-
- $output->elementStart('li', 'entity_subscribe');
- $url = common_local_url('ostatusinit',
- array('nickname' => $item->getTarget()->getNickname()));
- $output->element('a', array('href' => $url,
- 'class' => 'entity_remote_subscribe'),
-
- _m('Subscribe'));
- $output->elementEnd('li');
- $output->elementStart('li', 'entity_tag');
- $url = common_local_url('ostatustag',
- array('nickname' => $item->getTarget()->getNickname()));
- $output->element('a', array('href' => $url,
- 'class' => 'entity_remote_tag'),
-
- _m('List'));
- $output->elementEnd('li');
- return true;
- }
-
- public function onNodeInfoProtocols(array &$protocols)
- {
- $protocols[] = "ostatus";
- return true;
- }
- function onPluginVersion(array &$versions)
- {
- $versions[] = array('name' => 'OStatus',
- 'version' => self::PLUGIN_VERSION,
- 'author' => 'Evan Prodromou, James Walker, Brion Vibber, Zach Copley',
- 'homepage' => 'https://git.gnu.io/gnu/gnu-social/tree/master/plugins/OStatus',
-
- 'rawdescription' => _m('Follow people across social networks that implement '.
- '<a href="http://ostatus.org/">OStatus</a>.'));
- return true;
- }
-
- public static function localGroupFromUrl($url)
- {
- $group = User_group::getKV('uri', $url);
- if ($group instanceof User_group) {
- if ($group->isLocal()) {
- return $group->id;
- }
- } else {
-
-
-
- $template = common_local_url('groupbyid', array('id' => '31337'));
- $template = preg_quote($template, '/');
- $template = str_replace('31337', '(\d+)', $template);
- if (preg_match("/$template/", $url, $matches)) {
- return intval($matches[1]);
- }
- }
- return false;
- }
- public function onStartProfileGetAtomFeed($profile, &$feed)
- {
- $oprofile = Ostatus_profile::getKV('profile_id', $profile->id);
- if (!$oprofile instanceof Ostatus_profile) {
- return true;
- }
- $feed = $oprofile->feeduri;
- return false;
- }
- function onStartGetProfileFromURI($uri, &$profile)
- {
-
-
-
-
- $user = User::getKV('uri', $uri);
- if ($user instanceof User) {
- $profile = $user->getProfile();
- return false;
- } else {
- $group = User_group::getKV('uri', $uri);
- if ($group instanceof User_group) {
- $profile = $group->getProfile();
- return false;
- }
- }
-
- try {
- $oprofile = Ostatus_profile::ensureProfileURI($uri);
- $profile = $oprofile->localProfile();
- return !($profile instanceof Profile);
- } catch (Exception $e) {
- return true;
- }
- }
- function onEndWebFingerNoticeLinks(XML_XRD $xrd, Notice $target)
- {
- $salmon_url = null;
- $actor = $target->getProfile();
- if ($actor->isLocal()) {
- $profiletype = $this->profileTypeString($actor);
- $salmon_url = common_local_url("{$profiletype}salmon", array('id' => $actor->getID()));
- } else {
- try {
- $oprofile = Ostatus_profile::fromProfile($actor);
- $salmon_url = $oprofile->salmonuri;
- } catch (Exception $e) {
-
- }
- }
-
- if (!empty($salmon_url)) {
- $xrd->links[] = new XML_XRD_Element_Link(Salmon::REL_SALMON, $salmon_url);
- }
- return true;
- }
- function onEndWebFingerProfileLinks(XML_XRD $xrd, Profile $target)
- {
- if ($target->getObjectType() === ActivityObject::PERSON) {
- $this->addWebFingerPersonLinks($xrd, $target);
- } elseif ($target->getObjectType() === ActivityObject::GROUP) {
- $xrd->links[] = new XML_XRD_Element_Link(Discovery::UPDATESFROM,
- common_local_url('ApiTimelineGroup',
- array('id' => $target->getGroup()->getID(), 'format' => 'atom')),
- 'application/atom+xml');
- }
-
- $profiletype = $this->profileTypeString($target);
- $salmon_url = common_local_url("{$profiletype}salmon", array('id' => $target->id));
- $xrd->links[] = new XML_XRD_Element_Link(Salmon::REL_SALMON, $salmon_url);
-
- $xrd->links[] = new XML_XRD_Element_Link(Salmon::NS_REPLIES, $salmon_url);
- $xrd->links[] = new XML_XRD_Element_Link(Salmon::NS_MENTIONS, $salmon_url);
-
- $xrd->links[] = new XML_XRD_Element_Link('http://ostatus.org/schema/1.0/subscribe',
- common_local_url('ostatussub') . '?profile={uri}',
- null,
- true);
- return true;
- }
- protected function profileTypeString(Profile $target)
- {
-
- switch ($target->getObjectType()) {
- case ActivityObject::PERSON:
- return 'user';
- case ActivityObject::GROUP:
- return 'group';
- default:
- throw new ServerException('Unknown profile type for WebFinger profile links');
- }
- }
- protected function addWebFingerPersonLinks(XML_XRD $xrd, Profile $target)
- {
- $xrd->links[] = new XML_XRD_Element_Link(Discovery::UPDATESFROM,
- common_local_url('ApiTimelineUser',
- array('id' => $target->id, 'format' => 'atom')),
- 'application/atom+xml');
-
- $magicsig = Magicsig::getKV('user_id', $target->id);
- if (!$magicsig instanceof Magicsig && $target->isLocal()) {
- $magicsig = Magicsig::generate($target->getUser());
- }
- if (!$magicsig instanceof Magicsig) {
- return false;
- }
- if (Event::handle('StartAttachPubkeyToUserXRD', array($magicsig, $xrd, $target))) {
- $xrd->links[] = new XML_XRD_Element_Link(Magicsig::PUBLICKEYREL,
- 'data:application/magic-public-key,'. $magicsig->toString());
-
- Event::handle('EndAttachPubkeyToUserXRD', array($magicsig, $xrd, $target));
- }
- }
- public function onGetLocalAttentions(Profile $actor, array $attention_uris, array &$mentions, array &$groups)
- {
- list($groups, $mentions) = Ostatus_profile::filterAttention($actor, $attention_uris);
- }
-
- static public function onCheckActivityAuthorship(Activity $activity, Profile &$profile)
- {
- try {
- $oprofile = Ostatus_profile::ensureProfileURL($profile->getUrl());
- $profile = $oprofile->checkAuthorship($activity);
- } catch (Exception $e) {
- common_log(LOG_ERR, 'Could not get a profile or check authorship ('.get_class($e).': "'.$e->getMessage().'") for activity ID: '.$activity->id);
- $profile = null;
- return false;
- }
- return true;
- }
- public function onProfileDeleteRelated($profile, &$related)
- {
-
- $related[] = 'Ostatus_profile';
-
- $magicsig = Magicsig::getKV('user_id', $profile->id);
- if ($magicsig instanceof Magicsig) {
- $magicsig->delete();
- }
- return true;
- }
- public function onSalmonSlap($endpoint_uri, MagicEnvelope $magic_env, Profile $target=null)
- {
- try {
- $envxml = $magic_env->toXML($target);
- } catch (Exception $e) {
- common_log(LOG_ERR, sprintf('Could not generate Magic Envelope XML for profile id=='.$target->getID().': '.$e->getMessage()));
- return false;
- }
- $headers = array('Content-Type: application/magic-envelope+xml');
- try {
- $client = new HTTPClient();
- $client->setBody($envxml);
- $response = $client->post($endpoint_uri, $headers);
- } catch (Exception $e) {
- common_log(LOG_ERR, "Salmon post to $endpoint_uri failed: " . $e->getMessage());
- return false;
- }
- if ($response->getStatus() === 422) {
- common_debug(sprintf('Salmon (from profile %d) endpoint %s returned status %s. We assume it is a Diaspora seed; will adapt and try again if that plugin is enabled!', $magic_env->getActor()->getID(), $endpoint_uri, $response->getStatus()));
- return true;
- }
-
-
-
-
- if (!in_array($response->getStatus(), array(200, 201, 202))) {
- common_log(LOG_ERR, sprintf('Salmon (from profile %d) endpoint %s returned status %s: %s',
- $magic_env->getActor()->getID(), $endpoint_uri, $response->getStatus(), $response->getBody()));
- return true;
- }
-
- return false;
- }
- public function onCronDaily()
- {
- try {
- $sub = FeedSub::renewalCheck();
- } catch (NoResultException $e) {
- common_log(LOG_INFO, "There were no expiring feeds.");
- return;
- }
- $qm = QueueManager::get();
- while ($sub->fetch()) {
- $item = array('feedsub_id' => $sub->id);
- $qm->enqueue($item, 'pushrenew');
- }
- }
- }
|