]> git.mxchange.org Git - friendica.git/blobdiff - include/socgraph.php
projects / friendica.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Class file relocations
[friendica.git] / include / socgraph.php
diff --git a/include/socgraph.php b/include/socgraph.php
index f0a855d70c9d91412bca5c480af4a5a5b2055f18..e1c0e13856883ffac254795ac6c820ce136d084d 100644 (file)
--- a/include/socgraph.php
+++ b/include/socgraph.php
@@ -10,10 +10,11 @@
 use Friendica\App;
 use Friendica\Core\System;
 use Friendica\Core\Config;
+use Friendica\Core\Worker;
+use Friendica\Database\DBM;
 use Friendica\Network\Probe;
 
 require_once 'include/datetime.php';
-require_once 'include/probe.php';
 require_once 'include/network.php';
 require_once 'include/html2bbcode.php';
 require_once 'include/Contact.php';
@@ -39,7 +40,7 @@ require_once 'include/Photo.php';
  */
 function poco_load($cid, $uid = 0, $zcid = 0, $url = null) {
        // Call the function "poco_load_worker" via the worker
-       proc_run(PRIORITY_LOW, "include/discover_poco.php", "poco_load", (int)$cid, (int)$uid, (int)$zcid, $url);
+       Worker::add(PRIORITY_LOW, "discover_poco", "poco_load", (int)$cid, (int)$uid, (int)$zcid, $url);
 }
 
 /**
@@ -59,7 +60,7 @@ function poco_load_worker($cid, $uid, $zcid, $url) {
                        $r = q("select `poco`, `uid` from `contact` where `id` = %d limit 1",
                                intval($cid)
                        );
-                       if (dbm::is_result($r)) {
+                       if (DBM::is_result($r)) {
                                $url = $r[0]['poco'];
                                $uid = $r[0]['uid'];
                        }
@@ -252,7 +253,7 @@ function sanitize_gcontact($gcontact) {
                $r = q("SELECT `network` FROM `contact` WHERE `uid` = 0 AND `nurl` = '%s' AND `network` != '' AND `network` != '%s' LIMIT 1",
                        dbesc(normalise_link($gcontact['url'])), dbesc(NETWORK_STATUSNET)
                );
-               if (dbm::is_result($r)) {
+               if (DBM::is_result($r)) {
                        $gcontact['network'] = $r[0]["network"];
                }
 
@@ -260,7 +261,7 @@ function sanitize_gcontact($gcontact) {
                        $r = q("SELECT `network`, `url` FROM `contact` WHERE `uid` = 0 AND `alias` IN ('%s', '%s') AND `network` != '' AND `network` != '%s' LIMIT 1",
                                dbesc($gcontact['url']), dbesc(normalise_link($gcontact['url'])), dbesc(NETWORK_STATUSNET)
                        );
-                       if (dbm::is_result($r)) {
+                       if (DBM::is_result($r)) {
                                $gcontact['network'] = $r[0]["network"];
                        }
                }
@@ -273,7 +274,7 @@ function sanitize_gcontact($gcontact) {
                dbesc(normalise_link($gcontact['url']))
        );
 
-       if (dbm::is_result($x)) {
+       if (DBM::is_result($x)) {
                if (!isset($gcontact['network']) && ($x[0]["network"] != NETWORK_STATUSNET)) {
                        $gcontact['network'] = $x[0]["network"];
                }
@@ -305,7 +306,7 @@ function sanitize_gcontact($gcontact) {
                if ($alternate && ($gcontact['network'] == NETWORK_OSTATUS)) {
                        // Delete the old entry - if it exists
                        $r = q("SELECT `id` FROM `gcontact` WHERE `nurl` = '%s'", dbesc(normalise_link($orig_profile)));
-                       if (dbm::is_result($r)) {
+                       if (DBM::is_result($r)) {
                                q("DELETE FROM `gcontact` WHERE `nurl` = '%s'", dbesc(normalise_link($orig_profile)));
                                q("DELETE FROM `glink` WHERE `gcid` = %d", intval($r[0]["id"]));
                        }
@@ -360,7 +361,7 @@ function link_gcontact($gcid, $uid = 0, $cid = 0, $zcid = 0) {
                intval($zcid)
        );
 
-       if (!dbm::is_result($r)) {
+       if (!DBM::is_result($r)) {
                q("INSERT INTO `glink` (`cid`, `uid`, `gcid`, `zcid`, `updated`) VALUES (%d, %d, %d, %d, '%s') ",
                        intval($cid),
                        intval($uid),
@@ -454,7 +455,7 @@ function poco_detect_server($profile) {
 
        $r = q("SELECT `id` FROM `gserver` WHERE `nurl` = '%s' AND `last_contact` > `last_failure`",
                dbesc(normalise_link($server_url)));
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                return $server_url;
        }
 
@@ -476,7 +477,7 @@ function poco_last_updated($profile, $force = false) {
        $gcontacts = q("SELECT * FROM `gcontact` WHERE `nurl` = '%s'",
                        dbesc(normalise_link($profile)));
 
-       if (!dbm::is_result($gcontacts)) {
+       if (!DBM::is_result($gcontacts)) {
                return false;
        }
 
@@ -688,7 +689,7 @@ function poco_last_updated($profile, $force = false) {
                }
        }
        q("UPDATE `gcontact` SET `updated` = '%s', `last_contact` = '%s' WHERE `nurl` = '%s'",
-               dbesc(dbm::date($last_updated)), dbesc(dbm::date()), dbesc(normalise_link($profile)));
+               dbesc(DBM::date($last_updated)), dbesc(DBM::date()), dbesc(normalise_link($profile)));
 
        if (($gcontacts[0]["generation"] == 0)) {
                q("UPDATE `gcontact` SET `generation` = 9 WHERE `nurl` = '%s'",
@@ -970,7 +971,7 @@ function poco_check_server($server_url, $network = "", $force = false) {
        }
 
        $servers = q("SELECT * FROM `gserver` WHERE `nurl` = '%s'", dbesc(normalise_link($server_url)));
-       if (dbm::is_result($servers)) {
+       if (DBM::is_result($servers)) {
 
                if ($servers[0]["created"] <= NULL_DATE) {
                        q("UPDATE `gserver` SET `created` = '%s' WHERE `nurl` = '%s'",
@@ -1023,7 +1024,7 @@ function poco_check_server($server_url, $network = "", $force = false) {
 
        // Quit if there is a timeout.
        // But we want to make sure to only quit if we are mostly sure that this server url fits.
-       if (dbm::is_result($servers) && ($orig_server_url == $server_url) &&
+       if (DBM::is_result($servers) && ($orig_server_url == $server_url) &&
                ($serverret['errno'] == CURLE_OPERATION_TIMEDOUT)) {
                logger("Connection to server ".$server_url." timed out.", LOGGER_DEBUG);
                dba::update('gserver', array('last_failure' => datetime_convert()), array('nurl' => normalise_link($server_url)));
@@ -1417,7 +1418,7 @@ function count_common_friends($uid, $cid) {
        );
 
        // logger("count_common_friends: $uid $cid {$r[0]['total']}");
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                return $r[0]['total'];
        }
        return 0;
@@ -1450,7 +1451,7 @@ function common_friends($uid, $cid, $start = 0, $limit = 9999, $shuffle = false)
                intval($limit)
        );
 
-       /// @TODO Check all calling-findings of this function if they properly use dbm::is_result()
+       /// @TODO Check all calling-findings of this function if they properly use DBM::is_result()
        return $r;
 
 }
@@ -1466,7 +1467,7 @@ function count_common_friends_zcid($uid, $zcid) {
                intval($uid)
        );
 
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                return $r[0]['total'];
        }
        return 0;
@@ -1492,7 +1493,7 @@ function common_friends_zcid($uid, $zcid, $start = 0, $limit = 9999, $shuffle =
                intval($limit)
        );
 
-       /// @TODO Check all calling-findings of this function if they properly use dbm::is_result()
+       /// @TODO Check all calling-findings of this function if they properly use DBM::is_result()
        return $r;
 
 }
@@ -1508,7 +1509,7 @@ function count_all_friends($uid, $cid) {
                intval($uid)
        );
 
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                return $r[0]['total'];
        }
        return 0;
@@ -1532,7 +1533,7 @@ function all_friends($uid, $cid, $start = 0, $limit = 80) {
                intval($limit)
        );
 
-       /// @TODO Check all calling-findings of this function if they properly use dbm::is_result()
+       /// @TODO Check all calling-findings of this function if they properly use DBM::is_result()
        return $r;
 }
 
@@ -1555,11 +1556,11 @@ function suggestion_query($uid, $start = 0, $limit = 80) {
 
        $network = array(NETWORK_DFRN);
 
-       if (get_config('system','diaspora_enabled')) {
+       if (Config::get('system','diaspora_enabled')) {
                $network[] = NETWORK_DIASPORA;
        }
 
-       if (!get_config('system','ostatus_disabled')) {
+       if (!Config::get('system','ostatus_disabled')) {
                $network[] = NETWORK_OSTATUS;
        }
 
@@ -1587,7 +1588,7 @@ function suggestion_query($uid, $start = 0, $limit = 80) {
                intval($limit)
        );
 
-       if (dbm::is_result($r) && count($r) >= ($limit -1)) {
+       if (DBM::is_result($r) && count($r) >= ($limit -1)) {
                /*
                 * Uncommented because the result of the queries are to big to store it in the cache.
                 * We need to decide if we want to change the db column type or if we want to delete it.
@@ -1647,7 +1648,7 @@ function update_suggestions() {
 
        $done[] = System::baseUrl() . '/poco';
 
-       if (strlen(get_config('system','directory'))) {
+       if (strlen(Config::get('system','directory'))) {
                $x = fetch_url(get_server()."/pubsites");
                if ($x) {
                        $j = json_decode($x);
@@ -1670,7 +1671,7 @@ function update_suggestions() {
                dbesc(NETWORK_DFRN), dbesc(NETWORK_DIASPORA)
        );
 
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                foreach ($r as $rr) {
                        $base = substr($rr['poco'],0,strrpos($rr['poco'],'/'));
                        if (! in_array($base,$done)) {
@@ -1700,15 +1701,15 @@ function poco_fetch_serverlist($poco) {
                $server_url = str_replace("/index.php", "", $server->url);
 
                $r = q("SELECT `nurl` FROM `gserver` WHERE `nurl` = '%s'", dbesc(normalise_link($server_url)));
-               if (!dbm::is_result($r)) {
+               if (!DBM::is_result($r)) {
                        logger("Call server check for server ".$server_url, LOGGER_DEBUG);
-                       proc_run(PRIORITY_LOW, "include/discover_poco.php", "server", $server_url);
+                       Worker::add(PRIORITY_LOW, "discover_poco", "server", $server_url);
                }
        }
 }
 
 function poco_discover_federation() {
-       $last = get_config('poco','last_federation_discovery');
+       $last = Config::get('poco','last_federation_discovery');
 
        if ($last) {
                $next = $last + (24 * 60 * 60);
@@ -1724,7 +1725,7 @@ function poco_discover_federation() {
                $servers = json_decode($serverdata);
 
                foreach ($servers->pods as $server) {
-                       proc_run(PRIORITY_LOW, "include/discover_poco.php", "server", "https://".$server->host);
+                       Worker::add(PRIORITY_LOW, "discover_poco", "server", "https://".$server->host);
                }
        }
 
@@ -1737,7 +1738,7 @@ function poco_discover_federation() {
 
                        foreach ($servers as $server) {
                                $url = (is_null($server->https_score) ? 'http' : 'https').'://'.$server->name;
-                               proc_run(PRIORITY_LOW, "include/discover_poco.php", "server", $url);
+                               Worker::add(PRIORITY_LOW, "discover_poco", "server", $url);
                        }
                }
        }
@@ -1745,7 +1746,7 @@ function poco_discover_federation() {
        // Currently disabled, since the service isn't available anymore.
        // It is not removed since I hope that there will be a successor.
        // Discover GNU Social Servers.
-       //if (!get_config('system','ostatus_disabled')) {
+       //if (!Config::get('system','ostatus_disabled')) {
        //      $serverdata = "http://gstools.org/api/get_open_instances/";
 
        //      $result = z_fetch_url($serverdata);
@@ -1757,12 +1758,12 @@ function poco_discover_federation() {
        //      }
        //}
 
-       set_config('poco','last_federation_discovery', time());
+       Config::set('poco','last_federation_discovery', time());
 }
 
 function poco_discover_single_server($id) {
        $r = q("SELECT `poco`, `nurl`, `url`, `network` FROM `gserver` WHERE `id` = %d", intval($id));
-       if (!dbm::is_result($r)) {
+       if (!DBM::is_result($r)) {
                return false;
        }
 
@@ -1782,9 +1783,9 @@ function poco_discover_single_server($id) {
 
                poco_discover_server($data, 2);
 
-               if (get_config('system','poco_discovery') > 1) {
+               if (Config::get('system','poco_discovery') > 1) {
 
-                       $timeframe = get_config('system','poco_discovery_since');
+                       $timeframe = Config::get('system','poco_discovery_since');
                        if ($timeframe == 0) {
                                $timeframe = 30;
                        }
@@ -1802,7 +1803,7 @@ function poco_discover_single_server($id) {
                                $success = poco_discover_server(json_decode($retdata["body"]));
                        }
 
-                       if (!$success && (get_config('system','poco_discovery') > 2)) {
+                       if (!$success && (Config::get('system','poco_discovery') > 2)) {
                                logger("Fetch contacts from users of the server ".$server["nurl"], LOGGER_DEBUG);
                                poco_discover_server_users($data, $server);
                        }
@@ -1829,7 +1830,7 @@ function poco_discover($complete = false) {
 
        $no_of_queries = 5;
 
-       $requery_days = intval(get_config("system", "poco_requery_days"));
+       $requery_days = intval(Config::get("system", "poco_requery_days"));
 
        if ($requery_days == 0) {
                $requery_days = 7;
@@ -1837,7 +1838,7 @@ function poco_discover($complete = false) {
        $last_update = date("c", time() - (60 * 60 * 24 * $requery_days));
 
        $r = q("SELECT `id`, `url`, `network` FROM `gserver` WHERE `last_contact` >= `last_failure` AND `poco` != '' AND `last_poco_query` < '%s' ORDER BY RAND()", dbesc($last_update));
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                foreach ($r as $server) {
 
                        if (!poco_check_server($server["url"], $server["network"])) {
@@ -1847,7 +1848,7 @@ function poco_discover($complete = false) {
                        }
 
                        logger('Update directory from server '.$server['url'].' with ID '.$server['id'], LOGGER_DEBUG);
-                       proc_run(PRIORITY_LOW, "include/discover_poco.php", "update_server_directory", (int)$server['id']);
+                       Worker::add(PRIORITY_LOW, "discover_poco", "update_server_directory", (int)$server['id']);
 
                        if (!$complete && (--$no_of_queries == 0)) {
                                break;
@@ -2035,7 +2036,7 @@ function clean_contact_url($url) {
  */
 function fix_alternate_contact_address(&$contact) {
        if (($contact["network"] == NETWORK_OSTATUS) && poco_alternate_ostatus_url($contact["url"])) {
-               $data = probe_url($contact["url"]);
+               $data = Probe::uri($contact["url"]);
                if ($contact["network"] == NETWORK_OSTATUS) {
                        logger("Fix primary url from ".$contact["url"]." to ".$data["url"]." - Called by: ".System::callstack(), LOGGER_DEBUG);
                        $contact["url"] = $data["url"];
@@ -2083,7 +2084,7 @@ function get_gcontact_id($contact) {
        $r = q("SELECT `id`, `last_contact`, `last_failure`, `network` FROM `gcontact` WHERE `nurl` = '%s' LIMIT 1",
                dbesc(normalise_link($contact["url"])));
 
-       if (dbm::is_result($r)) {
+       if (DBM::is_result($r)) {
                $gcontact_id = $r[0]["id"];
 
                // Update every 90 days
@@ -2115,7 +2116,7 @@ function get_gcontact_id($contact) {
                $r = q("SELECT `id`, `network` FROM `gcontact` WHERE `nurl` = '%s' ORDER BY `id` LIMIT 2",
                        dbesc(normalise_link($contact["url"])));
 
-               if (dbm::is_result($r)) {
+               if (DBM::is_result($r)) {
                        $gcontact_id = $r[0]["id"];
 
                        $doprobing = in_array($r[0]["network"], array(NETWORK_DFRN, NETWORK_DIASPORA, NETWORK_OSTATUS, ""));
@@ -2125,7 +2126,7 @@ function get_gcontact_id($contact) {
 
        if ($doprobing) {
                logger("Last Contact: ". $last_contact_str." - Last Failure: ".$last_failure_str." - Checking: ".$contact["url"], LOGGER_DEBUG);
-               proc_run(PRIORITY_LOW, 'include/gprobe.php', $contact["url"]);
+               Worker::add(PRIORITY_LOW, 'gprobe', $contact["url"]);
        }
 
        return $gcontact_id;
@@ -2198,7 +2199,7 @@ function update_gcontact($contact) {
        fix_alternate_contact_address($contact);
 
        if (!isset($contact["updated"])) {
-               $contact["updated"] = dbm::date();
+               $contact["updated"] = DBM::date();
        }
 
        if ($contact["network"] == NETWORK_TWITTER) {
@@ -2241,7 +2242,7 @@ function update_gcontact($contact) {
                logger("Update gcontact for ".$contact["url"], LOGGER_DEBUG);
                $condition = array('`nurl` = ? AND (`generation` = 0 OR `generation` >= ?)',
                                normalise_link($contact["url"]), $contact["generation"]);
-               $contact["updated"] = dbm::date($contact["updated"]);
+               $contact["updated"] = DBM::date($contact["updated"]);
 
                $updated = array('photo' => $contact['photo'], 'name' => $contact['name'],
                                'nick' => $contact['nick'], 'addr' => $contact['addr'],
@@ -2261,7 +2262,7 @@ function update_gcontact($contact) {
                $r = q("SELECT `id` FROM `contact` WHERE `nurl` = '%s' AND `uid` = 0 ORDER BY `id` LIMIT 1",
                        dbesc(normalise_link($contact["url"])));
 
-               if (dbm::is_result($r)) {
+               if (DBM::is_result($r)) {
                        logger("Update public contact ".$r[0]["id"], LOGGER_DEBUG);
 
                        update_contact_avatar($contact["photo"], 0, $r[0]["id"]);
@@ -2293,7 +2294,7 @@ function update_gcontact($contact) {
  * @param str $url profile link
  */
 function update_gcontact_from_probe($url) {
-       $data = probe_url($url);
+       $data = Probe::uri($url);
 
        if (in_array($data["network"], array(NETWORK_PHANTOM))) {
                logger("Invalid network for contact url ".$data["url"]." - Called by: ".System::callstack(), LOGGER_DEBUG);
@@ -2409,14 +2410,14 @@ function gs_fetch_users($server) {
  */
 function gs_discover() {
 
-       $requery_days = intval(get_config("system", "poco_requery_days"));
+       $requery_days = intval(Config::get("system", "poco_requery_days"));
 
        $last_update = date("c", time() - (60 * 60 * 24 * $requery_days));
 
        $r = q("SELECT `nurl`, `url` FROM `gserver` WHERE `last_contact` >= `last_failure` AND `network` = '%s' AND `last_poco_query` < '%s' ORDER BY RAND() LIMIT 5",
                dbesc(NETWORK_OSTATUS), dbesc($last_update));
 
-       if (!dbm::is_result($r)) {
+       if (!DBM::is_result($r)) {
                return;
        }
 
@@ -2436,7 +2437,7 @@ function poco_serverlist() {
                ORDER BY `last_contact`
                LIMIT 1000",
                dbesc(NETWORK_DFRN), dbesc(NETWORK_DIASPORA), dbesc(NETWORK_OSTATUS));
-       if (!dbm::is_result($r)) {
+       if (!DBM::is_result($r)) {
                return false;
        }
 
Unnamed repository; edit this file 'description' to name the repository.