From 75f1a17f7e54b4a790d616e74e56c07f562c577f Mon Sep 17 00:00:00 2001 From: Michael Vogel Date: Mon, 23 Nov 2015 18:44:47 +0100 Subject: [PATCH] New function for creating the OStatus messages --- include/delivery.php | 2 + include/notifier.php | 3 + include/ostatus.php | 375 ++++++++++++++++++++++++++++++++++++++ include/pubsubpublish.php | 4 +- 4 files changed, 383 insertions(+), 1 deletion(-) diff --git a/include/delivery.php b/include/delivery.php index cdd59451f..851f633e6 100644 --- a/include/delivery.php +++ b/include/delivery.php @@ -2,6 +2,7 @@ require_once("boot.php"); require_once('include/queue_fn.php'); require_once('include/html2plain.php'); +require_once("include/ostatus.php"); function delivery_run(&$argv, &$argc){ global $a, $db; @@ -391,6 +392,7 @@ function delivery_run(&$argv, &$argc){ continue; if(($top_level) && ($public_message) && ($item['author-link'] === $item['owner-link']) && (! $expire)) + //$slaps[] = ostatus_salmon($item,$owner); $slaps[] = atom_entry($item,'html',null,$owner,true); } diff --git a/include/notifier.php b/include/notifier.php index 9dac5f114..52ec5765d 100644 --- a/include/notifier.php +++ b/include/notifier.php @@ -4,6 +4,7 @@ require_once('include/queue_fn.php'); require_once('include/html2plain.php'); require_once("include/Scrape.php"); require_once('include/diaspora.php'); +require_once("include/ostatus.php"); /* * This file was at one time responsible for doing all deliveries, but this caused @@ -529,6 +530,7 @@ function notifier_run(&$argv, &$argc){ unset($photos); } else { + //$slap = ostatus_salmon($target_item,$owner); $slap = atom_entry($target_item,'html',null,$owner,false); if($followup) { @@ -569,6 +571,7 @@ function notifier_run(&$argv, &$argc){ $atom .= atom_entry($item,'text',null,$owner,true); if(($top_level) && ($public_message) && ($item['author-link'] === $item['owner-link']) && (! $expire)) + //$slaps[] = ostatus_salmon($item,$owner); $slaps[] = atom_entry($item,'html',null,$owner,true); } } diff --git a/include/ostatus.php b/include/ostatus.php index 0dd462d3e..2a252b947 100644 --- a/include/ostatus.php +++ b/include/ostatus.php @@ -14,6 +14,15 @@ define('OSTATUS_DEFAULT_POLL_INTERVAL', 30); // given in minutes define('OSTATUS_DEFAULT_POLL_TIMEFRAME', 1440); // given in minutes define('OSTATUS_DEFAULT_POLL_TIMEFRAME_MENTIONS', 14400); // given in minutes +define("NS_ATOM", "http://www.w3.org/2005/Atom"); +define("NS_THR", "http://purl.org/syndication/thread/1.0"); +define("NS_GEORSS", "http://www.georss.org/georss"); +define("NS_ACTIVITY", "http://activitystrea.ms/spec/1.0/"); +define("NS_MEDIA", "http://purl.org/syndication/atommedia"); +define("NS_POCO", "http://portablecontacts.net/spec/1.0"); +define("NS_OSTATUS", "http://ostatus.org/schema/1.0"); +define("NS_STATUSNET", "http://status.net/schema/api/1/"); + function ostatus_check_follow_friends() { $r = q("SELECT `uid`,`v` FROM `pconfig` WHERE `cat`='system' AND `k`='ostatus_legacy_contact' AND `v` != ''"); @@ -1067,4 +1076,370 @@ function ostatus_store_conversation($itemid, $conversation_url) { logger('Storing conversation url '.$conversation_url.' for id '.$itemid); } } + +function xml_add_element($doc, $parent, $element, $value = "", $attributes = array()) { + $element = $doc->createElement($element, $value); + + foreach ($attributes AS $key => $value) { + $attribute = $doc->createAttribute($key); + $attribute->value = $value; + $element->appendChild($attribute); + } + + $parent->appendChild($element); +} + +function ostatus_add_header($doc, $owner) { + $a = get_app(); + + $r = q("SELECT * FROM `profile` WHERE `uid` = %d AND `is-default`", + intval($owner["user_uid"])); + if (!$r) + return; + + $profile = $r[0]; + + $root = $doc->createElementNS(NS_ATOM, 'feed'); + $doc->appendChild($root); + + $root->setAttributeNS(NS_ATOM, "xmlns:thr", NS_THR); + $root->setAttributeNS(NS_ATOM, "xmlns:georss", NS_GEORSS); + $root->setAttributeNS(NS_ATOM, "xmlns:activity", NS_ACTIVITY); + $root->setAttributeNS(NS_ATOM, "xmlns:media", NS_MEDIA); + $root->setAttributeNS(NS_ATOM, "xmlns:poco", NS_POCO); + $root->setAttributeNS(NS_ATOM, "xmlns:ostatus", NS_OSTATUS); + $root->setAttributeNS(NS_ATOM, "xmlns:statusnet", NS_STATUSNET); + + $attributes = array("uri" => "https://friendi.ca", "version" => FRIENDICA_VERSION."-".DB_UPDATE_VERSION); + xml_add_element($doc, $root, "generator", FRIENDICA_PLATFORM, $attributes); + xml_add_element($doc, $root, "id", $a->get_baseurl()."/profile/".$owner["nick"]); + xml_add_element($doc, $root, "title", sprintf("%s timeline", $profile["name"])); + xml_add_element($doc, $root, "subtitle", sprintf("Updates from %s on %s", $profile["name"], $a->config["sitename"])); + xml_add_element($doc, $root, "logo", $profile["photo"]); + xml_add_element($doc, $root, "updated", datetime_convert("UTC", "UTC", "now", ATOM_TIME)); + + $author = ostatus_add_author($doc, $owner, $profile); + $root->appendChild($author); + + $attributes = array("href" => $owner["url"], "rel" => "alternate", "type" => "text/html"); + xml_add_element($doc, $root, "link", "", $attributes); + + // To-Do: We have to find out what this is + //$attributes = array("href" => $a->get_baseurl()."/sup", + // "rel" => "http://api.friendfeed.com/2008/03#sup", + // "type" => "application/json"); + //xml_add_element($doc, $root, "link", "", $attributes); + + ostatus_hublinks($doc, $root); + + $attributes = array("href" => $a->get_baseurl()."/salmon/".$owner["nick"], "rel" => "salmon"); + xml_add_element($doc, $root, "link", "", $attributes); + + $attributes = array("href" => $a->get_baseurl()."/salmon/".$owner["nick"], "rel" => "http://salmon-protocol.org/ns/salmon-replies"); + xml_add_element($doc, $root, "link", "", $attributes); + + $attributes = array("href" => $a->get_baseurl()."/salmon/".$owner["nick"], "rel" => "http://salmon-protocol.org/ns/salmon-mention"); + xml_add_element($doc, $root, "link", "", $attributes); + + $attributes = array("href" => $a->get_baseurl()."/api/statuses/user_timeline/".$owner["nick"].".atom", + "rel" => "self", "type" => "application/atom+xml"); + xml_add_element($doc, $root, "link", "", $attributes); + + return $root; +} + +function ostatus_hublinks($doc, $root) { + $a = get_app(); + $hub = get_config('system','huburl'); + + $hubxml = ''; + if(strlen($hub)) { + $hubs = explode(',', $hub); + if(count($hubs)) { + foreach($hubs as $h) { + $h = trim($h); + if(! strlen($h)) + continue; + if ($h === '[internal]') + $h = $a->get_baseurl() . '/pubsubhubbub'; + xml_add_element($doc, $root, "link", "", array("href" => $h, "rel" => "hub")); + } + } + } +} + +function ostatus_get_attachment($doc, $root, $item) { + $o = ""; + $siteinfo = get_attached_data($item["body"]); + + switch($siteinfo["type"]) { + case 'link': + $attributes = array("rel" => "enclosure", + "href" => $siteinfo["url"], + "type" => "text/html; charset=UTF-8", + "length" => "", + "title" => $siteinfo["title"]); + xml_add_element($doc, $root, "link", "", $attributes); + break; + case 'photo': + $imgdata = get_photo_info($siteinfo["image"]); + $attributes = array("rel" => "enclosure", + "href" => $siteinfo["image"], + "type" => $imgdata["mime"], + "length" => intval($imgdata["size"])); + xml_add_element($doc, $root, "link", "", $attributes); + break; + case 'video': + $attributes = array("rel" => "enclosure", + "href" => $siteinfo["url"], + "type" => "text/html; charset=UTF-8", + "length" => "", + "title" => $siteinfo["title"]); + xml_add_element($doc, $root, "link", "", $attributes); + break; + default: + break; + } + + $arr = explode('[/attach],',$item['attach']); + if(count($arr)) { + foreach($arr as $r) { + $matches = false; + $cnt = preg_match('|\[attach\]href=\"(.*?)\" length=\"(.*?)\" type=\"(.*?)\" title=\"(.*?)\"|',$r,$matches); + if($cnt) { + $attributes = array("rel" => "enclosure", + "href" => $matches[1], + "type" => $matches[3]); + + if(intval($matches[2])) + $attributes["length"] = intval($matches[2]); + + if(trim($matches[4]) != "") + $attributes["title"] = trim($matches[4]); + + xml_add_element($doc, $root, "link", "", $attributes); + } + } + } +} + +function ostatus_add_author($doc, $owner, $profile) { + $a = get_app(); + + $author = $doc->createElement("author"); + xml_add_element($doc, $author, "activity:object-type", ACTIVITY_OBJ_PERSON); + xml_add_element($doc, $author, "uri", $owner["url"]); + xml_add_element($doc, $author, "name", $owner["nick"]); + + $attributes = array("rel" => "alternate", "type" => "text/html", "href" => $owner["url"]); + xml_add_element($doc, $author, "link", "", $attributes); + + $attributes = array( + "rel" => "avatar", + "type" => "image/jpeg", // To-Do? + "media:width" => 175, + "media:height" => 175, + "href" => $profile["photo"]); + xml_add_element($doc, $author, "link", "", $attributes); + + $attributes = array( + "rel" => "avatar", + "type" => "image/jpeg", // To-Do? + "media:width" => 80, + "media:height" => 80, + "href" => $profile["thumb"]); + xml_add_element($doc, $author, "link", "", $attributes); + + xml_add_element($doc, $author, "poco:preferredUsername", $owner["nick"]); + xml_add_element($doc, $author, "poco:displayName", $profile["name"]); + xml_add_element($doc, $author, "poco:note", $profile["about"]); + + if (trim($owner["location"]) != "") { + $element = $doc->createElement("poco:address"); + xml_add_element($doc, $element, "poco:formatted", $owner["location"]); + $author->appendChild($element); + } + + if (trim($profile["homepage"]) != "") { + $urls = $doc->createElement("poco:urls"); + xml_add_element($doc, $urls, "poco:type", "homepage"); + xml_add_element($doc, $urls, "poco:value", $profile["homepage"]); + xml_add_element($doc, $urls, "poco:primary", "true"); + $author->appendChild($urls); + } + + xml_add_element($doc, $author, "followers", "", array("url" => $a->get_baseurl()."/viewcontacts/".$owner["nick"])); + xml_add_element($doc, $author, "statusnet:profile_info", "", array("local_id" => $owner["user_uid"])); + + return $author; +} + +function ostatus_entry($doc, $item, $owner, $toplevel = false) { + $a = get_app(); + + if (!$toplevel) { + $entry = $doc->createElement("entry"); + $title = sprintf("New note by %s", $owner["nick"]); + } else { + $entry = $doc->createElementNS(NS_ATOM, "entry"); + + $entry->setAttributeNS(NS_ATOM, "xmlns:thr", NS_THR); + $entry->setAttributeNS(NS_ATOM, "xmlns:georss", NS_GEORSS); + $entry->setAttributeNS(NS_ATOM, "xmlns:activity", NS_ACTIVITY); + $entry->setAttributeNS(NS_ATOM, "xmlns:media", NS_MEDIA); + $entry->setAttributeNS(NS_ATOM, "xmlns:poco", NS_POCO); + $entry->setAttributeNS(NS_ATOM, "xmlns:ostatus", NS_OSTATUS); + $entry->setAttributeNS(NS_ATOM, "xmlns:statusnet", NS_STATUSNET); + + $r = q("SELECT * FROM `profile` WHERE `uid` = %d AND `is-default`", + intval($owner["user_uid"])); + if (!$r) + return; + + $profile = $r[0]; + + $author = ostatus_add_author($doc, $owner, $profile); + $entry->appendChild($author); + + $title = sprintf("New comment by %s", $owner["nick"]); + } + + xml_add_element($doc, $entry, "activity:object-type", $item["object-type"]); + xml_add_element($doc, $entry, "id", $item["uri"]); //tag:fresh.federati.net,2015-11-22:noticeId=324796:objectType=note + xml_add_element($doc, $entry, "title", $title); + + if($item['allow_cid'] || $item['allow_gid'] || $item['deny_cid'] || $item['deny_gid']) + $body = fix_private_photos($item['body'],$owner['uid'],$item, 0); + else + $body = $item['body']; + + if ($item['title'] != "") + $body = "[b]".$item['title']."[/b]\n\n".$body; + + $body = bbcode($body, false, false, 7); + xml_add_element($doc, $entry, "content", $body, array("type" => "html")); + + xml_add_element($doc, $entry, "link", "", array("rel" => "alternate", "type" => "text/html", + "href" => $a->get_baseurl()."/display/".$item["guid"])); + + xml_add_element($doc, $entry, "status_net", "", array("notice_id" => $item["id"])); + xml_add_element($doc, $entry, "activity:verb", construct_verb($item)); + xml_add_element($doc, $entry, "published", datetime_convert("UTC","UTC",$item["created"]."+00:00",ATOM_TIME)); + xml_add_element($doc, $entry, "updated", datetime_convert("UTC","UTC",$item["edited"]."+00:00",ATOM_TIME)); + + if (($item['parent'] != $item['id']) || ($item['parent-uri'] !== $item['uri']) || (($item['thr-parent'] !== '') && ($item['thr-parent'] !== $item['uri']))) { + $parent = q("SELECT `guid` FROM `item` WHERE `id` = %d", intval($item["parent"])); + $parent_item = (($item['thr-parent']) ? $item['thr-parent'] : $item['parent-uri']); + + $attributes = array( + "ref" => $parent_item, + "type" => "text/html", + "href" => $a->get_baseurl()."/display/".$parent[0]["guid"]); + xml_add_element($doc, $entry, "thr:in-reply-to", "", $attributes); + + $attributes = array( + "rel" => "related", + "href" => $a->get_baseurl()."/display/".$parent[0]["guid"]); + xml_add_element($doc, $entry, "link", "", $attributes); + } + + xml_add_element($doc, $entry, "link", "", array("rel" => "ostatus:conversation", + "href" => $a->get_baseurl()."/display/".$owner["nick"]."/".$item["parent"])); + xml_add_element($doc, $entry, "ostatus:conversation", $a->get_baseurl()."/display/".$owner["nick"]."/".$item["parent"]); + + $tags = item_getfeedtags($item); + + if(count($tags)) + foreach($tags as $t) + if ($t[0] == "@") + xml_add_element($doc, $entry, "link", "", array("rel" => "mentioned", + "ostatus:object-type" => ACTIVITY_OBJ_PERSON, + "href" => $t[1])); + + if (!$item["private"]) + xml_add_element($doc, $entry, "link", "", array("rel" => "mentioned", + "ostatus:object-type" => "http://activitystrea.ms/schema/1.0/collection", + "href" => "http://activityschema.org/collection/public")); + + if(count($tags)) + foreach($tags as $t) + if ($t[0] != "@") + xml_add_element($doc, $entry, "category", "", array("term" => $t[2])); + + ostatus_get_attachment($doc, $entry, $item); + + // To-Do: + // The API call has yet to be implemented + $attributes = array("href" => $a->get_baseurl()."/api/statuses/show/".$item["id"].".atom", + "rel" => "self", "type" => "application/atom+xml"); + xml_add_element($doc, $entry, "link", "", $attributes); + + $attributes = array("href" => $a->get_baseurl()."/api/statuses/show/".$item["id"].".atom", + "rel" => "edit", "type" => "application/atom+xml"); + xml_add_element($doc, $entry, "link", "", $attributes); + + $app = $item["app"]; + if ($app == "") + $app = "web"; + + xml_add_element($doc, $entry, "statusnet:notice_info", "", array("local_id" => $item["id"], "source" => $app)); + + return $entry; +} + +function ostatus_feed(&$a, $owner_nick, $last_update) { + + $r = q("SELECT `contact`.*, `user`.`uid` AS `user_uid`, `user`.`nickname`, `user`.`timezone`, `user`.`page-flags` + FROM `contact` INNER JOIN `user` ON `user`.`uid` = `contact`.`uid` + WHERE `contact`.`self` AND `user`.`nickname` = '%s' LIMIT 1", + dbesc($owner_nick)); + if (!$r) + return; + + $owner = $r[0]; + + if(!strlen($last_update)) + $last_update = 'now -30 days'; + + $check_date = datetime_convert('UTC','UTC',$last_update,'Y-m-d H:i:s'); + + $items = q("SELECT STRAIGHT_JOIN `item`.*, `item`.`id` AS `item_id` FROM `item` + INNER JOIN `thread` ON `thread`.`iid` = `item`.`parent` + LEFT JOIN `item` AS `thritem` ON `thritem`.`uri`=`item`.`thr-parent` AND `thritem`.`uid`=`item`.`uid` + WHERE `item`.`uid` = %d AND `item`.`received` > '%s' AND NOT `item`.`private` AND NOT `item`.`deleted` + AND `item`.`allow_cid` = '' AND `item`.`allow_gid` = '' AND `item`.`deny_cid` = '' AND `item`.`deny_gid` = '' + AND ((`item`.`wall` AND (`item`.`parent` = `item`.`id`)) + OR (`item`.`network` = '%s' AND ((`thread`.`network`='%s') OR (`thritem`.`network` = '%s'))) AND `thread`.`mention`) + AND (`item`.`owner-link` IN ('%s', '%s')) + ORDER BY `item`.`received` DESC + LIMIT 0, 300", + intval($owner["user_uid"]), dbesc($check_date), + dbesc(NETWORK_DFRN), dbesc(NETWORK_OSTATUS), dbesc(NETWORK_OSTATUS), + dbesc($owner["nurl"]), dbesc(str_replace("http://", "https://", $owner["nurl"])) + ); + + $doc = new DOMDocument('1.0', 'utf-8'); + $doc->formatOutput = true; + + $root = ostatus_add_header($doc, $owner); + + foreach ($items AS $item) { + $entry = ostatus_entry($doc, $item, $owner); + $root->appendChild($entry); + } + + return($doc->saveXML()); +} + +function ostatus_salmon($item,$owner) { + + $doc = new DOMDocument('1.0', 'utf-8'); + $doc->formatOutput = true; + + $entry = ostatus_entry($doc, $item, $owner, true); + + $doc->appendChild($entry); + + return($doc->saveXML()); +} ?> diff --git a/include/pubsubpublish.php b/include/pubsubpublish.php index bc81fd786..8ac468c31 100644 --- a/include/pubsubpublish.php +++ b/include/pubsubpublish.php @@ -1,5 +1,6 @@ 0"); foreach($r as $rr) { - $params = get_feed_for($a, '', $rr['nickname'], $rr['last_update'], 0, true); + //$params = get_feed_for($a, '', $rr['nickname'], $rr['last_update'], 0, true); + $params = ostatus_feed($a, $rr['nickname'], $rr['last_update']); $hmac_sig = hash_hmac("sha1", $params, $rr['secret']); $headers = array("Content-type: application/atom+xml",