. * * @category AtomPub * @package StatusNet * @author Evan Prodromou * @copyright 2010 StatusNet, Inc. * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0 * @link http://status.net/ */ if (!defined('STATUSNET')) { // This check helps protect against security problems; // your code file can't be executed directly from the web. exit(1); } /** * A remote service that supports AtomPub * * @category AtomPub * @package StatusNet * @author Evan Prodromou * @copyright 2010 StatusNet, Inc. * @license http://www.fsf.org/licensing/licenses/agpl-3.0.html AGPL 3.0 * @link http://status.net/ */ class ActivitySink { protected $svcDocUrl = null; protected $username = null; protected $password = null; protected $collections = array(); function __construct($svcDocUrl, $username, $password) { $this->svcDocUrl = $svcDocUrl; $this->username = $username; $this->password = $password; $this->_parseSvcDoc(); } private function _parseSvcDoc() { $client = new HTTPClient(); $response = $client->get($this->svcDocUrl); if ($response->getStatus() != 200) { throw new Exception("Can't get {$this->svcDocUrl}; response status " . $response->getStatus()); } $xml = $response->getBody(); $dom = new DOMDocument(); // We don't want to bother with white spaces $dom->preserveWhiteSpace = false; // Don't spew XML warnings to output $old = error_reporting(); error_reporting($old & ~E_WARNING); $ok = $dom->loadXML($xml); error_reporting($old); $path = new DOMXPath($dom); $path->registerNamespace('atom', 'http://www.w3.org/2005/Atom'); $path->registerNamespace('app', 'http://www.w3.org/2007/app'); $path->registerNamespace('activity', 'http://activitystrea.ms/spec/1.0/'); $collections = $path->query('//app:collection'); for ($i = 0; $i < $collections->length; $i++) { $collection = $collections->item($i); $url = $collection->getAttribute('href'); $takesEntries = false; $accepts = $path->query('app:accept', $collection); for ($j = 0; $j < $accepts->length; $j++) { $accept = $accepts->item($j); $acceptValue = $accept->nodeValue; if (preg_match('#application/atom\+xml(;\s*type=entry)?#', $acceptValue)) { $takesEntries = true; break; } } if (!$takesEntries) { continue; } $verbs = $path->query('activity:verb', $collection); if ($verbs->length == 0) { $this->_addCollection(ActivityVerb::POST, $url); } else { for ($k = 0; $k < $verbs->length; $k++) { $verb = $verbs->item($k); $this->_addCollection($verb->nodeValue, $url); } } } } private function _addCollection($verb, $url) { if (array_key_exists($verb, $this->collections)) { $this->collections[$verb][] = $url; } else { $this->collections[$verb] = array($url); } return; } function postActivity($activity) { if (!array_key_exists($activity->verb, $this->collections)) { throw new Exception("No collection for verb {$activity->verb}"); } else { if (count($this->collections[$activity->verb]) > 1) { common_log(LOG_NOTICE, "More than one collection for verb {$activity->verb}"); } $this->postToCollection($this->collections[$activity->verb][0], $activity); } } function postToCollection($url, $activity) { $client = new HTTPClient($url); $client->setMethod('POST'); $client->setAuth($this->username, $this->password); $client->setHeader('Content-Type', 'application/atom+xml;type=entry'); $client->setBody($activity->asString(true, true, true)); $response = $client->send(); } }