123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262 |
- <?php
- if (!defined('GNUSOCIAL') && !defined('STATUSNET')) { exit(1); }
- class AtompubsubscriptionfeedAction extends AtompubAction
- {
- private $_profile = null;
- private $_subscriptions = null;
- protected function atompubPrepare()
- {
- $subscriber = $this->trimmed('subscriber');
- $this->_profile = Profile::getKV('id', $subscriber);
- if (!$this->_profile instanceof Profile) {
-
-
- throw new ClientException(sprintf(_('No such profile id: %d.'),
- $subscriber), 404);
- }
- $this->_subscriptions = Subscription::bySubscriber($this->_profile->id,
- $this->offset,
- $this->limit);
- return true;
- }
- protected function handleGet()
- {
- $this->showFeed();
- }
- protected function handlePost()
- {
- $this->addSubscription();
- }
-
- function showFeed()
- {
- header('Content-Type: application/atom+xml; charset=utf-8');
- $url = common_local_url('AtomPubSubscriptionFeed',
- array('subscriber' => $this->_profile->id));
- $feed = new Atom10Feed(true);
- $feed->addNamespace('activity',
- 'http://activitystrea.ms/spec/1.0/');
- $feed->addNamespace('poco',
- 'http://portablecontacts.net/spec/1.0');
- $feed->addNamespace('media',
- 'http://purl.org/syndication/atommedia');
- $feed->addNamespace('georss',
- 'http://www.georss.org/georss');
- $feed->id = $url;
- $feed->setUpdated('now');
- $feed->addAuthor($this->_profile->getBestName(),
- $this->_profile->getURI());
-
-
- $feed->setTitle(sprintf(_("%s subscriptions"),
- $this->_profile->getBestName()));
-
-
- $feed->setSubtitle(sprintf(_("People %1\$s has subscribed to on %2\$s"),
- $this->_profile->getBestName(),
- common_config('site', 'name')));
- $feed->addLink(common_local_url('subscriptions',
- array('nickname' =>
- $this->_profile->nickname)));
- $feed->addLink($url,
- array('rel' => 'self',
- 'type' => 'application/atom+xml'));
-
- if ($this->page > 1) {
- $feed->addLink($url,
- array('rel' => 'first',
- 'type' => 'application/atom+xml'));
- $feed->addLink(common_local_url('AtomPubSubscriptionFeed',
- array('subscriber' =>
- $this->_profile->id),
- array('page' =>
- $this->page - 1)),
- array('rel' => 'prev',
- 'type' => 'application/atom+xml'));
- }
- if ($this->_subscriptions->N > $this->count) {
- $feed->addLink(common_local_url('AtomPubSubscriptionFeed',
- array('subscriber' =>
- $this->_profile->id),
- array('page' =>
- $this->page + 1)),
- array('rel' => 'next',
- 'type' => 'application/atom+xml'));
- }
- $i = 0;
-
- while ($this->_subscriptions->fetch()) {
-
- $i++;
- if ($i > $this->count) {
- break;
- }
- $act = $this->_subscriptions->asActivity();
- $feed->addEntryRaw($act->asString(false, false, false));
- }
- $this->raw($feed->getString());
- }
-
- function addSubscription()
- {
- if (empty($this->auth_user) ||
- $this->auth_user->id != $this->_profile->id) {
-
- throw new ClientException(_("Cannot add someone else's".
- " subscription."), 403);
- }
- $xml = file_get_contents('php://input');
- $dom = DOMDocument::loadXML($xml);
- if ($dom->documentElement->namespaceURI != Activity::ATOM ||
- $dom->documentElement->localName != 'entry') {
-
- $this->clientError(_('Atom post must be an Atom entry.'));
- }
- $activity = new Activity($dom->documentElement);
- $sub = null;
- if (Event::handle('StartAtomPubNewActivity', array(&$activity))) {
- if ($activity->verb != ActivityVerb::FOLLOW) {
-
- $this->clientError(_('Can only handle Follow activities.'));
- }
- $person = $activity->objects[0];
- if ($person->type != ActivityObject::PERSON) {
-
- $this->clientError(_('Can only follow people.'));
- }
-
- try {
- $profile = Profile::fromUri($person->id);
- } catch (UnknownUriException $e) {
-
-
- $this->clientError(sprintf(_('Unknown profile %s.'), $person->id));
- }
- if (Subscription::exists($this->_profile, $profile)) {
-
-
-
- $this->clientError(sprintf(_('Already subscribed to %s.'),
- $person->id),
- 409);
- }
- if (Subscription::start($this->_profile, $profile)) {
- $sub = Subscription::pkeyGet(array('subscriber' => $this->_profile->id,
- 'subscribed' => $profile->id));
- }
- Event::handle('EndAtomPubNewActivity', array($activity, $sub));
- }
- if (!empty($sub)) {
- $act = $sub->asActivity();
- header('Content-Type: application/atom+xml; charset=utf-8');
- header('Content-Location: ' . $act->selfLink);
- $this->startXML();
- $this->raw($act->asString(true, true, true));
- $this->endXML();
- }
- }
- }
|