]> git.mxchange.org Git - friendica.git/blobdiff - src/Network/Probe.php
Merge pull request #7090 from nupplaphil/task/mod_like
[friendica.git] / src / Network / Probe.php
index f61eed4192231b29cdd3e2c153bfc8308fbc0a46..b0d2630103beaed42328d4aa61cee75a08a3d57f 100644 (file)
@@ -10,6 +10,7 @@ namespace Friendica\Network;
  */
 
 use DOMDocument;
+use DomXPath;
 use Friendica\Core\Cache;
 use Friendica\Core\Config;
 use Friendica\Core\Logger;
@@ -18,15 +19,14 @@ use Friendica\Core\System;
 use Friendica\Database\DBA;
 use Friendica\Model\Contact;
 use Friendica\Model\Profile;
+use Friendica\Protocol\ActivityPub;
 use Friendica\Protocol\Email;
 use Friendica\Protocol\Feed;
-use Friendica\Protocol\ActivityPub;
 use Friendica\Util\Crypto;
 use Friendica\Util\DateTimeFormat;
 use Friendica\Util\Network;
 use Friendica\Util\Strings;
 use Friendica\Util\XML;
-use DomXPath;
 
 /**
  * @brief This class contain functions for probing URL
@@ -35,6 +35,7 @@ use DomXPath;
 class Probe
 {
        private static $baseurl;
+       private static $istimeout;
 
        /**
         * @brief Rearrange the array so that it always has the same order
@@ -74,7 +75,7 @@ class Probe
         */
        private static function ownHost($host)
        {
-               $own_host = get_app()->getHostName();
+               $own_host = \get_app()->getHostName();
 
                $parts = parse_url($host);
 
@@ -97,6 +98,7 @@ class Probe
         * @param string $host The host part of an url
         *
         * @return array with template and type of the webfinger template for JSON or XML
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function hostMeta($host)
        {
@@ -123,6 +125,7 @@ class Probe
                        $curlResult = Network::curl($url, false, $redirects, ['timeout' => $xrd_timeout, 'accept_content' => 'application/xrd+xml']);
                        if ($curlResult->isTimeout()) {
                                Logger::log("Probing timeout for " . $url, Logger::DEBUG);
+                               self::$istimeout = true;
                                return false;
                        }
                        $xml = $curlResult->getBody();
@@ -155,7 +158,7 @@ class Probe
                                continue;
                        }
 
-                       if (($attributes["rel"] == "lrdd") && !empty($attributes["template"])) {
+                       if (!empty($attributes["rel"]) && $attributes["rel"] == "lrdd" && !empty($attributes["template"])) {
                                $type = (empty($attributes["type"]) ? '' : $attributes["type"]);
 
                                $lrdd[$type] = $attributes["template"];
@@ -188,6 +191,7 @@ class Probe
         * @param string $hcard_url Link to the hcard - is returned by reference
         *
         * @return string profile link
+        * @throws HTTPException\InternalServerErrorException
         */
        public static function webfingerDfrn($webbie, &$hcard_url)
        {
@@ -221,6 +225,7 @@ class Probe
         * @param string $uri Address that should be probed
         *
         * @return array uri data
+        * @throws HTTPException\InternalServerErrorException
         */
        public static function lrdd($uri)
        {
@@ -315,6 +320,8 @@ class Probe
         * @param boolean $cache   Use cached values?
         *
         * @return array uri data
+        * @throws HTTPException\InternalServerErrorException
+        * @throws \ImagickException
         */
        public static function uri($uri, $network = '', $uid = -1, $cache = true)
        {
@@ -329,16 +336,24 @@ class Probe
                        $uid = local_user();
                }
 
+               self::$istimeout = false;
+
                if ($network != Protocol::ACTIVITYPUB) {
                        $data = self::detect($uri, $network, $uid);
                } else {
                        $data = null;
                }
 
-               $ap_profile = ActivityPub::probeProfile($uri);
+               // When the previous detection process had got a time out
+               // we could falsely detect a Friendica profile as AP profile.
+               if (!self::$istimeout) {
+                       $ap_profile = ActivityPub::probeProfile($uri);
 
-               if (!empty($ap_profile) && (defaults($data, 'network', '') != Protocol::DFRN)) {
-                       $data = $ap_profile;
+                       if (!empty($ap_profile) && empty($network) && (defaults($data, 'network', '') != Protocol::DFRN)) {
+                               $data = $ap_profile;
+                       }
+               } else {
+                       Logger::notice('Time out detected. AP will not be probed.', ['uri' => $uri]);
                }
 
                if (!isset($data['url'])) {
@@ -412,7 +427,7 @@ class Probe
                                // This doesn't cover the case when a community isn't a community anymore
                                if (!empty($data['community']) && $data['community']) {
                                        $fields['community'] = $data['community'];
-                                       $fields['contact-type'] = Contact::ACCOUNT_TYPE_COMMUNITY;
+                                       $fields['contact-type'] = Contact::TYPE_COMMUNITY;
                                }
 
                                $fieldnames = [];
@@ -495,30 +510,6 @@ class Probe
                return $data;
        }
 
-       /**
-        * @brief Switch the scheme of an url between http and https
-        *
-        * @param string $url URL
-        *
-        * @return string switched URL
-        */
-       private static function switchScheme($url)
-       {
-               $parts = parse_url($url);
-
-               if (!isset($parts['scheme'])) {
-                       return $url;
-               }
-
-               if ($parts['scheme'] == 'http') {
-                       $url = str_replace('http://', 'https://', $url);
-               } elseif ($parts['scheme'] == 'https') {
-                       $url = str_replace('https://', 'http://', $url);
-               }
-
-               return $url;
-       }
-
        /**
         * @brief Checks if a profile url should be OStatus but only provides partial information
         *
@@ -527,6 +518,7 @@ class Probe
         * @param string $type      type
         *
         * @return array fixed webfinger data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function fixOStatus($webfinger, $lrdd, $type)
        {
@@ -550,7 +542,7 @@ class Probe
                        return $webfinger;
                }
 
-               $url = self::switchScheme($webfinger['subject']);
+               $url = Network::switchScheme($webfinger['subject']);
                $path = str_replace('{uri}', urlencode($url), $lrdd);
                $webfinger2 = self::webfinger($path, $type);
 
@@ -572,6 +564,7 @@ class Probe
         * @param integer $uid     User ID for the probe (only used for mails)
         *
         * @return array uri data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function detect($uri, $network, $uid)
        {
@@ -740,6 +733,7 @@ class Probe
         * @param string $type type
         *
         * @return array webfinger data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function webfinger($url, $type)
        {
@@ -748,6 +742,7 @@ class Probe
 
                $curlResult = Network::curl($url, false, $redirects, ['timeout' => $xrd_timeout, 'accept_content' => $type]);
                if ($curlResult->isTimeout()) {
+                       self::$istimeout = true;
                        return false;
                }
                $data = $curlResult->getBody();
@@ -810,11 +805,13 @@ class Probe
         * @param array  $data         The already fetched data
         *
         * @return array noscrape data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function pollNoscrape($noscrape_url, $data)
        {
                $curlResult = Network::curl($noscrape_url);
                if ($curlResult->isTimeout()) {
+                       self::$istimeout = true;
                        return false;
                }
                $content = $curlResult->getBody();
@@ -926,6 +923,8 @@ class Probe
         * @param string $profile_link Link to the profile page
         *
         * @return array profile data
+        * @throws HTTPException\InternalServerErrorException
+        * @throws \ImagickException
         */
        public static function profile($profile_link)
        {
@@ -976,6 +975,7 @@ class Probe
         * @param array $webfinger Webfinger data
         *
         * @return array DFRN data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function dfrn($webfinger)
        {
@@ -1057,11 +1057,13 @@ class Probe
         * @param boolean $dfrn      Poll DFRN specific data
         *
         * @return array hcard data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function pollHcard($hcard_url, $data, $dfrn = false)
        {
                $curlResult = Network::curl($hcard_url);
                if ($curlResult->isTimeout()) {
+                       self::$istimeout = true;
                        return false;
                }
                $content = $curlResult->getBody();
@@ -1181,6 +1183,7 @@ class Probe
         * @param array $webfinger Webfinger data
         *
         * @return array Diaspora data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function diaspora($webfinger)
        {
@@ -1268,6 +1271,7 @@ class Probe
         * @param bool  $short     Short detection mode
         *
         * @return array|bool OStatus data or "false" on error or "true" on short mode
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function ostatus($webfinger, $short = false)
        {
@@ -1287,7 +1291,6 @@ class Probe
                        $data["addr"] = str_replace('acct:', '', $webfinger["subject"]);
                }
 
-               $pubkey = "";
                if (is_array($webfinger["links"])) {
                        // The array is reversed to take into account the order of preference for same-rel links
                        // See: https://tools.ietf.org/html/rfc7033#section-4.4.4
@@ -1313,6 +1316,7 @@ class Probe
                                        } elseif (Strings::normaliseLink($pubkey) == 'http://') {
                                                $curlResult = Network::curl($pubkey);
                                                if ($curlResult->isTimeout()) {
+                                                       self::$istimeout = true;
                                                        return false;
                                                }
                                                $pubkey = $curlResult->getBody();
@@ -1345,6 +1349,7 @@ class Probe
                // Fetch all additional data from the feed
                $curlResult = Network::curl($data["poll"]);
                if ($curlResult->isTimeout()) {
+                       self::$istimeout = true;
                        return false;
                }
                $feed = $curlResult->getBody();
@@ -1450,6 +1455,7 @@ class Probe
         *
         * @param array $webfinger Webfinger data
         *
+        * @param       $addr
         * @return array pump.io data
         */
        private static function pumpio($webfinger, $addr)
@@ -1552,11 +1558,13 @@ class Probe
         * @param boolean $probe Do a probe if the page contains a feed link
         *
         * @return array feed data
+        * @throws HTTPException\InternalServerErrorException
         */
        private static function feed($url, $probe = true)
        {
                $curlResult = Network::curl($url);
                if ($curlResult->isTimeout()) {
+                       self::$istimeout = true;
                        return false;
                }
                $feed = $curlResult->getBody();
@@ -1614,6 +1622,7 @@ class Probe
         * @param integer $uid User ID
         *
         * @return array mail data
+        * @throws \Exception
         */
        private static function mail($uri, $uid)
        {
@@ -1701,6 +1710,7 @@ class Probe
         * @param string $base   Another path that is hopefully complete
         *
         * @return string fixed avatar path
+        * @throws \Exception
         */
        public static function fixAvatar($avatar, $base)
        {