]> git.mxchange.org Git - friendica.git/commitdiff
New Diaspora code
authorMichael Vogel <icarus@dabo.de>
Sat, 27 Feb 2016 22:54:17 +0000 (23:54 +0100)
committerMichael Vogel <icarus@dabo.de>
Sat, 27 Feb 2016 22:54:17 +0000 (23:54 +0100)
include/diaspora.php
include/diaspora2.php [new file with mode: 0644]

index 93fe2a472feb47268375709fd4f771614c8e7634..9dbbeabbcffa87fa124e610c5d3b8493c92c395f 100644 (file)
@@ -58,6 +58,8 @@ function diaspora_dispatch($importer,$msg,$attempt=1) {
                return;
        }
 
+       $data = $msg;
+
        // php doesn't like dashes in variable names
 
        $msg['message'] = str_replace(
@@ -74,48 +76,83 @@ function diaspora_dispatch($importer,$msg,$attempt=1) {
 
 
        if($xmlbase->request) {
+               $tempfile = tempnam(get_temppath(), "diaspora-request");
+               file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_request($importer,$xmlbase->request);
        }
        elseif($xmlbase->status_message) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-status_message");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_post($importer,$xmlbase->status_message,$msg);
        }
        elseif($xmlbase->profile) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-profile");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_profile($importer,$xmlbase->profile,$msg);
        }
        elseif($xmlbase->comment) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-comment");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_comment($importer,$xmlbase->comment,$msg);
        }
        elseif($xmlbase->like) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-like");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_like($importer,$xmlbase->like,$msg);
        }
        elseif($xmlbase->asphoto) {
+               $tempfile = tempnam(get_temppath(), "diaspora-asphoto");
+               file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_asphoto($importer,$xmlbase->asphoto,$msg);
        }
        elseif($xmlbase->reshare) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-reshare");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_reshare($importer,$xmlbase->reshare,$msg);
        }
        elseif($xmlbase->retraction) {
+               $tempfile = tempnam(get_temppath(), "diaspora-retraction");
+               file_put_contents($tempfile, json_encode($data));
                $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));
                $ret = diaspora_signed_retraction($importer,$xmlbase->signed_retraction,$msg);
        }
        elseif($xmlbase->relayable_retraction) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-relayable_retraction");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_signed_retraction($importer,$xmlbase->relayable_retraction,$msg);
        }
        elseif($xmlbase->photo) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-photo");
+               //file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_photo($importer,$xmlbase->photo,$msg,$attempt);
        }
        elseif($xmlbase->conversation) {
+               $tempfile = tempnam(get_temppath(), "diaspora-conversation");
+               file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_conversation($importer,$xmlbase->conversation,$msg);
        }
        elseif($xmlbase->message) {
+               $tempfile = tempnam(get_temppath(), "diaspora-message");
+               file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_message($importer,$xmlbase->message,$msg);
        }
        elseif($xmlbase->participation) {
+               //$tempfile = tempnam(get_temppath(), "diaspora-participation");
+               //file_put_contents($tempfile, json_encode($data));
+               $ret = diaspora_participation($importer,$xmlbase->participation);
+       }
+       elseif($xmlbase->poll_participation) {
+               $tempfile = tempnam(get_temppath(), "diaspora-poll_participation");
+               file_put_contents($tempfile, json_encode($data));
                $ret = diaspora_participation($importer,$xmlbase->participation);
        }
        else {
+               $tempfile = tempnam(get_temppath(), "diaspora-unknown");
+               file_put_contents($tempfile, json_encode($data));
                logger('diaspora_dispatch: unknown message type: ' . print_r($xmlbase,true));
        }
        return $ret;
diff --git a/include/diaspora2.php b/include/diaspora2.php
new file mode 100644 (file)
index 0000000..690e54a
--- /dev/null
@@ -0,0 +1,638 @@
+<?php
+/**
+ * @file include/diaspora.php
+ * @brief The implementation of the diaspora protocol
+ */
+
+require_once("include/diaspora.php");
+require_once("include/Scrape.php");
+
+function array_to_xml($array, &$xml) {
+
+       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();
+               }
+       }
+
+       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));
+       }
+}
+
+/**
+ * @brief This class contain functions to create and send DFRN XML files
+ *
+ */
+class diaspora {
+
+       public static function dispatch_public($msg) {
+
+               $enabled = intval(get_config("system", "diaspora_enabled"));
+               if (!$enabled) {
+                       logger('diaspora is disabled');
+                       return false;
+               }
+
+               // Use a dummy importer to import the data for the public copy
+               $importer = array("uid" => 0, "page-flags" => PAGE_FREELOVE);
+               self::dispatch($importer,$msg);
+
+               // Now distribute it to the followers
+               $r = q("SELECT `user`.* FROM `user` WHERE `user`.`uid` IN
+                       (SELECT `contact`.`uid` FROM `contact` WHERE `contact`.`network` = '%s' AND `contact`.`addr` = '%s')
+                       AND NOT `account_expired` AND NOT `account_removed`",
+                       dbesc(NETWORK_DIASPORA),
+                       dbesc($msg["author"])
+               );
+               if(count($r)) {
+                       foreach($r as $rr) {
+                               logger("delivering to: ".$rr["username"]);
+                               self::dispatch($rr,$msg);
+                       }
+               } else
+                       logger("No subscribers for ".$msg["author"]." ".print_r($msg, true));
+       }
+
+       public static function dispatch($importer, $msg) {
+
+               // The sender is the handle of the contact that sent the message.
+               // This will often be different with relayed messages (for example "like" and "comment")
+               $sender = $msg->author;
+
+               if (!diaspora::valid_posting($msg, $fields)) {
+                       logger("Invalid posting");
+                       return false;
+               }
+
+               $type = $fields->getName();
+
+               switch ($type) {
+                       case "account_deletion":
+                               return self::import_account_deletion($importer, $fields);
+
+                       case "comment":
+                               return self::import_comment($importer, $sender, $fields);
+
+                       case "conversation":
+                               return self::import_conversation($importer, $fields);
+
+                       case "like":
+                               return self::import_like($importer, $sender, $fields);
+
+                       case "message":
+                               return self::import_message($importer, $fields);
+
+                       case "participation":
+                               return self::import_participation($importer, $fields);
+
+                       case "photo":
+                               return self::import_photo($importer, $fields);
+
+                       case "poll_participation":
+                               return self::import_poll_participation($importer, $fields);
+
+                       case "profile":
+                               return self::import_profile($importer, $fields);
+
+                       case "request":
+                               return self::import_request($importer, $fields);
+
+                       case "reshare":
+                               return self::import_reshare($importer, $fields);
+
+                       case "retraction":
+                               return self::import_retraction($importer, $fields);
+
+                       case "status_message":
+                               return self::import_status_message($importer, $fields);
+
+                       default:
+                               logger("Unknown message type ".$type);
+                               return false;
+               }
+
+               return true;
+       }
+
+       /**
+        * @brief Checks if a posting is valid and fetches the data fields.
+        *
+        * This function does not only check the signature.
+        * 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
+        *
+        * @return bool Is the posting valid?
+        */
+       private function valid_posting($msg, &$fields) {
+
+               $data = parse_xml_string($msg->message, false);
+
+               $first_child = $data->getName();
+
+               if ($data->getName() == "XML") {
+                       $oldXML = true;
+                       foreach ($data->post->children() as $child)
+                               $element = $child;
+               } else {
+                       $oldXML = false;
+                       $element = $data;
+               }
+
+               $type = $element->getName();
+
+               if (in_array($type, array("signed_retraction", "relayable_retraction")))
+                       $type = "retraction";
+
+               $fields = new SimpleXMLElement("<".$type."/>");
+
+               $signed_data = "";
+
+               foreach ($element->children() AS $fieldname => $data) {
+
+                       if ($oldXML) {
+                               // Translation for the old XML structure
+                               if ($fieldname == "diaspora_handle")
+                                       $fieldname = "author";
+
+                               if ($fieldname == "participant_handles")
+                                       $fieldname = "participants";
+
+                               if (in_array($type, array("like", "participation"))) {
+                                       if ($fieldname == "target_type")
+                                               $fieldname = "parent_type";
+                               }
+
+                               if ($fieldname == "sender_handle")
+                                       $fieldname = "author";
+
+                               if ($fieldname == "recipient_handle")
+                                       $fieldname = "recipient";
+
+                               if ($fieldname == "root_diaspora_id")
+                                       $fieldname = "root_author";
+
+                               if ($type == "retraction") {
+                                       if ($fieldname == "post_guid")
+                                               $fieldname = "target_guid";
+
+                                       if ($fieldname == "type")
+                                               $fieldname = "target_type";
+                               }
+                       }
+
+                       if ($fieldname == "author_signature")
+                               $author_signature = base64_decode($data);
+                       elseif ($fieldname == "parent_author_signature")
+                               $parent_author_signature = base64_decode($data);
+                       elseif ($fieldname != "target_author_signature") {
+                               if ($signed_data != "") {
+                                       $signed_data .= ";";
+                                       $signed_data_parent .= ";";
+                               }
+
+                               $signed_data .= $data;
+                               $fields->$fieldname = $data;
+                       }
+               }
+
+               if (in_array($type, array("status_message", "reshare")))
+                       if ($msg->author != $fields->author) {
+                               logger("Message handle is not the same as envelope sender. Quitting this message.");
+                               return false;
+                       }
+
+               if (!in_array($type, array("comment", "conversation", "message", "like")))
+                       return true;
+
+               if (!isset($author_signature))
+                       return false;
+
+               if (isset($parent_author_signature)) {
+                       $key = self::get_key($msg->author);
+
+                       if (!rsa_verify($signed_data, $parent_author_signature, $key, "sha256"))
+                               return false;
+               }
+
+               $key = self::get_key($fields->author);
+
+               return rsa_verify($signed_data, $author_signature, $key, "sha256");
+       }
+
+       private function get_key($handle) {
+               logger("Fetching diaspora key for: ".$handle);
+
+               $r = self::get_person_by_handle($handle);
+               if($r)
+                       return $r["pubkey"];
+
+               return "";
+       }
+
+       private function get_person_by_handle($handle) {
+
+               $r = q("SELECT * FROM `fcontact` WHERE `network` = '%s' AND `addr` = '%s' LIMIT 1",
+                       dbesc(NETWORK_DIASPORA),
+                       dbesc($handle)
+               );
+               if (count($r)) {
+                       $person = $r[0];
+                       logger("In cache ".print_r($r,true), LOGGER_DEBUG);
+
+                       // update record occasionally so it doesn't get stale
+                       $d = strtotime($person["updated"]." +00:00");
+                       if ($d < strtotime("now - 14 days"))
+                               $update = true;
+               }
+
+               if (!$person OR $update) {
+                       logger("create or refresh", LOGGER_DEBUG);
+                       $r = probe_url($handle, PROBE_DIASPORA);
+
+                       // Note that Friendica contacts will return a "Diaspora person"
+                       // if Diaspora connectivity is enabled on their server
+                       if (count($r) AND ($r["network"] === NETWORK_DIASPORA)) {
+                               self::add_fcontact($r, $update);
+                               $person = $r;
+                       }
+               }
+               return $person;
+       }
+
+       private function add_fcontact($arr, $update = false) {
+               /// @todo Remove this function from include/network.php
+
+               if($update) {
+                       $r = q("UPDATE `fcontact` SET
+                                       `name` = '%s',
+                                       `photo` = '%s',
+                                       `request` = '%s',
+                                       `nick` = '%s',
+                                       `addr` = '%s',
+                                       `batch` = '%s',
+                                       `notify` = '%s',
+                                       `poll` = '%s',
+                                       `confirm` = '%s',
+                                       `alias` = '%s',
+                                       `pubkey` = '%s',
+                                       `updated` = '%s'
+                               WHERE `url` = '%s' AND `network` = '%s'",
+                                       dbesc($arr["name"]),
+                                       dbesc($arr["photo"]),
+                                       dbesc($arr["request"]),
+                                       dbesc($arr["nick"]),
+                                       dbesc($arr["addr"]),
+                                       dbesc($arr["batch"]),
+                                       dbesc($arr["notify"]),
+                                       dbesc($arr["poll"]),
+                                       dbesc($arr["confirm"]),
+                                       dbesc($arr["alias"]),
+                                       dbesc($arr["pubkey"]),
+                                       dbesc(datetime_convert()),
+                                       dbesc($arr["url"]),
+                                       dbesc($arr["network"])
+                               );
+               } else {
+                       $r = q("INSERT INTO `fcontact` (`url`,`name`,`photo`,`request`,`nick`,`addr`,
+                                       `batch`, `notify`,`poll`,`confirm`,`network`,`alias`,`pubkey`,`updated`)
+                               VALUES ('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
+                                       dbesc($arr["url"]),
+                                       dbesc($arr["name"]),
+                                       dbesc($arr["photo"]),
+                                       dbesc($arr["request"]),
+                                       dbesc($arr["nick"]),
+                                       dbesc($arr["addr"]),
+                                       dbesc($arr["batch"]),
+                                       dbesc($arr["notify"]),
+                                       dbesc($arr["poll"]),
+                                       dbesc($arr["confirm"]),
+                                       dbesc($arr["network"]),
+                                       dbesc($arr["alias"]),
+                                       dbesc($arr["pubkey"]),
+                                       dbesc(datetime_convert())
+                               );
+               }
+
+               return $r;
+       }
+
+       private function get_contact_by_handle($uid, $handle) {
+               $r = q("SELECT * FROM `contact` WHERE `uid` = %d AND `addr` = '%s' LIMIT 1",
+                       intval($uid),
+                       dbesc($handle)
+               );
+
+               if ($r AND count($r))
+                       return $r[0];
+
+               $handle_parts = explode("@", $handle);
+               $nurl_sql = '%%://' . $handle_parts[1] . '%%/profile/' . $handle_parts[0];
+               $r = q("SELECT * FROM `contact` WHERE `network` = '%s' AND `uid` = %d AND `nurl` LIKE '%s' LIMIT 1",
+                       dbesc(NETWORK_DFRN),
+                       intval($uid),
+                       dbesc($nurl_sql)
+               );
+               if($r AND count($r))
+                       return $r[0];
+
+               return false;
+       }
+
+/*
+function DiasporaFetchGuid($item) {
+        preg_replace_callback("&\[url=/posts/([^\[\]]*)\](.*)\[\/url\]&Usi",
+                function ($match) use ($item){
+                        return(DiasporaFetchGuidSub($match, $item));
+                },$item["body"]);
+}
+
+function DiasporaFetchGuidSub($match, $item) {
+        $a = get_app();
+
+        if (!diaspora_store_by_guid($match[1], $item["author-link"]))
+                diaspora_store_by_guid($match[1], $item["owner-link"]);
+}
+
+function diaspora_store_by_guid($guid, $server, $uid = 0) {
+        require_once("include/Contact.php");
+
+        $serverparts = parse_url($server);
+        $server = $serverparts["scheme"]."://".$serverparts["host"];
+
+        logger("Trying to fetch item ".$guid." from ".$server, LOGGER_DEBUG);
+
+        $item = diaspora_fetch_message($guid, $server);
+
+        if (!$item)
+                return false;
+
+        logger("Successfully fetched item ".$guid." from ".$server, LOGGER_DEBUG);
+
+        $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"];
+
+        $message_id = $author.':'.$guid;
+        $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"];
+
+        $person = find_diaspora_person_by_handle($author);
+
+        $contact_id = get_contact($person['url'], $uid);
+
+        $contacts = q("SELECT * FROM `contact` WHERE `id` = %d", intval($contact_id));
+        $importers = q("SELECT * FROM `user` WHERE `uid` = %d", intval($uid));
+
+        if ($contacts AND $importers)
+                if(!diaspora_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);
+
+        $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'] = $message_id;
+        $datarray['changed'] = $datarray['created'] = $datarray['edited'] = datetime_convert('UTC','UTC',$created);
+        $datarray['private'] = $private;
+        $datarray['parent'] = 0;
+        $datarray['plink'] = diaspora_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;
+
+        if ($datarray['contact-id'] == 0)
+                return false;
+
+        DiasporaFetchGuid($datarray);
+        $message_id = item_store($datarray);
+
+        /// @TODO
+        /// Looking if there is some subscribe mechanism in Diaspora to get all comments for this post
+
+        return $message_id;
+}
+*/
+
+       private function import_account_deletion($importer, $data) {
+               return true;
+       }
+
+       private function import_comment($importer, $sender, $data) {
+               $guid = notags(unxmlify($data->guid));
+               $parent_guid = notags(unxmlify($data->parent_guid));
+               $text = unxmlify($data->text);
+               $author = notags(unxmlify($data->author));
+
+               $contact = self::get_contact_by_handle($importer["uid"], $sender);
+               if (!$contact) {
+                       logger("cannot find contact for sender: ".$sender);
+                       return false;
+               }
+/*
+        if(! diaspora_post_allow($importer,$contact, true)) {
+                logger('diaspora_comment: Ignoring this author.');
+                return 202;
+        }
+
+        $r = q("SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1",
+                intval($importer['uid']),
+                dbesc($guid)
+        );
+        if(count($r)) {
+                logger('diaspora_comment: our comment just got relayed back to us (or there was a guid collision) : ' . $guid);
+                return;
+        }
+
+        $r = q("SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1",
+                intval($importer['uid']),
+                dbesc($parent_guid)
+        );
+
+        if(!count($r)) {
+                $result = diaspora_store_by_guid($parent_guid, $contact['url'], $importer['uid']);
+
+                if (!$result) {
+                        $person = find_diaspora_person_by_handle($diaspora_handle);
+                        $result = diaspora_store_by_guid($parent_guid, $person['url'], $importer['uid']);
+                }
+
+                if ($result) {
+                        logger("Fetched missing item ".$parent_guid." - result: ".$result, LOGGER_DEBUG);
+
+                        $r = q("SELECT * FROM `item` WHERE `uid` = %d AND `guid` = '%s' LIMIT 1",
+                                intval($importer['uid']),
+                                dbesc($parent_guid)
+                        );
+                }
+        }
+
+        if(! count($r)) {
+                logger('diaspora_comment: parent item not found: parent: ' . $parent_guid . ' item: ' . $guid);
+                return;
+        }
+        $parent_item = $r[0];
+
+        // Find the original comment author information.
+        // We need this to make sure we display the comment author
+        // information (name and avatar) correctly.
+        if(strcasecmp($diaspora_handle,$msg['author']) == 0)
+                $person = $contact;
+        else {
+                $person = find_diaspora_person_by_handle($diaspora_handle);
+
+                if(! is_array($person)) {
+                        logger('diaspora_comment: unable to find author details');
+                        return;
+                }
+        }
+
+        // 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);
+        $message_id = $diaspora_handle . ':' . $guid;
+
+        $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'] = $message_id;
+        $datarray['parent-uri'] = $parent_item['uri'];
+
+        // No timestamps for comments? OK, we'll the use current time.
+        $datarray['changed'] = $datarray['created'] = $datarray['edited'] = datetime_convert();
+        $datarray['private'] = $parent_item['private'];
+
+        $datarray['owner-name'] = $parent_item['owner-name'];
+        $datarray['owner-link'] = $parent_item['owner-link'];
+        $datarray['owner-avatar'] = $parent_item['owner-avatar'];
+
+        $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($xml);
+        $datarray["object-type"] = ACTIVITY_OBJ_COMMENT;
+
+        // We can't be certain what the original app is if the message is relayed.
+        if(($parent_item['origin']) && (! $parent_author_signature))
+                $datarray['app']  = 'Diaspora';
+
+        DiasporaFetchGuid($datarray);
+        $message_id = item_store($datarray);
+
+        $datarray['id'] = $message_id;
+
+        // If we are the origin of the parent we store the original signature and notify our followers
+        if($parent_item['origin']) {
+                $author_signature_base64 = base64_encode($author_signature);
+                $author_signature_base64 = diaspora_repair_signature($author_signature_base64, $diaspora_handle);
+
+                q("insert into sign (`iid`,`signed_text`,`signature`,`signer`) values (%d,'%s','%s','%s') ",
+                        intval($message_id),
+                        dbesc($signed_data),
+                        dbesc($author_signature_base64),
+                        dbesc($diaspora_handle)
+                );
+
+                // notify others
+                proc_run('php','include/notifier.php','comment-import',$message_id);
+        }
+*/
+               return true;
+       }
+
+       private function import_conversation($importer, $data) {
+               return true;
+       }
+
+       private function import_like($importer, $sender, $data) {
+               return true;
+       }
+
+       private function import_message($importer, $data) {
+               return true;
+       }
+
+       private function import_participation($importer, $data) {
+               return true;
+       }
+
+       private function import_photo($importer, $data) {
+               return true;
+       }
+
+       private function import_poll_participation($importer, $data) {
+               return true;
+       }
+
+       private function import_profile($importer, $data) {
+               return true;
+       }
+
+       private function import_request($importer, $data) {
+               return true;
+       }
+
+       private function import_reshare($importer, $data) {
+               return true;
+       }
+
+       private function import_retraction($importer, $data) {
+               return true;
+       }
+
+       private function import_status_message($importer, $data) {
+               return true;
+       }
+}
+?>