<?php
-
/**
* Action to let RSSCloud aggregators request update notification when
* user profile feeds change.
exit(1);
}
+/**
+ * Action class to handle RSSCloud notification (subscription) requests
+ *
+ * @category Plugin
+ * @package StatusNet
+ * @author Zach Copley <zach@status.net>
+ * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html GNU Affero General Public License version 3.0
+ * @link http://status.net/
+ */
class RSSCloudRequestNotifyAction extends Action
{
/**
{
parent::prepare($args);
- $this->ip = $_SERVER['REMOTE_ADDR'];
- $this->port = $this->arg('port');
- $this->path = $this->arg('path');
+ $this->ip = $_SERVER['REMOTE_ADDR'];
+ $this->port = $this->arg('port');
+ $this->path = $this->arg('path');
+
+ if ($this->path[0] != '/') {
+ $this->path = '/' . $this->path;
+ }
+
$this->protocol = $this->arg('protocol');
$this->procedure = $this->arg('notifyProcedure');
- $this->feeds = $this->getFeeds();
+ $this->domain = $this->arg('domain');
- $this->subscriber_url = 'http://' . $this->ip . ':' . $this->port . $this->path;
+ $this->feeds = $this->getFeeds();
return true;
}
+ /**
+ * Handle the request
+ *
+ * Checks for all the required parameters for a subscription,
+ * validates that the feed being subscribed to is real, and then
+ * saves the subsctiption.
+ *
+ * @param array $args $_REQUEST data (unused)
+ *
+ * @return void
+ */
function handle($args)
{
parent::handle($args);
if ($_SERVER['REQUEST_METHOD'] != 'POST') {
- $this->showResult(false, 'Request must be POST.');
+ // TRANS: Form validation error displayed when POST is not used.
+ $this->showResult(false, _m('Request must be POST.'));
return;
}
$missing[] = 'port';
}
- $path = $this->arg('path');
-
if (empty($this->path)) {
$missing[] = 'path';
}
- $protocol = $this->arg('protocol');
-
if (empty($this->protocol)) {
$missing[] = 'protocol';
+ } else if (strtolower($this->protocol) != 'http-post') {
+ // TRANS: Form validation error displayed when HTTP POST is not used.
+ $msg = _m('Only HTTP POST notifications are supported at this time.');
+ $this->showResult(false, $msg);
+ return;
}
if (!isset($this->procedure)) {
}
if (!empty($missing)) {
- $msg = 'The following parameters were missing from the request body: ' .
- implode(', ', $missing) . '.';
+ // TRANS: List separator.
+ $separator = _m('SEPARATOR',', ');
+ // TRANS: Form validation error displayed when a request body is missing expected parameters.
+ // TRANS: %s is a list of parameters separated by a list separator (default: ", ").
+ $msg = sprintf(_m('The following parameters were missing from the request body: %s.'),implode($separator, $missing));
$this->showResult(false, $msg);
return;
}
if (empty($this->feeds)) {
- $this->showResult(false,
- 'You must provide at least one valid profile feed url (url1, url2, url3 ... urlN).');
+ // TRANS: Form validation error displayed when not providing any valid profile feed URLs.
+ $msg = _m('You must provide at least one valid profile feed URL ' .
+ '(url1, url2, url3 ... urlN).');
+ $this->showResult(false, $msg);
return;
}
- $endpoint = $ip . ':' . $port . $path;
+ // We have to validate everything before saving anything.
+ // We only return one success or failure no matter how
+ // many feeds the subscriber is trying to subscribe to
+ foreach ($this->feeds as $feed) {
+ if (!$this->validateFeed($feed)) {
+ $nh = $this->getNotifyUrl();
+ common_log(LOG_WARNING,
+ "RSSCloud plugin - $nh tried to subscribe to invalid feed: $feed");
+
+ // TRANS: Form validation error displayed when not providing a valid feed URL.
+ $msg = _m('Feed subscription failed: Not a valid feed.');
+ $this->showResult(false, $msg);
+ return;
+ }
+
+ if (!$this->testNotificationHandler($feed)) {
+ // TRANS: Form validation error displayed when feed subscription failed.
+ $msg = _m('Feed subscription failed: ' .
+ 'Notification handler does not respond correctly.');
+ $this->showResult(false, $msg);
+ return;
+ }
+ }
foreach ($this->feeds as $feed) {
$this->saveSubscription($feed);
}
- // XXX: What to do about deleting stale subscriptions? 25 hours seems harsh.
- // WordPress doesn't ever remove subscriptions.
-
- $msg = 'Thanks for the registration. It worked. When the feed(s) update(s) we\'ll notify you. ' .
- ' Don\'t forget to re-register after 24 hours, your subscription will expire in 25.';
+ // XXX: What to do about deleting stale subscriptions?
+ // 25 hours seems harsh. WordPress doesn't ever remove
+ // subscriptions.
+ // TRANS: Success message after subscribing to one or more feeds.
+ $msg = _m('Thanks for the subscription. ' .
+ 'When the feed(s) update(s), you will be notified.');
$this->showResult(true, $msg);
}
+ /**
+ * Validate that the requested feed is one we serve
+ * up via RSSCloud.
+ *
+ * @param string $feed the feed in question
+ *
+ * @return void
+ */
+ function validateFeed($feed)
+ {
+ $user = $this->userFromFeed($feed);
+
+ if (empty($user)) {
+ return false;
+ }
+
+ return true;
+ }
+
+ /**
+ * Pull all of the urls (url1, url2, url3...urlN) that
+ * the subscriber wants to subscribe to.
+ *
+ * @return array $feeds the list of feeds
+ */
function getFeeds()
{
$feeds = array();
- foreach ($this->args as $key => $feed ) {
- if (preg_match('|url\d+|', $key)) {
-
- if ($this->testFeed($feed)) {
- $feeds[] = $feed;
- } else {
- $msg = 'RSSCloud Plugin - ' . $this->ip . ' tried to subscribe ' .
- 'to a non-existent feed: ' . $feed;
- common_log(LOG_WARN, $msg);
- }
+ while (list($key, $feed) = each($this->args)) {
+ if (preg_match('/^url\d*$/', $key)) {
+ $feeds[] = $feed;
}
}
return $feeds;
}
+ /**
+ * Test that a notification handler is there and is reponding
+ * correctly. This is called before adding a subscription.
+ *
+ * @param string $feed the feed to verify
+ *
+ * @return boolean success result
+ */
function testNotificationHandler($feed)
{
- $notifier = new RSSCloudNotifier();
- return $notifier->postUpdate($endpoint, $feed);
- }
-
- // returns valid user or false
- function testFeed($feed)
- {
- $user = $this->userFromFeed($feed);
-
- if (!empty($user)) {
+ $notifyUrl = $this->getNotifyUrl();
- common_debug("Valid feed: $feed");
+ $notifier = new RSSCloudNotifier();
- // OK, so this is a valid profile feed url, now let's see if the
- // other system reponds to our notifications before we
- // add the sub...
+ if (isset($this->domain)) {
+ // 'domain' param set, so we have to use GET and send a challenge
+ common_log(LOG_INFO,
+ 'RSSCloud plugin - Testing notification handler with challenge: ' .
+ $notifyUrl);
+ return $notifier->challenge($notifyUrl, $feed);
+ } else {
+ common_log(LOG_INFO, 'RSSCloud plugin - Testing notification handler: ' .
+ $notifyUrl);
- if ($this->testNotificationHandler($feed)) {
- return true;
- }
+ return $notifier->postUpdate($notifyUrl, $feed);
}
+ }
- return false;
+ /**
+ * Build the URL for the notification handler based on the
+ * parameters passed in with the subscription request.
+ *
+ * @return string notification handler url
+ */
+ function getNotifyUrl()
+ {
+ if (isset($this->domain)) {
+ return 'http://' . $this->domain . ':' . $this->port . $this->path;
+ } else {
+ return 'http://' . $this->ip . ':' . $this->port . $this->path;
+ }
}
- // this actually does the validating and figuring out the
- // user, which it returns
+ /**
+ * Uses the nickname part of the subscribed feed URL to figure out
+ * whethere there's really a user with such a feed. Used to
+ * validate feeds before adding a subscription.
+ *
+ * @param string $feed the feed in question
+ *
+ * @return boolean success
+ */
function userFromFeed($feed)
{
- // We only do profile feeds
-
- $path = common_path('api/statuses/user_timeline/');
- $valid = '%^' . $path . '(?<nickname>.*)\.rss$%';
+ // We only do canonical RSS2 profile feeds (specified by ID), e.g.:
+ // http://www.example.com/api/statuses/user_timeline/2.rss
+ $path = common_path('api/statuses/user_timeline/');
+ $valid = '%^' . $path . '(?<id>.*)\.rss$%';
if (preg_match($valid, $feed, $matches)) {
- $user = User::staticGet('nickname', $matches['nickname']);
+ $user = User::getKV('id', $matches['id']);
if (!empty($user)) {
return $user;
}
return false;
}
+ /**
+ * Save an RSSCloud subscription
+ *
+ * @param string $feed a valid profile feed
+ *
+ * @return boolean success result
+ */
function saveSubscription($feed)
{
- // check to see if we already have a profile for this subscriber
-
- $other = Remote_profile::staticGet('uri', $this->subscriber_url);
-
- if ($other === false) {
- $other->saveProfile();
- }
+ $user = $this->userFromFeed($feed);
- $user = userFromFeed($feed);
+ $notifyUrl = $this->getNotifyUrl();
- $result = subs_subscribe_to($user, $other);
+ $sub = RSSCloudSubscription::getSubscription($user->id, $notifyUrl);
- if ($result != true) {
- $msg = "RSSPlugin - got '$result' trying to subscribe " .
- "$this->subscriber_url to $user->nickname" . "'s profile feed.";
- common_log(LOG_WARN, $msg);
+ if ($sub) {
+ common_log(LOG_INFO, "RSSCloud plugin - $notifyUrl refreshed subscription" .
+ " to user $user->nickname (id: $user->id).");
} else {
- $msg = 'RSSCloud plugin - subscribe: ' . $this->subscriber_url .
- ' subscribed to ' . $feed;
-
- common_log(LOG_INFO, $msg);
- }
- }
-
- function saveProfile()
- {
- common_debug("Saving remote profile for $this->subscriber_url");
+ $sub = new RSSCloudSubscription();
- // XXX: We need to add a field to Remote_profile to indicate the kind
- // of remote profile? i.e: OMB, RSSCloud, PuSH, Twitter
+ $sub->subscribed = $user->id;
+ $sub->url = $notifyUrl;
+ $sub->created = common_sql_now();
- $remote = new Remote_profile();
- $remote->uri = $this->subscriber_url;
- $remote->postnoticeurl = $this->subscriber_url;
- $remote->created = DB_DataObject_Cast::dateTime();
+ if (!$sub->insert()) {
+ common_log_db_error($sub, 'INSERT', __FILE__);
+ return false;
+ }
- if (!$remote->insert()) {
- throw new Exception(_('RSSCloud plugin - Error inserting remote profile!'));
+ common_log(LOG_INFO, "RSSCloud plugin - $notifyUrl subscribed" .
+ " to user $user->nickname (id: $user->id)");
}
+
+ return true;
}
+ /**
+ * Show an XML message indicating the subscription
+ * was successful or failed.
+ *
+ * @param boolean $success whether it was good or bad
+ * @param string $msg the message to output
+ *
+ * @return boolean success result
+ */
function showResult($success, $msg)
{
$this->startXML();
- $this->elementStart('notifyResult', array('success' => ($success) ? 'true' : 'false',
- 'msg' => $msg));
+ $this->elementStart('notifyResult',
+ array('success' => ($success) ? 'true' : 'false',
+ 'msg' => $msg));
$this->endXML();
}
-
}
-
-
-
projects / quix0rs-gnu-social.git / blobdiff