123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795 |
- <?php
- defined('GNUSOCIAL') || die();
- class Activity
- {
- const SPEC = 'http://activitystrea.ms/spec/1.0/';
- const SCHEMA = 'http://activitystrea.ms/schema/1.0/';
- const MEDIA = 'http://purl.org/syndication/atommedia';
- const VERB = 'verb';
- const OBJECT = 'object';
- const ACTOR = 'actor';
- const SUBJECT = 'subject';
- const OBJECTTYPE = 'object-type';
- const CONTEXT = 'context';
- const TARGET = 'target';
- const ATOM = 'http://www.w3.org/2005/Atom';
- const AUTHOR = 'author';
- const PUBLISHED = 'published';
- const UPDATED = 'updated';
- const RSS = null;
- const PUBDATE = 'pubDate';
- const DESCRIPTION = 'description';
- const GUID = 'guid';
- const SELF = 'self';
- const IMAGE = 'image';
- const URL = 'url';
- const DC = 'http://purl.org/dc/elements/1.1/';
- const CREATOR = 'creator';
- const CONTENTNS = 'http://purl.org/rss/1.0/modules/content/';
- const ENCODED = 'encoded';
- public $actor;
- public $verb;
- public $objects = array();
- public $target;
- public $context;
- public $time;
- public $link;
- public $entry;
- public $feed;
- public $summary;
- public $content;
- public $id;
- public $title;
- public $categories = array();
- public $enclosures = array();
- public $attachments = array();
- public $extra = array();
- public $source;
- public $selfLink;
- public $editLink;
- public $generator;
-
- public function __construct($entry = null, $feed = null)
- {
- if (is_null($entry)) {
- return;
- }
-
- if ($feed instanceof DOMDocument) {
- throw new ClientException(
-
- _('Expecting a root feed element but got a whole XML document.')
- );
- }
- $this->entry = $entry;
- $this->feed = $feed;
- if (
- $entry->namespaceURI === Activity::ATOM
- && $entry->localName === 'entry'
- ) {
- $this->_fromAtomEntry($entry, $feed);
- } elseif (
- $entry->namespaceURI === Activity::RSS
- && $entry->localName === 'item'
- ) {
- $this->_fromRssItem($entry, $feed);
- } elseif (
- $entry->namespaceURI === Activity::SPEC
- && $entry->localName === 'object'
- ) {
- $this->_fromAtomEntry($entry, $feed);
- } else {
-
- throw new Exception("Unknown DOM element: {$entry->namespaceURI} {$entry->localName}");
- }
- }
- public function _fromAtomEntry($entry, $feed)
- {
- $pubEl = $this->_child($entry, self::PUBLISHED, self::ATOM);
- if (!empty($pubEl)) {
- $this->time = strtotime($pubEl->textContent);
- } else {
-
- $updateEl = $this->_child($entry, self::UPDATED, self::ATOM);
- if (!empty($updateEl)) {
- $this->time = strtotime($updateEl->textContent);
- } else {
- $this->time = null;
- }
- }
- $this->link = ActivityUtils::getPermalink($entry);
- $verbEl = $this->_child($entry, self::VERB);
- if (!empty($verbEl)) {
- $this->verb = trim($verbEl->textContent);
- } else {
- $this->verb = ActivityVerb::POST;
-
- }
-
- $objectEls = ActivityUtils::children($entry, self::OBJECT, self::SPEC);
- if (count($objectEls) > 0) {
- foreach ($objectEls as $objectEl) {
-
- $objectType = ActivityUtils::childContent($objectEl, self::OBJECTTYPE, self::SPEC);
- if ((!empty($objectType) && $objectType == ActivityObject::ACTIVITY) || $this->verb == ActivityVerb::SHARE) {
- $this->objects[] = new Activity($objectEl);
- } else {
- $this->objects[] = new ActivityObject($objectEl);
- }
- }
- } else {
-
- $this->objects[] = new ActivityObject($entry);
- }
- if (!empty($actorEl = $this->_child($entry, self::ACTOR))) {
-
-
-
- $this->actor = new ActivityObject($actorEl);
-
-
-
- if (!preg_match('/^\w+:/', $this->actor->id)) {
- $authorEl = ActivityUtils::child($entry, 'author');
- if (!empty($authorEl)) {
- $authorObj = new ActivityObject($authorEl);
- $this->actor->id = $authorObj->id;
- }
- }
- } elseif (!empty($authorEl = $this->_child(
- $entry,
- self::AUTHOR,
- self::ATOM
- ))) {
-
-
- $this->actor = new ActivityObject($authorEl);
- } elseif (
- !empty($feed)
- && !empty($subjectEl = $this->_child($feed, self::SUBJECT))
- ) {
-
-
- $this->actor = new ActivityObject($subjectEl);
- } elseif (
- !empty($feed)
- && !empty($authorEl = $this->_child($feed, self::AUTHOR, self::ATOM))
- ) {
-
-
- $this->actor = new ActivityObject($authorEl);
- }
- $contextEl = $this->_child($entry, self::CONTEXT);
- if (!empty($contextEl)) {
- $this->context = new ActivityContext($contextEl);
- } else {
- $this->context = new ActivityContext($entry);
- }
- $targetEl = $this->_child($entry, self::TARGET);
- if (!empty($targetEl)) {
- $this->target = new ActivityObject($targetEl);
- } elseif (ActivityUtils::compareVerbs($this->verb, array(ActivityVerb::FAVORITE))) {
-
- $this->target = clone($this->objects[0]);
- }
- $this->summary = ActivityUtils::childContent($entry, 'summary');
- $this->id = ActivityUtils::childContent($entry, 'id');
- $this->content = ActivityUtils::getContent($entry);
- $catEls = $entry->getElementsByTagNameNS(self::ATOM, 'category');
- if ($catEls) {
- for ($i = 0; $i < $catEls->length; $i++) {
- $catEl = $catEls->item($i);
- $this->categories[] = new AtomCategory($catEl);
- }
- }
- foreach (ActivityUtils::getLinks($entry, 'enclosure') as $link) {
- $this->enclosures[] = $link->getAttribute('href');
- }
-
- $this->selfLink = ActivityUtils::getSelfLink($entry);
- $this->editLink = ActivityUtils::getLink($entry, 'edit', 'application/atom+xml');
- }
- public function _fromRssItem($item, $channel)
- {
- $verbEl = $this->_child($item, self::VERB);
- if (!empty($verbEl)) {
- $this->verb = trim($verbEl->textContent);
- } else {
- $this->verb = ActivityVerb::POST;
-
- }
- $pubDateEl = $this->_child($item, self::PUBDATE, self::RSS);
- if (!empty($pubDateEl)) {
- $this->time = strtotime($pubDateEl->textContent);
- }
- if (!empty($authorEl = $this->_child(
- $item,
- self::AUTHOR,
- self::RSS
- ))) {
- $this->actor = ActivityObject::fromRssAuthor($authorEl);
- } elseif (!empty($dcCreatorEl = $this->_child(
- $item,
- self::CREATOR,
- self::DC
- ))) {
- $this->actor = ActivityObject::fromDcCreator($dcCreatorEl);
- } elseif (!empty($posterousEl = $this->_child(
- $item,
- ActivityObject::AUTHOR,
- ActivityObject::POSTEROUS
- ))) {
-
- $this->actor = ActivityObject::fromPosterousAuthor($posterousEl);
- } elseif (!empty($channel)) {
- $this->actor = ActivityObject::fromRssChannel($channel);
- } else {
-
- }
- $this->title = ActivityUtils::childContent($item, ActivityObject::TITLE, self::RSS);
- $contentEl = ActivityUtils::child($item, self::ENCODED, self::CONTENTNS);
- if (!empty($contentEl)) {
-
- $this->content = $contentEl->textContent;
- } else {
- $descriptionEl = ActivityUtils::child($item, self::DESCRIPTION, self::RSS);
- if (!empty($descriptionEl)) {
-
-
-
-
-
-
- $this->content = htmlspecialchars($descriptionEl->textContent);
- }
- }
- $this->link = ActivityUtils::childContent($item, ActivityUtils::LINK, self::RSS);
-
-
- $guidEl = ActivityUtils::child($item, self::GUID, self::RSS);
- if (!empty($guidEl)) {
- $this->id = $guidEl->textContent;
- if ($guidEl->hasAttribute('isPermaLink') && $guidEl->getAttribute('isPermaLink') != 'false') {
-
- $this->link = $this->id;
- }
- }
- $this->objects[] = new ActivityObject($item);
- $this->context = new ActivityContext($item);
- }
-
- public function toAtomEntry()
- {
- return null;
- }
-
- public function asArray()
- {
- $activity = array();
-
- $activity['actor'] = $this->actor->asArray();
-
- $activity['content'] = $this->content;
-
- if (!empty($this->generator)) {
- $activity['generator'] = $this->generator->asArray();
- }
-
-
- $activity['id'] = $this->id;
-
- if (count($this->objects) == 0) {
- common_log(LOG_ERR, "Can't save " . $this->id);
- } else {
- if (count($this->objects) > 1) {
- common_log(LOG_WARNING, "Ignoring " . (count($this->objects) - 1) . " extra objects in JSON output for activity " . $this->id);
- }
- $object = $this->objects[0];
- if ($object instanceof Activity) {
-
- if (ActivityVerb::canonical($this->verb) == ActivityVerb::canonical(ActivityVerb::SHARE) &&
- ActivityVerb::canonical($object->verb) == ActivityVerb::canonical(ActivityVerb::POST)) {
-
- $object = $object->objects[0];
- }
- }
- $activity['object'] = $object->asArray();
- if ($object instanceof Activity) {
- $activity['object']['objectType'] = 'activity';
- }
- foreach ($this->attachments as $attachment) {
- if (empty($activity['object']['attachments'])) {
- $activity['object']['attachments'] = array();
- }
- $activity['object']['attachments'][] = $attachment->asArray();
- }
- }
-
-
- if (!empty($this->context)) {
- if (!empty($this->context->location)) {
- $loc = $this->context->location;
- $activity['location'] = array(
- 'objectType' => 'place',
- 'position' => sprintf("%+02.5F%+03.5F/", $loc->lat, $loc->lon),
- 'lat' => $loc->lat,
- 'lon' => $loc->lon
- );
- $name = $loc->getName();
- if ($name) {
- $activity['location']['displayName'] = $name;
- }
-
- $url = $loc->getURL();
- if ($url) {
- $activity['location']['url'] = $url;
- }
- }
- $activity['to'] = $this->context->getToArray();
- $ctxarr = $this->context->asArray();
- if (array_key_exists('inReplyTo', $ctxarr)) {
- $activity['object']['inReplyTo'] = $ctxarr['inReplyTo'];
- unset($ctxarr['inReplyTo']);
- }
- if (!array_key_exists('status_net', $activity)) {
- $activity['status_net'] = array();
- }
- foreach ($ctxarr as $key => $value) {
- $activity['status_net'][$key] = $value;
- }
- }
-
- $activity['published'] = self::iso8601Date($this->time);
-
- $provider = array(
- 'objectType' => 'service',
- 'displayName' => common_config('site', 'name'),
- 'url' => common_root_url()
- );
- $activity['provider'] = $provider;
-
- if (!empty($this->target)) {
- $activity['target'] = $this->target->asArray();
- }
-
- $activity['title'] = $this->title;
-
-
-
- $activity['verb'] = ActivityVerb::canonical($this->verb);
-
- if ($this->link) {
- $activity['url'] = $this->link;
- }
-
- if ($activity['verb'] == 'post') {
- $tags = array();
- foreach ($this->categories as $cat) {
- if (mb_strlen($cat->term) > 0) {
-
- $tags[] = array('objectType' => 'http://activityschema.org/object/hashtag',
- 'displayName' => $cat->term);
- }
- }
- if (count($tags) > 0) {
- $activity['object']['tags'] = $tags;
- }
- }
-
-
-
- foreach ($this->extra as $e) {
- list($objectName, $props, $txt) = $e;
- if (!empty($objectName)) {
- $parts = explode(":", $objectName);
- if (count($parts) == 2 && $parts[0] == "statusnet") {
- if (!array_key_exists('status_net', $activity)) {
- $activity['status_net'] = array();
- }
- $activity['status_net'][$parts[1]] = $props;
- } else {
- $activity[$objectName] = $props;
- }
- }
- }
- return array_filter($activity);
- }
- public function asString(
- $namespace = false,
- $author = true,
- $source = false
- ) {
- $xs = new XMLStringer(true);
- $this->outputTo($xs, $namespace, $author, $source);
- return $xs->getString();
- }
- public function outputTo(
- $xs,
- $namespace = false,
- $author = true,
- $source = false,
- $tag = 'entry'
- ) {
- if ($namespace) {
- $attrs = array('xmlns' => 'http://www.w3.org/2005/Atom',
- 'xmlns:thr' => 'http://purl.org/syndication/thread/1.0',
- 'xmlns:activity' => 'http://activitystrea.ms/spec/1.0/',
- 'xmlns:georss' => 'http://www.georss.org/georss',
- 'xmlns:ostatus' => 'http://ostatus.org/schema/1.0',
- 'xmlns:poco' => 'http://portablecontacts.net/spec/1.0',
- 'xmlns:media' => 'http://purl.org/syndication/atommedia',
- 'xmlns:statusnet' => 'http://status.net/schema/api/1/');
- } else {
- $attrs = array();
- }
- $xs->elementStart($tag, $attrs);
- if ($tag != 'entry') {
- $xs->element('activity:object-type', null, ActivityObject::ACTIVITY);
- }
- if ($this->verb == ActivityVerb::POST && count($this->objects) == 1 && $tag == 'entry') {
- $obj = $this->objects[0];
- $obj->outputTo($xs, null);
- } else {
- $xs->element('id', null, $this->id);
- if ($this->title) {
- $xs->element('title', null, $this->title);
- } else {
-
- $xs->element('title', null, "");
- }
- $xs->element('content', array('type' => 'html'), $this->content);
- if (!empty($this->summary)) {
- $xs->element('summary', null, $this->summary);
- }
- if (!empty($this->link)) {
- $xs->element('link', array('rel' => 'alternate',
- 'type' => 'text/html',
- 'href' => $this->link));
- }
- }
- $xs->element('activity:verb', null, $this->verb);
- $published = self::iso8601Date($this->time);
- $xs->element('published', null, $published);
- $xs->element('updated', null, $published);
- if ($author) {
- $this->actor->outputTo($xs, 'author');
- }
- if ($this->verb != ActivityVerb::POST || count($this->objects) != 1 || $tag != 'entry') {
- foreach ($this->objects as $object) {
- if ($object instanceof Activity) {
- $object->outputTo($xs, false, true, true, 'activity:object');
- } else {
- $object->outputTo($xs, 'activity:object');
- }
- }
- }
- if (!empty($this->context)) {
- if (!empty($this->context->replyToID)) {
- if (!empty($this->context->replyToUrl)) {
- $xs->element('thr:in-reply-to', [
- 'ref' => $this->context->replyToID,
- 'href' => $this->context->replyToUrl,
- ]);
- } else {
- $xs->element('thr:in-reply-to', [
- 'ref' => $this->context->replyToID,
- ]);
- }
- }
- if (!empty($this->context->replyToUrl)) {
- $xs->element('link', [
- 'rel' => 'related',
- 'href' => $this->context->replyToUrl,
- ]);
- }
- if (!empty($this->context->conversation)) {
- $convattr = [];
- $conv = Conversation::getKV('uri', $this->context->conversation);
- if ($conv instanceof Conversation) {
- $convattr['href'] = $conv->getUrl();
- $convattr['local_id'] = $conv->getID();
- $convattr['ref'] = $conv->getUri();
- $xs->element('link', [
- 'rel' => 'ostatus:' . ActivityContext::CONVERSATION,
- 'href' => $convattr['href'],
- ]);
- } else {
- $convattr['ref'] = $this->context->conversation;
- }
- $xs->element(
- 'ostatus:' . ActivityContext::CONVERSATION,
- $convattr,
- $this->context->conversation
- );
-
- }
- foreach ($this->context->attention as $attnURI=>$type) {
- $xs->element('link', [
- 'rel' => ActivityContext::MENTIONED,
- ActivityContext::OBJECTTYPE => $type,
- 'href' => $attnURI,
- ]);
- }
- if (!empty($this->context->location)) {
- $loc = $this->context->location;
- $xs->element('georss:point', null, $loc->lat . ' ' . $loc->lon);
- }
- }
- if ($this->target) {
- $this->target->outputTo($xs, 'activity:target');
- }
- foreach ($this->categories as $cat) {
- $cat->outputTo($xs);
- }
-
- foreach ($this->enclosures as $enclosure) {
- if (is_string($enclosure)) {
- $xs->element('link', array('rel' => 'enclosure',
- 'href' => $enclosure));
- } else {
- $attributes = array('rel' => 'enclosure',
- 'href' => $enclosure->url,
- 'type' => $enclosure->mimetype,
- 'length' => $enclosure->size);
- if ($enclosure->title) {
- $attributes['title'] = $enclosure->title;
- }
- $xs->element('link', $attributes);
- }
- }
-
- if ($source && !empty($this->source)) {
- $xs->elementStart('source');
- $xs->element('id', null, $this->source->id);
- $xs->element('title', null, $this->source->title);
- if (array_key_exists('alternate', $this->source->links)) {
- $xs->element('link', array('rel' => 'alternate',
- 'type' => 'text/html',
- 'href' => $this->source->links['alternate']));
- }
- if (array_key_exists('self', $this->source->links)) {
- $xs->element('link', array('rel' => 'self',
- 'type' => 'application/atom+xml',
- 'href' => $this->source->links['self']));
- }
- if (array_key_exists('license', $this->source->links)) {
- $xs->element('link', array('rel' => 'license',
- 'href' => $this->source->links['license']));
- }
- if (!empty($this->source->icon)) {
- $xs->element('icon', null, $this->source->icon);
- }
- if (!empty($this->source->updated)) {
- $xs->element('updated', null, $this->source->updated);
- }
- $xs->elementEnd('source');
- }
- if (!empty($this->selfLink)) {
- $xs->element('link', array('rel' => 'self',
- 'type' => 'application/atom+xml',
- 'href' => $this->selfLink));
- }
- if (!empty($this->editLink)) {
- $xs->element('link', array('rel' => 'edit',
- 'type' => 'application/atom+xml',
- 'href' => $this->editLink));
- }
-
- foreach ($this->extra as $el) {
- list($tag, $attrs, $content) = $el;
- $xs->element($tag, $attrs, $content);
- }
- $xs->elementEnd($tag);
- return;
- }
- private function _child($element, $tag, $namespace=self::SPEC)
- {
- return ActivityUtils::child($element, $tag, $namespace);
- }
-
- public static function iso8601Date($tm)
- {
- $dateStr = date('d F Y H:i:s', $tm);
- $d = new DateTime($dateStr, new DateTimeZone('UTC'));
- return $d->format('c');
- }
- }
|