summaryrefslogtreecommitdiff
path: root/plugins/RSSCloud/RSSCloudRequestNotify.php
diff options
context:
space:
mode:
authorZach Copley <zach@status.net>2009-09-21 00:54:56 -0700
committerZach Copley <zach@status.net>2010-01-05 22:59:42 -0800
commit51ac7439e1875e7703c7aaeba91d19838b860032 (patch)
tree1911530cd1c4e4633555690d01c98c43a7da8985 /plugins/RSSCloud/RSSCloudRequestNotify.php
parent391003c3c65572dd156244390d8eedd2dfd96f90 (diff)
/rsscloud/request_notify should work now
Diffstat (limited to 'plugins/RSSCloud/RSSCloudRequestNotify.php')
-rw-r--r--plugins/RSSCloud/RSSCloudRequestNotify.php187
1 files changed, 141 insertions, 46 deletions
diff --git a/plugins/RSSCloud/RSSCloudRequestNotify.php b/plugins/RSSCloud/RSSCloudRequestNotify.php
index 1d4087334..48bd3fb27 100644
--- a/plugins/RSSCloud/RSSCloudRequestNotify.php
+++ b/plugins/RSSCloud/RSSCloudRequestNotify.php
@@ -1,7 +1,8 @@
<?php
/**
- * Notifier
+ * Action to let RSSCloud aggregators request update notification when
+ * user profile feeds change.
*
* PHP version 5
*
@@ -32,9 +33,8 @@ if (!defined('STATUSNET')) {
exit(1);
}
-class RSSCloudRequestNotifyAction extends Action
+class RSSCloudRequestNotifyAction extends Action
{
-
/**
* Initialization.
*
@@ -45,100 +45,195 @@ class RSSCloudRequestNotifyAction extends Action
function prepare($args)
{
parent::prepare($args);
+
+ $this->ip = $_SERVER['REMOTE_ADDR'];
+ $this->port = $this->arg('port');
+ $this->path = $this->arg('path');
+ $this->protocol = $this->arg('protocol');
+ $this->procedure = $this->arg('notifyProcedure');
+ $this->feeds = $this->getFeeds();
+
+ $this->subscriber_url = 'http://' . $this->ip . ':' . $this->port . $this->path;
+
return true;
}
function handle($args)
{
parent::handle($args);
-
+
if ($_SERVER['REQUEST_METHOD'] != 'POST') {
- showResult(false, 'Request must be POST.');
+ $this->showResult(false, 'Request must be POST.');
+ return;
}
-
- $ip = $_SERVER['REMOTE_ADDR'];
+
$missing = array();
- $port = $this->arg('port');
-
+
if (empty($this->port)) {
$missing[] = 'port';
}
-
+
$path = $this->arg('path');
if (empty($this->path)) {
$missing[] = 'path';
}
-
+
$protocol = $this->arg('protocol');
if (empty($this->protocol)) {
$missing[] = 'protocol';
}
-
- if (empty($this->notifyProcedure)) {
+
+ if (!isset($this->procedure)) {
$missing[] = 'notifyProcedure';
}
-
+
if (!empty($missing)) {
$msg = 'The following parameters were missing from the request body: ' .
- implode(',', $missing) . '.';
+ implode(', ', $missing) . '.';
$this->showResult(false, $msg);
+ return;
}
-
- $feeds = $this->getFeeds();
-
- if (empty($feeds)) {
- $this->showResult(false,
- 'You must provide at least one feed url (url1, url2, url3 ... urlN).');
+
+ if (empty($this->feeds)) {
+ $this->showResult(false,
+ 'You must provide at least one valid profile feed url (url1, url2, url3 ... urlN).');
+ return;
}
-
+
$endpoint = $ip . ':' . $port . $path;
-
- foreach ($feeds as $feed) {
-
+
+ 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.';
+
+ $this->showResult(true, $msg);
}
-
-
+
function getFeeds()
{
$feeds = array();
-
+
foreach ($this->args as $key => $feed ) {
if (preg_match('|url\d+|', $key)) {
-
- // XXX: validate feeds somehow and kick bad ones out
-
- $feeds[] = $feed;
+
+ 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);
+ }
}
}
-
+
return $feeds;
}
-
-
- function checkNotifyHandler()
+
+ 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)) {
+
+ common_debug("Valid feed: $feed");
+
+ // 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 ($this->testNotificationHandler($feed)) {
+ return true;
+ }
+ }
+
+ return false;
+ }
+
+ // this actually does the validating and figuring out the
+ // user, which it returns
+ function userFromFeed($feed)
{
-
+ // We only do profile feeds
+
+ $path = common_path('api/statuses/user_timeline/');
+ $valid = '%^' . $path . '(?<nickname>.*)\.rss$%';
+
+ if (preg_match($valid, $feed, $matches)) {
+ $user = User::staticGet('nickname', $matches['nickname']);
+ if (!empty($user)) {
+ return $user;
+ }
+ }
+
+ return false;
}
-
- function validateFeed()
+
+ 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 = userFromFeed($feed);
+
+ $result = subs_subscribe_to($user, $other);
+
+ if ($result != true) {
+ $msg = "RSSPlugin - got '$result' trying to subscribe " .
+ "$this->subscriber_url to $user->nickname" . "'s profile feed.";
+ common_log(LOG_WARN, $msg);
+ } 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");
+
+ // XXX: We need to add a field to Remote_profile to indicate the kind
+ // of remote profile? i.e: OMB, RSSCloud, PuSH, Twitter
+
+ $remote = new Remote_profile();
+ $remote->uri = $this->subscriber_url;
+ $remote->postnoticeurl = $this->subscriber_url;
+ $remote->created = DB_DataObject_Cast::dateTime();
+
+ if (!$remote->insert()) {
+ throw new Exception(_('RSSCloud plugin - Error inserting remote profile!'));
+ }
}
-
- function showResult($success, $msg)
+
+ function showResult($success, $msg)
{
$this->startXML();
$this->elementStart('notifyResult', array('success' => ($success) ? 'true' : 'false',
'msg' => $msg));
$this->endXML();
-
}
-
-
+
}