From: Michael Vogel Date: Mon, 29 Feb 2016 07:02:50 +0000 (+0100) Subject: "profile". "like" and "comment" could work, status messages only partly. X-Git-Url: https://git.mxchange.org/?a=commitdiff_plain;h=6d3581dac8dc5a27a18a39709fa3ae38c080c490;p=friendica.git "profile". "like" and "comment" could work, status messages only partly. --- diff --git a/include/diaspora.php b/include/diaspora.php index 9dbbeabbcf..4ec7489ca4 100644 --- a/include/diaspora.php +++ b/include/diaspora.php @@ -116,8 +116,8 @@ function diaspora_dispatch($importer,$msg,$attempt=1) { $ret = diaspora_retraction($importer,$xmlbase->retraction,$msg); } elseif($xmlbase->signed_retraction) { - $tempfile = tempnam(get_temppath(), "diaspora-signed_retraction"); - file_put_contents($tempfile, json_encode($data)); + //$tempfile = tempnam(get_temppath(), "diaspora-signed_retraction"); + //file_put_contents($tempfile, json_encode($data)); $ret = diaspora_signed_retraction($importer,$xmlbase->signed_retraction,$msg); } elseif($xmlbase->relayable_retraction) { diff --git a/include/diaspora2.php b/include/diaspora2.php index e6e2d74bf6..578a496c0a 100644 --- a/include/diaspora2.php +++ b/include/diaspora2.php @@ -7,30 +7,43 @@ require_once("include/bb2diaspora.php"); require_once("include/Scrape.php"); require_once("include/Contact.php"); +require_once("include/Photo.php"); +require_once("include/socgraph.php"); -function array_to_xml($array, &$xml) { +class xml { + function from_array($array, &$xml) { - if (!is_object($xml)) { - foreach($array as $key => $value) { - $root = new SimpleXMLElement('<'.$key.'/>'); - array_to_xml($value, $root); + if (!is_object($xml)) { + foreach($array as $key => $value) { + $root = new SimpleXMLElement('<'.$key.'/>'); + array_to_xml($value, $root); - $dom = dom_import_simplexml($root)->ownerDocument; - $dom->formatOutput = true; - return $dom->saveXML(); + $dom = dom_import_simplexml($root)->ownerDocument; + $dom->formatOutput = true; + return $dom->saveXML(); + } + } + + foreach($array as $key => $value) { + if (!is_array($value) AND !is_numeric($key)) + $xml->addChild($key, $value); + elseif (is_array($value)) + array_to_xml($value, $xml->addChild($key)); } } - foreach($array as $key => $value) { - if (!is_array($value) AND !is_numeric($key)) - $xml->addChild($key, $value); - elseif (is_array($value)) - array_to_xml($value, $xml->addChild($key)); + function copy(&$source, &$target, $elementname) { + if (count($source->children()) == 0) + $target->addChild($elementname, $source); + else { + $child = $target->addChild($elementname); + foreach ($source->children() AS $childfield => $childentry) + self::copy($childentry, $child, $childfield); + } } } - /** - * @brief This class contain functions to create and send DFRN XML files + * @brief This class contain functions to create and send Diaspora XML files * */ class diaspora { @@ -39,7 +52,7 @@ class diaspora { $enabled = intval(get_config("system", "diaspora_enabled")); if (!$enabled) { - logger('diaspora is disabled'); + logger("diaspora is disabled"); return false; } @@ -69,7 +82,7 @@ class diaspora { // This will often be different with relayed messages (for example "like" and "comment") $sender = $msg["author"]; - if (!diaspora::valid_posting($msg, $fields)) { + if (!diaspora::valid_posting($msg, $fields, $data2)) { logger("Invalid posting"); return false; } @@ -77,34 +90,36 @@ class diaspora { $type = $fields->getName(); switch ($type) { - case "account_deletion": + case "account_deletion": // Not implemented return self::import_account_deletion($importer, $fields); case "comment": return true; - // return self::import_comment($importer, $sender, $fields); + //return self::import_comment($importer, $sender, $fields); case "conversation": return self::import_conversation($importer, $fields); case "like": - // return true; - return self::import_like($importer, $sender, $fields); + return true; + //return self::import_like($importer, $sender, $fields); case "message": - return self::import_message($importer, $fields); + return true; + //return self::import_message($importer, $fields); - case "participation": + case "participation": // Not implemented return self::import_participation($importer, $fields); case "photo": return self::import_photo($importer, $fields); - case "poll_participation": + case "poll_participation": // Not implemented return self::import_poll_participation($importer, $fields); case "profile": - return self::import_profile($importer, $fields); + return true; + //return self::import_profile($importer, $fields); case "request": return self::import_request($importer, $fields); @@ -116,7 +131,7 @@ class diaspora { return self::import_retraction($importer, $fields); case "status_message": - return self::import_status_message($importer, $fields); + return self::import_status_message($importer, $fields, $msg, $data2); default: logger("Unknown message type ".$type); @@ -133,16 +148,20 @@ class diaspora { * It also does the conversion between the old and the new diaspora format. * * @param array $msg Array with the XML, the sender handle and the sender signature - * @param object $fields SimpleXML object that contains the posting + * @param object $fields SimpleXML object that contains the posting when it is valid * * @return bool Is the posting valid? */ - private function valid_posting($msg, &$fields) { + private function valid_posting($msg, &$fields, &$element) { $data = parse_xml_string($msg["message"], false); + if (!is_object($data)) + return false; + $first_child = $data->getName(); + // Is this the new or the old version? if ($data->getName() == "XML") { $oldXML = true; foreach ($data->post->children() as $child) @@ -154,6 +173,8 @@ class diaspora { $type = $element->getName(); + // All retractions are handled identically from now on. + // In the new version there will only be "retraction". if (in_array($type, array("signed_retraction", "relayable_retraction"))) $type = "retraction"; @@ -161,8 +182,7 @@ class diaspora { $signed_data = ""; - foreach ($element->children() AS $fieldname => $data) { - + foreach ($element->children() AS $fieldname => $entry) { if ($oldXML) { // Translation for the old XML structure if ($fieldname == "diaspora_handle") @@ -195,30 +215,33 @@ class diaspora { } if ($fieldname == "author_signature") - $author_signature = base64_decode($data); + $author_signature = base64_decode($entry); elseif ($fieldname == "parent_author_signature") - $parent_author_signature = base64_decode($data); + $parent_author_signature = base64_decode($entry); elseif ($fieldname != "target_author_signature") { if ($signed_data != "") { $signed_data .= ";"; $signed_data_parent .= ";"; } - $signed_data .= $data; + $signed_data .= $entry; } if (!in_array($fieldname, array("parent_author_signature", "target_author_signature"))) - $fields->$fieldname = $data; + xml::copy($entry, $fields, $fieldname); } - if (in_array($type, array("status_message", "reshare"))) + // This is something that shouldn't happen at all. + if (in_array($type, array("status_message", "reshare", "profile"))) if ($msg["author"] != $fields->author) { logger("Message handle is not the same as envelope sender. Quitting this message."); return false; } + // Only some message types have signatures. So we quit here for the other types. if (!in_array($type, array("comment", "conversation", "message", "like"))) return true; + // No author_signature? This is a must, so we quit. if (!isset($author_signature)) return false; @@ -373,85 +396,57 @@ class diaspora { logger("Trying to fetch item ".$guid." from ".$server, LOGGER_DEBUG); -/// @todo $item = self::fetch_message($guid, $server); + $msg = self::fetch_message($guid, $server); - if (!$item) + if (!$msg) return false; logger("Successfully fetched item ".$guid." from ".$server, LOGGER_DEBUG); -// @todo - neue Funktion import_status... nutzen -print_r($item); -die(); - return self::import_status_message($importer, $data); + // Now call the dispatcher + return self::dispatch_public($msg); + } -/* - $body = $item["body"]; - $str_tags = $item["tag"]; - $app = $item["app"]; - $created = $item["created"]; - $author = $item["author"]; - $guid = $item["guid"]; - $private = $item["private"]; - $object = $item["object"]; - $objecttype = $item["object-type"]; + private function fetch_message($guid, $server, $level = 0) { - $r = q("SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", - intval($uid), - dbesc($guid) - ); - if(count($r)) - return $r[0]["id"]; + if ($level > 5) + return false; - $person = self::get_person_by_handle($author); + // This will not work if the server is not a Diaspora server + $source_url = $server."/p/".$guid.".xml"; + $x = fetch_url($source_url); + if(!$x) + return false; - $contact_id = get_contact($person["url"], $uid); + /// @todo - should maybe solved by the dispatcher + $source_xml = parse_xml_string($x, false); - $contacts = q("SELECT * FROM `contact` WHERE `id` = %d", intval($contact_id)); - $importers = q("SELECT * FROM `user` WHERE `uid` = %d", intval($uid)); + if (!is_object($source_xml)) + return false; - if ($contacts AND $importers) - if (!self::post_allow($importers[0],$contacts[0], false)) { - logger("Ignoring author ".$person["url"]." for uid ".$uid); - return false; - } else - logger("Author ".$person["url"]." is allowed for uid ".$uid); + if ($source_xml->post->reshare) { + // Reshare of a reshare - old Diaspora version + return self::fetch_message($source_xml->post->reshare->root_guid, $server, ++$level); + } elseif ($source_xml->getName() == "reshare") { + // Reshare of a reshare - new Diaspora version + return self::fetch_message($source_xml->root_guid, $server, ++$level); + } - $datarray = array(); - $datarray["uid"] = $uid; - $datarray["contact-id"] = $contact_id; - $datarray["wall"] = 0; - $datarray["network"] = NETWORK_DIASPORA; - $datarray["guid"] = $guid; - $datarray["uri"] = $datarray["parent-uri"] = $author.":".$guid; - $datarray["changed"] = $datarray["created"] = $datarray["edited"] = datetime_convert('UTC','UTC',$created); - $datarray["private"] = $private; - $datarray["parent"] = 0; - $datarray["plink"] = self::plink($author, $guid); - $datarray["author-name"] = $person["name"]; - $datarray["author-link"] = $person["url"]; - $datarray["author-avatar"] = ((x($person,'thumb')) ? $person["thumb"] : $person["photo"]); - $datarray["owner-name"] = $datarray["author-name"]; - $datarray["owner-link"] = $datarray["author-link"]; - $datarray["owner-avatar"] = $datarray["author-avatar"]; - $datarray["body"] = $body; - $datarray["tag"] = $str_tags; - $datarray["app"] = $app; - $datarray["visible"] = ((strlen($body)) ? 1 : 0); - $datarray["object"] = $object; - $datarray["object-type"] = $objecttype; + // Fetch the author - for the old and the new Diaspora version + if ($source_xml->post->status_message->diaspora_handle) + $author = (string)$source_xml->post->status_message->diaspora_handle; + elseif ($source_xml->author) + $author = (string)$source_xml->author; - if ($datarray["contact-id"] == 0) + if (!$author) return false; - self::fetch_guid($datarray); - $message_id = item_store($datarray); + $msg = array("message" => $x, "author" => $author); - /// @TODO - /// Looking if there is some subscribe mechanism in Diaspora to get all comments for this post + // We don't really need this, but until the work is unfinished we better will keep this + $msg["key"] = self::get_key($msg["author"]); - return $message_id; -*/ + return $msg; } private function post_allow($importer, $contact, $is_comment = false) { @@ -485,7 +480,9 @@ die(); } private function fetch_parent_item($uid, $guid, $author, $contact) { - $r = q("SELECT `id`, `body`, `wall`, `uri`, `private`, `owner-name`, `owner-link`, `owner-avatar`, `origin` + $r = q("SELECT `id`, `body`, `wall`, `uri`, `private`, `origin`, + `author-name`, `author-link`, `author-avatar`, + `owner-name`, `owner-link`, `owner-avatar` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", intval($uid), dbesc($guid)); @@ -500,8 +497,9 @@ die(); if ($result) { logger("Fetched missing item ".$guid." - result: ".$result, LOGGER_DEBUG); - $r = q("SELECT `id`, `body`, `wall`, `uri`, `private`, - `owner-name`, `owner-link`, `owner-avatar`, `origin` + $r = q("SELECT `id`, `body`, `wall`, `uri`, `private`, `origin`, + `author-name`, `author-link`, `author-avatar`, + `owner-name`, `owner-link`, `owner-avatar` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", intval($uid), dbesc($guid)); } @@ -514,7 +512,49 @@ die(); return $r[0]; } + private function get_author_contact_by_url($contact, $person, $uid) { + + $r = q("SELECT `id`, `network` FROM `contact` WHERE `nurl` = '%s' AND `uid` = %d LIMIT 1", + dbesc(normalise_link($person["url"])), intval($uid)); + if ($r) { + $cid = $r[0]["id"]; + $network = $r[0]["network"]; + } else { + $cid = $contact["id"]; + $network = NETWORK_DIASPORA; + } + + return (array("cid" => $cid, "network" => $network)); + } + + public static function is_redmatrix($url) { + return(strstr($url, "/channel/")); + } + + private function plink($addr, $guid) { + $r = q("SELECT `url`, `nick`, `network` FROM `fcontact` WHERE `addr`='%s' LIMIT 1", dbesc($addr)); + + // Fallback + if (!$r) + return "https://".substr($addr,strpos($addr,"@")+1)."/posts/".$guid; + + // Friendica contacts are often detected as Diaspora contacts in the "fcontact" table + // So we try another way as well. + $s = q("SELECT `network` FROM `gcontact` WHERE `nurl`='%s' LIMIT 1", dbesc(normalise_link($r[0]["url"]))); + if ($s) + $r[0]["network"] = $s[0]["network"]; + + if ($r[0]["network"] == NETWORK_DFRN) + return(str_replace("/profile/".$r[0]["nick"]."/", "/display/".$guid, $r[0]["url"]."/")); + + if (self::is_redmatrix($r[0]["url"])) + return $r[0]["url"]."/?f=&mid=".$guid; + + return "https://".substr($addr,strpos($addr,"@")+1)."/posts/".$guid; + } + private function import_account_deletion($importer, $data) { + // Not supported by now. We are waiting for sample data return true; } @@ -534,16 +574,16 @@ die(); logger("Ignoring the author ".$sender); return false; } -/* + $r = q("SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", intval($importer["uid"]), dbesc($guid) ); if(count($r)) { logger("The comment already exists: ".$guid); - return; + return false; } -*/ + $parent_item = self::fetch_parent_item($importer["uid"], $parent_guid, $author, $contact); if (!$parent_item) return false; @@ -555,51 +595,39 @@ die(); } // Fetch the contact id - if we know this contact - $r = q("SELECT `id`, `network` FROM `contact` WHERE `nurl` = '%s' AND `uid` = %d LIMIT 1", - dbesc(normalise_link($person["url"])), intval($importer["uid"])); - if ($r) { - $cid = $r[0]["id"]; - $network = $r[0]["network"]; - } else { - $cid = $contact["id"]; - $network = NETWORK_DIASPORA; - } - - $body = diaspora2bb($text); + $author_contact = self::get_author_contact_by_url($contact, $person, $importer["uid"]); $datarray = array(); $datarray["uid"] = $importer["uid"]; - $datarray["contact-id"] = $cid; - $datarray["type"] = 'remote-comment'; - $datarray["wall"] = $parent_item["wall"]; - $datarray["network"] = $network; - $datarray["verb"] = ACTIVITY_POST; - $datarray["gravity"] = GRAVITY_COMMENT; - $datarray["guid"] = $guid; - $datarray["uri"] = $author.":".$guid; - $datarray["parent-uri"] = $parent_item["uri"]; + $datarray["contact-id"] = $author_contact["cid"]; + $datarray["network"] = $author_contact["network"]; - // The old Diaspora protocol doesn't have a timestamp for comments - $datarray["changed"] = $datarray["created"] = $datarray["edited"] = datetime_convert(); - $datarray["private"] = $parent_item["private"]; + $datarray["author-name"] = $person["name"]; + $datarray["author-link"] = $person["url"]; + $datarray["author-avatar"] = ((x($person,"thumb")) ? $person["thumb"] : $person["photo"]); $datarray["owner-name"] = $contact["name"]; $datarray["owner-link"] = $contact["url"]; $datarray["owner-avatar"] = ((x($contact,"thumb")) ? $contact["thumb"] : $contact["photo"]); - $datarray["author-name"] = $person["name"]; - $datarray["author-link"] = $person["url"]; - $datarray["author-avatar"] = ((x($person,"thumb")) ? $person["thumb"] : $person["photo"]); - $datarray["body"] = $body; - $datarray["object"] = json_encode($data); + $datarray["guid"] = $guid; + $datarray["uri"] = $author.":".$guid; + + $datarray["type"] = "remote-comment"; + $datarray["verb"] = ACTIVITY_POST; + $datarray["gravity"] = GRAVITY_COMMENT; + $datarray["parent-uri"] = $parent_item["uri"]; + $datarray["object-type"] = ACTIVITY_OBJ_COMMENT; + $datarray["object"] = json_encode($data); + + $datarray["body"] = diaspora2bb($text); self::fetch_guid($datarray); -// $message_id = item_store($datarray); -print_r($datarray); - $datarray["id"] = $message_id; + $message_id = item_store($datarray); + // print_r($datarray); // If we are the origin of the parent we store the original data and notify our followers if($message_id AND $parent_item["origin"]) { @@ -622,6 +650,36 @@ print_r($datarray); return true; } + private function construct_like_body($contact, $parent_item, $guid) { + $bodyverb = t('%1$s likes %2$s\'s %3$s'); + + $ulink = "[url=".$contact["url"]."]".$contact["name"]."[/url]"; + $alink = "[url=".$parent_item["author-link"]."]".$parent_item["author-name"]."[/url]"; + $plink = "[url=".App::get_baseurl()."/display/".urlencode($guid)."]".t("status")."[/url]"; + + return sprintf($bodyverb, $ulink, $alink, $plink); + } + + private function construct_like_object($importer, $parent_item) { + $objtype = ACTIVITY_OBJ_NOTE; + $link = xmlify(''."\n") ; + $parent_body = $parent_item["body"]; + + $obj = <<< EOT + + + $objtype + 1 + {$parent_item["uri"]} + $link + + $parent_body + +EOT; + + return $obj; + } + private function import_like($importer, $sender, $data) { $positive = notags(unxmlify($data->positive)); $guid = notags(unxmlify($data->guid)); @@ -649,7 +707,7 @@ print_r($datarray); logger("Ignoring the author ".$sender); return false; } -/* + $r = q("SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", intval($importer["uid"]), dbesc($guid) @@ -658,7 +716,7 @@ print_r($datarray); logger("The like already exists: ".$guid); return false; } -*/ + $parent_item = self::fetch_parent_item($importer["uid"], $parent_guid, $author, $contact); if (!$parent_item) return false; @@ -670,72 +728,37 @@ print_r($datarray); } // Fetch the contact id - if we know this contact - $r = q("SELECT `id`, `network` FROM `contact` WHERE `nurl` = '%s' AND `uid` = %d LIMIT 1", - dbesc(normalise_link($person["url"])), intval($importer["uid"])); - if ($r) { - $cid = $r[0]["id"]; - $network = $r[0]["network"]; - } else { - $cid = $contact["id"]; - $network = NETWORK_DIASPORA; - } - -// ------------------------------------------------ - $objtype = ACTIVITY_OBJ_NOTE; - $link = xmlify(''."\n") ; - $parent_body = $parent_item["body"]; - - $obj = <<< EOT - - - $objtype - 1 - {$parent_item["uri"]} - $link - - $parent_body - -EOT; - $bodyverb = t('%1$s likes %2$s\'s %3$s'); - - $ulink = "[url=".$contact["url"]."]".$contact["name"]."[/url]"; - $alink = "[url=".$parent_item["author-link"]."]".$parent_item["author-name"]."[/url]"; - $plink = "[url=".App::get_baseurl()."/display/".urlencode($guid)."]".t("status")."[/url]"; - $body = sprintf($bodyverb, $ulink, $alink, $plink); -// ------------------------------------------------ + $author_contact = self::get_author_contact_by_url($contact, $person, $importer["uid"]); $datarray = array(); - $datarray["uri"] = $author.":".$guid; $datarray["uid"] = $importer["uid"]; - $datarray["guid"] = $guid; - $datarray["network"] = $network; - $datarray["contact-id"] = $cid; - $datarray["type"] = "activity"; - $datarray["wall"] = $parent_item["wall"]; - $datarray["gravity"] = GRAVITY_LIKE; - $datarray["parent"] = $parent_item["id"]; - $datarray["parent-uri"] = $parent_item["uri"]; + $datarray["contact-id"] = $author_contact["cid"]; + $datarray["network"] = $author_contact["network"]; + + $datarray["author-name"] = $person["name"]; + $datarray["author-link"] = $person["url"]; + $datarray["author-avatar"] = ((x($person,"thumb")) ? $person["thumb"] : $person["photo"]); $datarray["owner-name"] = $contact["name"]; $datarray["owner-link"] = $contact["url"]; $datarray["owner-avatar"] = ((x($contact,"thumb")) ? $contact["thumb"] : $contact["photo"]); - $datarray["author-name"] = $person["name"]; - $datarray["author-link"] = $person["url"]; - $datarray["author-avatar"] = ((x($person,"thumb")) ? $person["thumb"] : $person["photo"]); + $datarray["guid"] = $guid; + $datarray["uri"] = $author.":".$guid; - $datarray["body"] = $body; - $datarray["private"] = $parent_item["private"]; + $datarray["type"] = "activity"; $datarray["verb"] = ACTIVITY_LIKE; - $datarray["object-type"] = $objtype; - $datarray["object"] = $obj; - $datarray["visible"] = 1; - $datarray["unseen"] = 1; - $datarray["last-child"] = 0; + $datarray["gravity"] = GRAVITY_LIKE; + $datarray["parent-uri"] = $parent_item["uri"]; -print_r($datarray); -// $message_id = item_store($datarray); + $datarray["object-type"] = ACTIVITY_OBJ_NOTE; + $datarray["object"] = self::construct_like_object($importer, $parent_item); + + $datarray["body"] = self::construct_like_body($contact, $parent_item, $guid); + + $message_id = item_store($datarray); + //print_r($datarray); // If we are the origin of the parent we store the original data and notify our followers if($message_id AND $parent_item["origin"]) { @@ -751,10 +774,86 @@ print_r($datarray); proc_run("php", "include/notifier.php", "comment-import", $message_id); } - return true; + return $message_id; } private function import_message($importer, $data) { + $guid = notags(unxmlify($data->guid)); + $parent_guid = notags(unxmlify($data->parent_guid)); + $text = unxmlify($data->text); + $created_at = datetime_convert("UTC", "UTC", notags(unxmlify($data->created_at))); + $author = notags(unxmlify($data->author)); + $conversation_guid = notags(unxmlify($data->conversation_guid)); + + $parent_uri = $author.":".$parent_guid; + + $contact = self::get_contact_by_handle($importer["uid"], $author); + if (!$contact) { + logger("cannot find contact: ".$author); + return false; + } + + if(($contact["rel"] == CONTACT_IS_FOLLOWER) || ($contact["blocked"]) || ($contact["readonly"])) { + logger("Ignoring this author."); + return false; + } + + $conversation = null; + + $c = q("SELECT * FROM `conv` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", + intval($importer["uid"]), + dbesc($conversation_guid) + ); + if(count($c)) + $conversation = $c[0]; + else { + logger("conversation not available."); + return false; + } + + $reply = 0; + + $body = diaspora2bb($text); + $message_id = $author.":".$guid; + + $person = self::get_person_by_handle($author); + if (!$person) { + logger("unable to find author details"); + return false; + } + + $r = q("SELECT `id` FROM `mail` WHERE `uri` = '%s' AND `uid` = %d LIMIT 1", + dbesc($message_id), + intval($importer["uid"]) + ); + if(count($r)) { + logger("duplicate message already delivered.", LOGGER_DEBUG); + return false; + } + + q("INSERT INTO `mail` (`uid`, `guid`, `convid`, `from-name`,`from-photo`,`from-url`,`contact-id`,`title`,`body`,`seen`,`reply`,`uri`,`parent-uri`,`created`) + VALUES ( %d, '%s', %d, '%s', '%s', '%s', %d, '%s', '%s', %d, %d, '%s','%s','%s')", + intval($importer["uid"]), + dbesc($guid), + intval($conversation["id"]), + dbesc($person["name"]), + dbesc($person["photo"]), + dbesc($person["url"]), + intval($contact["id"]), + dbesc($conversation["subject"]), + dbesc($body), + 0, + 1, + dbesc($message_id), + dbesc($parent_uri), + dbesc($created_at) + ); + + q("UPDATE `conv` SET `updated` = '%s' WHERE `id` = %d", + dbesc(datetime_convert()), + intval($conversation["id"]) + ); + return true; } @@ -771,14 +870,445 @@ print_r($datarray); } private function import_profile($importer, $data) { + $author = notags(unxmlify($data->author)); + + $contact = self::get_contact_by_handle($importer["uid"], $author); + if (!$contact) + return; + + $name = unxmlify($data->first_name).((strlen($data->last_name)) ? " ".unxmlify($data->last_name) : ""); + $image_url = unxmlify($data->image_url); + $birthday = unxmlify($data->birthday); + $location = diaspora2bb(unxmlify($data->location)); + $about = diaspora2bb(unxmlify($data->bio)); + $gender = unxmlify($data->gender); + $searchable = (unxmlify($data->searchable) == "true"); + $nsfw = (unxmlify($data->nsfw) == "true"); + $tags = unxmlify($data->tag_string); + + $tags = explode("#", $tags); + + $keywords = array(); + foreach ($tags as $tag) { + $tag = trim(strtolower($tag)); + if ($tag != "") + $keywords[] = $tag; + } + + $keywords = implode(", ", $keywords); + + $handle_parts = explode("@", $author); + $nick = $handle_parts[0]; + + if($name === "") + $name = $handle_parts[0]; + + if( preg_match("|^https?://|", $image_url) === 0) + $image_url = "http://".$handle_parts[1].$image_url; + + update_contact_avatar($image_url, $importer["uid"], $contact["id"]); + + // Generic birthday. We don't know the timezone. The year is irrelevant. + + $birthday = str_replace("1000", "1901", $birthday); + + if ($birthday != "") + $birthday = datetime_convert("UTC", "UTC", $birthday, "Y-m-d"); + + // this is to prevent multiple birthday notifications in a single year + // if we already have a stored birthday and the 'm-d' part hasn't changed, preserve the entry, which will preserve the notify year + + if(substr($birthday,5) === substr($contact["bd"],5)) + $birthday = $contact["bd"]; + + $r = q("UPDATE `contact` SET `name` = '%s', `nick` = '%s', `addr` = '%s', `name-date` = '%s', `bd` = '%s', + `location` = '%s', `about` = '%s', `keywords` = '%s', `gender` = '%s' WHERE `id` = %d AND `uid` = %d", + dbesc($name), + dbesc($nick), + dbesc($author), + dbesc(datetime_convert()), + dbesc($birthday), + dbesc($location), + dbesc($about), + dbesc($keywords), + dbesc($gender), + intval($contact["id"]), + intval($importer["uid"]) + ); + + if ($searchable) { + poco_check($contact["url"], $name, NETWORK_DIASPORA, $image_url, $about, $location, $gender, $keywords, "", + datetime_convert(), 2, $contact["id"], $importer["uid"]); + } + + $gcontact = array("url" => $contact["url"], "network" => NETWORK_DIASPORA, "generation" => 2, + "photo" => $image_url, "name" => $name, "location" => $location, + "about" => $about, "birthday" => $birthday, "gender" => $gender, + "addr" => $author, "nick" => $nick, "keywords" => $keywords, + "hide" => !$searchable, "nsfw" => $nsfw); + + update_gcontact($gcontact); + return true; } private function import_request($importer, $data) { +print_r($data); +/* + $author = unxmlify($xml->author); + $recipient = unxmlify($xml->recipient); + + if (!$author || !$recipient) + return; + + $contact = self::get_contact_by_handle($importer["uid"],$author); + + if($contact) { + + // perhaps we were already sharing with this person. Now they're sharing with us. + // That makes us friends. + + if($contact["rel"] == CONTACT_IS_FOLLOWER && in_array($importer["page-flags"], array(PAGE_FREELOVE))) { + q("UPDATE `contact` SET `rel` = %d, `writable` = 1 WHERE `id` = %d AND `uid` = %d", + intval(CONTACT_IS_FRIEND), + intval($contact["id"]), + intval($importer["uid"]) + ); + } + // send notification + + $r = q("SELECT `hide-friends` FROM `profile` WHERE `uid` = %d AND `is-default` = 1 LIMIT 1", + intval($importer["uid"]) + ); + + if((count($r)) && (!$r[0]["hide-friends"]) && (!$contact["hidden"]) && intval(get_pconfig($importer["uid"],'system','post_newfriend'))) { + require_once('include/items.php'); + + $self = q("SELECT * FROM `contact` WHERE `self` = 1 AND `uid` = %d LIMIT 1", + intval($importer["uid"]) + ); + + // they are not CONTACT_IS_FOLLOWER anymore but that's what we have in the array + + if(count($self) && $contact["rel"] == CONTACT_IS_FOLLOWER) { + + $arr = array(); + $arr["uri"] = $arr["parent-uri"] = item_new_uri($a->get_hostname(), $importer["uid"]); + $arr["uid"] = $importer["uid"]; + $arr["contact-id"] = $self[0]["id"]; + $arr["wall"] = 1; + $arr["type"] = 'wall'; + $arr["gravity"] = 0; + $arr["origin"] = 1; + $arr["author-name"] = $arr["owner-name"] = $self[0]["name"]; + $arr["author-link"] = $arr["owner-link"] = $self[0]["url"]; + $arr["author-avatar"] = $arr["owner-avatar"] = $self[0]["thumb"]; + $arr["verb"] = ACTIVITY_FRIEND; + $arr["object-type"] = ACTIVITY_OBJ_PERSON; + + $A = '[url=' . $self[0]["url"] . "]' . $self[0]["name"] . '[/url]'; + $B = '[url=' . $contact["url"] . "]' . $contact["name"] . '[/url]'; + $BPhoto = '[url=' . $contact["url"] . "]' . '[img]' . $contact["thumb"] . '[/img][/url]'; + $arr["body"] = sprintf( t('%1$s is now friends with %2$s'), $A, $B)."\n\n\n".$Bphoto; + + $arr["object"] = '' . ACTIVITY_OBJ_PERSON . '' . $contact["name"] . '' + . '' . $contact["url"] . '/' . $contact["name"] . ''; + $arr["object"] .= '' . xmlify('' . "\n") +; + $arr["object"] .= xmlify('' . "\n"); + $arr["object"] .= '' . "\n"; + $arr["last-child"] = 1; + + $arr["allow_cid"] = $user[0]["allow_cid"]; + $arr["allow_gid"] = $user[0]["allow_gid"]; + $arr["deny_cid"] = $user[0]["deny_cid"]; + $arr["deny_gid"] = $user[0]["deny_gid"]; + + $i = item_store($arr); + if($i) + proc_run('php',"include/notifier.php","activity","$i"); + + } + + } + + return; + } + + $ret = self::get_person_by_handle($author); + + + if((! count($ret)) || ($ret["network"] != NETWORK_DIASPORA)) { + logger('diaspora_request: Cannot resolve diaspora handle ' . $author . ' for ' . $recipient); + return; + } + + $batch = (($ret["batch"]) ? $ret["batch"] : implode('/', array_slice(explode('/',$ret["url"]),0,3)) . '/receive/public'); + + + + $r = q("INSERT INTO `contact` (`uid`, `network`,`addr`,`created`,`url`,`nurl`,`batch`,`name`,`nick`,`photo`,`pubkey`,`notify`,`poll`,`blocked`,`priority`) + VALUES ( %d, '%s', '%s', '%s', '%s','%s','%s','%s','%s','%s','%s','%s','%s',%d,%d) ", + intval($importer["uid"]), + dbesc($ret["network"]), + dbesc($ret["addr"]), + datetime_convert(), + dbesc($ret["url"]), + dbesc(normalise_link($ret["url"])), + dbesc($batch), + dbesc($ret["name"]), + dbesc($ret["nick"]), + dbesc($ret["photo"]), + dbesc($ret["pubkey"]), + dbesc($ret["notify"]), + dbesc($ret["poll"]), + 1, + 2 + ); + + // find the contact record we just created + + $contact_record = diaspora_get_contact_by_handle($importer["uid"],$author); + + if(! $contact_record) { + logger('diaspora_request: unable to locate newly created contact record.'); + return; + } + + $g = q("select def_gid from user where uid = %d limit 1", + intval($importer["uid"]) + ); + if($g && intval($g[0]["def_gid"])) { + require_once('include/group.php'); + group_add_member($importer["uid"],'',$contact_record["id"],$g[0]["def_gid"]); + } + + if($importer["page-flags"] == PAGE_NORMAL) { + + $hash = random_string() . (string) time(); // Generate a confirm_key + + $ret = q("INSERT INTO `intro` ( `uid`, `contact-id`, `blocked`, `knowyou`, `note`, `hash`, `datetime` ) + VALUES ( %d, %d, %d, %d, '%s', '%s', '%s' )", + intval($importer["uid"]), + intval($contact_record["id"]), + 0, + 0, + dbesc( t('Sharing notification from Diaspora network')), + dbesc($hash), + dbesc(datetime_convert()) + ); + } + else { + + // automatic friend approval + + require_once('include/Photo.php'); + + update_contact_avatar($contact_record["photo"],$importer["uid"],$contact_record["id"]); + + // technically they are sharing with us (CONTACT_IS_SHARING), + // but if our page-type is PAGE_COMMUNITY or PAGE_SOAPBOX + // we are going to change the relationship and make them a follower. + + if($importer["page-flags"] == PAGE_FREELOVE) + $new_relation = CONTACT_IS_FRIEND; + else + $new_relation = CONTACT_IS_FOLLOWER; + + $r = q("UPDATE `contact` SET `rel` = %d, + `name-date` = '%s', + `uri-date` = '%s', + `blocked` = 0, + `pending` = 0, + `writable` = 1 + WHERE `id` = %d + ", + intval($new_relation), + dbesc(datetime_convert()), + dbesc(datetime_convert()), + intval($contact_record["id"]) + ); + + $u = q("select * from user where uid = %d limit 1",intval($importer["uid"])); + if($u) + $ret = diaspora_share($u[0],$contact_record); + } +*/ return true; } private function import_reshare($importer, $data) { +/* + $guid = notags(unxmlify($xml->guid)); + $author = notags(unxmlify($xml->author)); + + + if($author != $msg["author"]) { + logger('diaspora_post: Potential forgery. Message handle is not the same as envelope sender.'); + return 202; + } + + $contact = diaspora_get_contact_by_handle($importer["uid"],$author); + if(! $contact) + return; + + if(! diaspora_post_allow($importer,$contact, false)) { + logger('diaspora_reshare: Ignoring this author: ' . $author . ' ' . print_r($xml,true)); + return 202; + } + + $message_id = $author . ':' . $guid; + $r = q("SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", + intval($importer["uid"]), + dbesc($guid) + ); + if(count($r)) { + logger('diaspora_reshare: message exists: ' . $guid); + return; + } + + $orig_author = notags(unxmlify($xml->root_diaspora_id)); + $orig_guid = notags(unxmlify($xml->root_guid)); + $orig_url = $a->get_baseurl()."/display/".$orig_guid; + + $create_original_post = false; + + // Do we already have this item? + $r = q("SELECT `body`, `tag`, `app`, `created`, `plink`, `object`, `object-type`, `uri` FROM `item` WHERE `guid` = '%s' AND `visible` AND NOT +`deleted` AND `body` != '' LIMIT 1", + dbesc($orig_guid), + dbesc(NETWORK_DIASPORA) + ); + if(count($r)) { + logger('reshared message '.$orig_guid." reshared by ".$guid.' already exists on system.'); + + // Maybe it is already a reshared item? + // Then refetch the content, since there can be many side effects with reshared posts from other networks or reshares from reshares + require_once('include/api.php'); + if (api_share_as_retweet($r[0])) + $r = array(); + else { + $body = $r[0]["body"]; + $str_tags = $r[0]["tag"]; + $app = $r[0]["app"]; + $orig_created = $r[0]["created"]; + $orig_plink = $r[0]["plink"]; + $orig_uri = $r[0]["uri"]; + $object = $r[0]["object"]; + $objecttype = $r[0]["object-type"]; + } + } + + if (!count($r)) { + $body = ""; + $str_tags = ""; + $app = ""; + + $server = 'https://'.substr($orig_author,strpos($orig_author,'@')+1); + logger('1st try: reshared message '.$orig_guid." reshared by ".$guid.' will be fetched from original server: '.$server); + $item = diaspora_fetch_message($orig_guid, $server); + + if (!$item) { + $server = 'https://'.substr($author,strpos($author,'@')+1); + logger('2nd try: reshared message '.$orig_guid." reshared by ".$guid." will be fetched from sharer's server: ".$server); + $item = diaspora_fetch_message($orig_guid, $server); + } + if (!$item) { + $server = 'http://'.substr($orig_author,strpos($orig_author,'@')+1); + logger('3rd try: reshared message '.$orig_guid." reshared by ".$guid.' will be fetched from original server: '.$server); + $item = diaspora_fetch_message($orig_guid, $server); + } + if (!$item) { + $server = 'http://'.substr($author,strpos($author,'@')+1); + logger('4th try: reshared message '.$orig_guid." reshared by ".$guid." will be fetched from sharer's server: ".$server); + $item = diaspora_fetch_message($orig_guid, $server); + } + + if ($item) { + $body = $item["body"]; + $str_tags = $item["tag"]; + $app = $item["app"]; + $orig_created = $item["created"]; + $orig_author = $item["author"]; + $orig_guid = $item["guid"]; + $orig_plink = diaspora_plink($orig_author, $orig_guid); + $orig_uri = $orig_author.':'.$orig_guid; + $create_original_post = ($body != ""); + $object = $item["object"]; + $objecttype = $item["object-type"]; + } + } + + $plink = diaspora_plink($author, $guid); + + $person = find_diaspora_person_by_handle($orig_author); + + $created = unxmlify($xml->created_at); + $private = ((unxmlify($xml->public) == 'false') ? 1 : 0); + + $datarray = array(); + + $datarray["uid"] = $importer["uid"]; + $datarray["contact-id"] = $contact["id"]; + $datarray["wall"] = 0; + $datarray["network"] = NETWORK_DIASPORA; + $datarray["guid"] = $guid; + $datarray["uri"] = $datarray["parent-uri"] = $message_id; + $datarray["changed"] = $datarray["created"] = $datarray["edited"] = datetime_convert('UTC','UTC',$created); + $datarray["private"] = $private; + $datarray["parent"] = 0; + $datarray["plink"] = $plink; + $datarray["owner-name"] = $contact["name"]; + $datarray["owner-link"] = $contact["url"]; + $datarray["owner-avatar"] = ((x($contact,'thumb')) ? $contact["thumb"] : $contact["photo"]); + $prefix = share_header($person["name"], $person["url"], ((x($person,'thumb')) ? $person["thumb"] : $person["photo"]), $orig_guid, $orig_created, $orig_url); + + $datarray["author-name"] = $contact["name"]; + $datarray["author-link"] = $contact["url"]; + $datarray["author-avatar"] = $contact["thumb"]; + $datarray["body"] = $prefix.$body."[/share]"; + + $datarray["object"] = json_encode($xml); + $datarray["object-type"] = $objecttype; + + $datarray["tag"] = $str_tags; + $datarray["app"] = $app; + + // if empty content it might be a photo that hasn't arrived yet. If a photo arrives, we'll make it visible. (testing) + $datarray["visible"] = ((strlen($body)) ? 1 : 0); + + // Store the original item of a reshare + if ($create_original_post) { + require_once("include/Contact.php"); + + $datarray2 = $datarray; + + $datarray2["uid"] = 0; + $datarray2["contact-id"] = get_contact($person["url"], 0); + $datarray2["guid"] = $orig_guid; + $datarray2["uri"] = $datarray2["parent-uri"] = $orig_uri; + $datarray2["changed"] = $datarray2["created"] = $datarray2["edited"] = $datarray2["commented"] = $datarray2["received"] = datetime_convert('UTC','UTC',$orig_created); + $datarray2["parent"] = 0; + $datarray2["plink"] = $orig_plink; + + $datarray2["author-name"] = $person["name"]; + $datarray2["author-link"] = $person["url"]; + $datarray2["author-avatar"] = ((x($person,'thumb')) ? $person["thumb"] : $person["photo"]); + $datarray2["owner-name"] = $datarray2["author-name"]; + $datarray2["owner-link"] = $datarray2["author-link"]; + $datarray2["owner-avatar"] = $datarray2["author-avatar"]; + $datarray2["body"] = $body; + $datarray2["object"] = $object; + + DiasporaFetchGuid($datarray2); + $message_id = item_store($datarray2); + + logger("Store original item ".$orig_guid." under message id ".$message_id); + } + + DiasporaFetchGuid($datarray); + $message_id = item_store($datarray); +*/ return true; } @@ -786,8 +1316,131 @@ print_r($datarray); return true; } - private function import_status_message($importer, $data) { - return true; + private function import_status_message($importer, $data, $msg, $data2) { + + $raw_message = unxmlify($data->raw_message); + $guid = notags(unxmlify($data->guid)); + $author = notags(unxmlify($data->author)); + $public = notags(unxmlify($data->public)); + $created_at = notags(unxmlify($data->created_at)); + $provider_display_name = notags(unxmlify($data->provider_display_name)); + + foreach ($data->children() AS $name => $entry) + if (count($entry->children())) + if (!in_array($name, array("location", "photo", "poll"))) + die("Kinder: ".$name."\n"); +/* + if ($data->location) { + print_r($location); + foreach ($data->location->children() AS $fieldname => $data) + echo $fieldname." - ".$data."\n"; + die("Location!\n"); + } +*/ +/* + if ($data->photo) { + print_r($data->photo); + foreach ($data->photo->children() AS $fieldname => $data) + echo $fieldname." - ".$data."\n"; + die("Photo!\n"); + } +*/ + + if ($data->poll) { + print_r($data2); + print_r($data); + die("poll!\n"); + } + + + $contact = self::get_contact_by_handle($importer["uid"], $author); + if (!$contact) { + logger("A Contact for handle ".$author." and user ".$importer["uid"]." was not found"); + return false; + } + + if (!self::post_allow($importer, $contact, false)) { + logger("Ignoring this author."); + return false; + } +/* + $r = q("SELECT `id` FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1", + intval($importer["uid"]), + dbesc($guid) + ); + if(count($r)) { + logger("message exists: ".$guid); + return false; + } +*/ + $private = (($public == "false") ? 1 : 0); + + $body = diaspora2bb($raw_message); + + $datarray = array(); + + if($data->photo->remote_photo_path AND $data->photo->remote_photo_name) + $datarray["object-type"] = ACTIVITY_OBJ_PHOTO; + else { + $datarray["object-type"] = ACTIVITY_OBJ_NOTE; + // Add OEmbed and other information to the body + if (!self::is_redmatrix($contact["url"])) + $body = add_page_info_to_body($body, false, true); + } + + $str_tags = ""; + + $cnt = preg_match_all("/@\[url=(.*?)\[\/url\]/ism", $body, $matches, PREG_SET_ORDER); + if($cnt) { + foreach($matches as $mtch) { + if(strlen($str_tags)) + $str_tags .= ","; + $str_tags .= "@[url=".$mtch[1]."[/url]"; + } + } + $plink = self::plink($author, $guid); + + $datarray["uid"] = $importer["uid"]; + $datarray["contact-id"] = $contact["id"]; + $datarray["network"] = NETWORK_DIASPORA; + + $datarray["author-name"] = $contact["name"]; + $datarray["author-link"] = $contact["url"]; + $datarray["author-avatar"] = ((x($contact,"thumb")) ? $contact["thumb"] : $contact["photo"]); + + $datarray["owner-name"] = $datarray["author-name"]; + $datarray["owner-link"] = $datarray["author-link"]; + $datarray["owner-avatar"] = $datarray["author-avatar"]; + + $datarray["guid"] = $guid; + $datarray["uri"] = $datarray["parent-uri"] = $author.":".$guid; + + $datarray["verb"] = ACTIVITY_POST; + $datarray["gravity"] = GRAVITY_PARENT; + + $datarray["object"] = json_encode($data); + + $datarray["body"] = $body; + + $datarray["tag"] = $str_tags; + if ($provider_display_name != "") + $datarray["app"] = $provider_display_name; + + $datarray["plink"] = $plink; + $datarray["private"] = $private; + $datarray["changed"] = $datarray["created"] = $datarray["edited"] = datetime_convert("UTC", "UTC", $created_at); + + // if empty content it might be a photo that hasn't arrived yet. If a photo arrives, we'll make it visible. + + $datarray["visible"] = ((strlen($body)) ? 1 : 0); + + self::fetch_guid($datarray); + //$message_id = item_store($datarray); + print_r($datarray); + + logger("Stored item with message id ".$message_id, LOGGER_DEBUG); + + return $message_id; } } ?>