Only update contact data for OStatus contacts

[friendica.git] / include / ostatus.php

diff --git a/include/ostatus.php b/include/ostatus.php
index 53887d535b1b5d3f8bcfdc55b176b19c8a2878d8..523ccfe510e55144255fb0052dd693db7425c976 100644 (file)
--- a/include/ostatus.php
+++ b/include/ostatus.php
@@ -7,11 +7,63 @@ require_once("mod/share.php");
 require_once("include/enotify.php");
 require_once("include/socgraph.php");
 require_once("include/Photo.php");
+require_once("include/Scrape.php");
+require_once("include/follow.php");
 
 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
 
+function ostatus_check_follow_friends() {
+       $r = q("SELECT `uid`,`v` FROM `pconfig` WHERE `cat`='system' AND `k`='ostatus_legacy_contact' AND `v` != ''");
+
+       if (!$r)
+               return;
+
+       foreach ($r AS $contact) {
+               ostatus_follow_friends($contact["uid"], $contact["v"]);
+               set_pconfig($contact["uid"], "system", "ostatus_legacy_contact", "");
+       }
+}
+
+// This function doesn't work reliable by now.
+function ostatus_follow_friends($uid, $url) {
+       $contact = probe_url($url);
+
+       if (!$contact)
+               return;
+
+       $api = $contact["baseurl"]."/api/";
+
+       // Fetching friends
+       $data = z_fetch_url($api."statuses/friends.json?screen_name=".$contact["nick"]);
+
+       if (!$data["success"])
+               return;
+
+       $friends = json_decode($data["body"]);
+
+       foreach ($friends AS $friend) {
+               $url = $friend->statusnet_profile_url;
+               $r = q("SELECT `url` FROM `contact` WHERE `uid` = %d AND
+                       (`nurl` = '%s' OR `alias` = '%s' OR `alias` = '%s') AND
+                       `network` != '%s' LIMIT 1",
+                       intval($uid), dbesc(normalise_link($url)),
+                       dbesc(normalise_link($url)), dbesc($url), dbesc(NETWORK_STATUSNET));
+               if (!$r) {
+                       $data = probe_url($friend->statusnet_profile_url);
+                       if ($data["network"] == NETWORK_OSTATUS) {
+                               $result = new_contact($uid,$friend->statusnet_profile_url);
+                               if ($result["success"])
+                                       logger($friend->name." ".$url." - success", LOGGER_DEBUG);
+                               else
+                                       logger($friend->name." ".$url." - failed", LOGGER_DEBUG);
+                       } else
+                               logger($friend->name." ".$url." - not OStatus", LOGGER_DEBUG);
+               }
+       }
+}
+
 function ostatus_fetchauthor($xpath, $context, $importer, &$contact, $onlyfetch) {
 
        $author = array();
@@ -85,9 +137,9 @@ function ostatus_fetchauthor($xpath, $context, $importer, &$contact, $onlyfetch)
                        if ($value != "")
                                $contact["location"] = $value;
 
-                       q("UPDATE `contact` SET `name` = '%s', `nick` = '%s', `about` = '%s', `location` = '%s', `name-date` = '%s' WHERE `id` = %d",
+                       q("UPDATE `contact` SET `name` = '%s', `nick` = '%s', `about` = '%s', `location` = '%s', `name-date` = '%s' WHERE `id` = %d AND `network` = '%s'",
                                dbesc($contact["name"]), dbesc($contact["nick"]), dbesc($contact["about"]), dbesc($contact["location"]),
-                               dbesc(datetime_convert()), intval($contact["id"]));
+                               dbesc(datetime_convert()), intval($contact["id"]), dbesc(NETWORK_OSTATUS));
 
                        poco_check($contact["url"], $contact["name"], $contact["network"], $author["author-avatar"], $contact["about"], $contact["location"],
                                        "", "", "", datetime_convert(), 2, $contact["id"], $contact["uid"]);
@@ -100,9 +152,9 @@ function ostatus_fetchauthor($xpath, $context, $importer, &$contact, $onlyfetch)
 
                        $photos = import_profile_photo($author["author-avatar"], $importer["uid"], $contact["id"]);
 
-                       q("UPDATE `contact` SET `photo` = '%s', `thumb` = '%s', `micro` = '%s', `avatar-date` = '%s' WHERE `id` = %d",
+                       q("UPDATE `contact` SET `photo` = '%s', `thumb` = '%s', `micro` = '%s', `avatar-date` = '%s' WHERE `id` = %d AND `network` = '%s'",
                                dbesc($photos[0]), dbesc($photos[1]), dbesc($photos[2]),
-                               dbesc(datetime_convert()), intval($contact["id"]));
+                               dbesc(datetime_convert()), intval($contact["id"]), dbesc(NETWORK_OSTATUS));
                }
        }
 
@@ -239,11 +291,13 @@ function ostatus_import($xml,$importer,&$contact, &$hub) {
                // Delete a message
                if ($item["verb"] == "qvitter-delete-notice") {
                        // ignore "Delete" messages (by now)
+                       logger("Ignore delete message ".print_r($item, true));
                        continue;
                }
 
                if ($item["verb"] == ACTIVITY_JOIN) {
                        // ignore "Join" messages
+                       logger("Ignore join message ".print_r($item, true));
                        continue;
                }
 
@@ -258,10 +312,24 @@ function ostatus_import($xml,$importer,&$contact, &$hub) {
                }
 
                if ($item["verb"] == ACTIVITY_FAVORITE) {
-                       // ignore "Favorite" messages
+                       $orig_uri = $xpath->query("activity:object/atom:id", $entry)->item(0)->nodeValue;
+                       logger("Favorite ".$orig_uri." ".print_r($item, true));
+
+                       $item["verb"] = ACTIVITY_LIKE;
+                       $item["parent-uri"] = $orig_uri;
+                       $item["gravity"] = GRAVITY_LIKE;
+               }
+
+               if ($item["verb"] == NAMESPACE_OSTATUS."/unfavorite") {
+                       // Ignore "Unfavorite" message
+                       logger("Ignore unfavorite message ".print_r($item, true));
                        continue;
                }
 
+               // http://activitystrea.ms/schema/1.0/rsvp-yes
+               if (!in_array($item["verb"], array(ACTIVITY_POST, ACTIVITY_LIKE, ACTIVITY_SHARE)))
+                       logger("Unhandled verb ".$item["verb"]." ".print_r($item, true));
+
                $item["created"] = $xpath->query('atom:published/text()', $entry)->item(0)->nodeValue;
                $item["edited"] = $xpath->query('atom:updated/text()', $entry)->item(0)->nodeValue;
                $conversation = $xpath->query('ostatus:conversation/text()', $entry)->item(0)->nodeValue;
@@ -634,9 +702,13 @@ function ostatus_completion($conversation_url, $uid, $item = array()) {
                $conv_as = str_replace(',"statusnet:notice_info":', ',"statusnet_notice_info":', $conv_as);
                $conv_as = json_decode($conv_as);
 
+               $no_of_items = sizeof($items);
+
                if (@is_array($conv_as->items))
-                       $items = array_merge($items, $conv_as->items);
-               else
+                       foreach ($conv_as->items AS $single_item)
+                               $items[$single_item->id] = $single_item;
+
+               if ($no_of_items == sizeof($items))
                        break;
 
                $pageno++;