]> git.mxchange.org Git - friendica.git/blobdiff - src/Model/Contact/Relation.php
Merge pull request #9046 from annando/local-followers
[friendica.git] / src / Model / Contact / Relation.php
index a98f2bfd9a2af35bbcb4ba7cbf63dd8528e83996..24d663cbbf41b34b09b046fe33b0cdb2864740ce 100644 (file)
@@ -26,6 +26,10 @@ use Friendica\Core\Logger;
 use Friendica\Core\Protocol;
 use Friendica\Database\DBA;
 use Friendica\DI;
+use Friendica\Model\APContact;
+use Friendica\Model\Contact;
+use Friendica\Model\Profile;
+use Friendica\Model\User;
 use Friendica\Protocol\ActivityPub;
 use Friendica\Util\DateTimeFormat;
 use Friendica\Util\Strings;
@@ -80,18 +84,25 @@ class Relation
                        return;
                }
 
-               $apcontact = APContact::getByURL($url, false);
-
-               if (!empty($apcontact['followers']) && is_string($apcontact['followers'])) {
-                       $followers = ActivityPub::fetchItems($apcontact['followers']);
+               $uid = User::getIdForURL($url);
+               if (!empty($uid)) {
+                       // Fetch the followers/followings locally
+                       $followers = self::getContacts($uid, [Contact::FOLLOWER, Contact::FRIEND]);
+                       $followings = self::getContacts($uid, [Contact::SHARING, Contact::FRIEND]);
                } else {
-                       $followers = [];
-               }
+                       $apcontact = APContact::getByURL($url, false);
 
-               if (!empty($apcontact['following']) && is_string($apcontact['following'])) {
-                       $followings = ActivityPub::fetchItems($apcontact['following']);
-               } else {
-                       $followings = [];
+                       if (!empty($apcontact['followers']) && is_string($apcontact['followers'])) {
+                               $followers = ActivityPub::fetchItems($apcontact['followers']);
+                       } else {
+                               $followers = [];
+                       }
+
+                       if (!empty($apcontact['following']) && is_string($apcontact['following'])) {
+                               $followings = ActivityPub::fetchItems($apcontact['following']);
+                       } else {
+                               $followings = [];
+                       }
                }
 
                if (empty($followers) && empty($followings)) {
@@ -148,6 +159,33 @@ class Relation
                return;
        }
 
+       /**
+        * Fetch contact list from the given local user
+        *
+        * @param integer $uid
+        * @param array $rel
+        * @return void
+        */
+       private static function getContacts(int $uid, array $rel)
+       {
+               $list = [];
+               $profile = Profile::getByUID($uid);
+               if (!empty($profile['hide-friends'])) {
+                       return $list;
+               }
+
+               $condition = ['rel' => $rel, 'uid' => $uid, 'self' => false, 'deleted' => false,
+                       'hidden' => false, 'archive' => false, 'pending' => false];
+               $condition = DBA::mergeConditions($condition, ["`url` IN (SELECT `url` FROM `apcontact`)"]);
+               $contacts = DBA::select('contact', ['url'], $condition);
+               while ($contact = DBA::fetch($contacts)) {
+                       $list[] = $contact['url'];
+               }
+               DBA::close($contacts);
+
+               return $list;
+       }
+
        /**
         * Tests if a given contact url is discoverable
         *
@@ -164,7 +202,7 @@ class Relation
                }
 
                if (empty($contact)) {
-                       $contact = Contact::getByURL($url);
+                       $contact = Contact::getByURL($url, false);
                }
 
                if (empty($contact)) {
@@ -207,6 +245,110 @@ class Relation
                return true;
        }
 
+       /**
+        * @param int $uid   user
+        * @param int $start optional, default 0
+        * @param int $limit optional, default 80
+        * @return array
+        */
+       static public function getSuggestions(int $uid, int $start = 0, int $limit = 80)
+       {
+               $cid = Contact::getPublicIdByUserId($uid);
+               $totallimit = $start + $limit;
+               $contacts = [];
+
+               Logger::info('Collecting suggestions', ['uid' => $uid, 'cid' => $cid, 'start' => $start, 'limit' => $limit]);
+
+               $diaspora = DI::config()->get('system', 'diaspora_enabled') ? Protocol::DIASPORA : Protocol::ACTIVITYPUB;
+               $ostatus = !DI::config()->get('system', 'ostatus_disabled') ? Protocol::OSTATUS : Protocol::ACTIVITYPUB;
+
+               // The query returns contacts where contacts interacted with whom the given user follows.
+               // Contacts who already are in the user's contact table are ignored.
+               $results = DBA::select('contact', [],
+                       ["`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` IN
+                               (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ?)
+                                       AND NOT `cid` IN (SELECT `id` FROM `contact` WHERE `uid` = ? AND `nurl` IN
+                                               (SELECT `nurl` FROM `contact` WHERE `uid` = ? AND `rel` IN (?, ?))))
+                       AND NOT `hidden` AND `network` IN (?, ?, ?, ?)",
+                       $cid, 0, $uid, Contact::FRIEND, Contact::SHARING,
+                       Protocol::ACTIVITYPUB, Protocol::DFRN, $diaspora, $ostatus],
+                       ['order' => ['last-item' => true], 'limit' => $totallimit]
+               );
+
+               while ($contact = DBA::fetch($results)) {
+                       $contacts[$contact['id']] = $contact;
+               }
+               DBA::close($results);
+
+               Logger::info('Contacts of contacts who are followed by the given user', ['uid' => $uid, 'cid' => $cid, 'count' => count($contacts)]);
+
+               if (count($contacts) >= $totallimit) {
+                       return array_slice($contacts, $start, $limit);
+               }
+
+               // The query returns contacts where contacts interacted with whom also interacted with the given user.
+               // Contacts who already are in the user's contact table are ignored.
+               $results = DBA::select('contact', [],
+                       ["`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` IN
+                               (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ?)
+                                       AND NOT `cid` IN (SELECT `id` FROM `contact` WHERE `uid` = ? AND `nurl` IN
+                                               (SELECT `nurl` FROM `contact` WHERE `uid` = ? AND `rel` IN (?, ?))))
+                       AND NOT `hidden` AND `network` IN (?, ?, ?, ?)",
+                       $cid, 0, $uid, Contact::FRIEND, Contact::SHARING,
+                       Protocol::ACTIVITYPUB, Protocol::DFRN, $diaspora, $ostatus],
+                       ['order' => ['last-item' => true], 'limit' => $totallimit]
+               );
+
+               while ($contact = DBA::fetch($results)) {
+                       $contacts[$contact['id']] = $contact;
+               }
+               DBA::close($results);
+
+               Logger::info('Contacts of contacts who are following the given user', ['uid' => $uid, 'cid' => $cid, 'count' => count($contacts)]);
+
+               if (count($contacts) >= $totallimit) {
+                       return array_slice($contacts, $start, $limit);
+               }
+
+               // The query returns contacts that follow the given user but aren't followed by that user.
+               $results = DBA::select('contact', [],
+                       ["`nurl` IN (SELECT `nurl` FROM `contact` WHERE `uid` = ? AND `rel` = ?)
+                       AND NOT `hidden` AND `uid` = ? AND `network` IN (?, ?, ?, ?)",
+                       $uid, Contact::FOLLOWER, 0, 
+                       Protocol::ACTIVITYPUB, Protocol::DFRN, $diaspora, $ostatus],
+                       ['order' => ['last-item' => true], 'limit' => $totallimit]
+               );
+
+               while ($contact = DBA::fetch($results)) {
+                       $contacts[$contact['id']] = $contact;
+               }
+               DBA::close($results);
+
+               Logger::info('Followers that are not followed by the given user', ['uid' => $uid, 'cid' => $cid, 'count' => count($contacts)]);
+
+               if (count($contacts) >= $totallimit) {
+                       return array_slice($contacts, $start, $limit);
+               }
+
+               // The query returns any contact that isn't followed by that user.
+               $results = DBA::select('contact', [],
+                       ["NOT `nurl` IN (SELECT `nurl` FROM `contact` WHERE `uid` = ? AND `rel` IN (?, ?))
+                       AND NOT `hidden` AND `uid` = ? AND `network` IN (?, ?, ?, ?)",
+                       $uid, Contact::FRIEND, Contact::SHARING, 0, 
+                       Protocol::ACTIVITYPUB, Protocol::DFRN, $diaspora, $ostatus],
+                       ['order' => ['last-item' => true], 'limit' => $totallimit]
+               );
+
+               while ($contact = DBA::fetch($results)) {
+                       $contacts[$contact['id']] = $contact;
+               }
+               DBA::close($results);
+
+               Logger::info('Any contact', ['uid' => $uid, 'cid' => $cid, 'count' => count($contacts)]);
+
+               return array_slice($contacts, $start, $limit);
+       }
+
        /**
         * Counts all the known follows of the provided public contact
         *
@@ -218,12 +360,8 @@ class Relation
        public static function countFollows(int $cid, array $condition = [])
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-    AND `follows`
-)', $cid]
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`)', 
+                       $cid]
                );
 
                return DI::dba()->count('contact', $condition);
@@ -243,24 +381,13 @@ class Relation
        public static function listFollows(int $cid, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-    AND `follows`
-)', $cid]
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`)', 
+                       $cid]
                );
 
-               $follows = DI::dba()->selectToArray(
-                       'contact',
-                       $condition,
-                       [
-                               'limit' => [$offset, $count],
-                               'order' => [$shuffle ? 'RAND()' : 'name']
-                       ]
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'RAND()' : 'name']]
                );
-
-               return $follows;
        }
 
        /**
@@ -274,12 +401,8 @@ class Relation
        public static function countFollowers(int $cid, array $condition = [])
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-    AND `follows`
-)', $cid]
+                       ['`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)',
+                       $cid]
                );
 
                return DI::dba()->count('contact', $condition);
@@ -299,24 +422,99 @@ class Relation
        public static function listFollowers(int $cid, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-    AND `follows`
-)', $cid]
+                       ['`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)', $cid]
                );
 
-               $followers = DI::dba()->selectToArray(
-                       'contact',
-                       $condition,
-                       [
-                               'limit' => [$offset, $count],
-                               'order' => [$shuffle ? 'RAND()' : 'name']
-                       ]
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'RAND()' : 'name']]
                );
+       }
 
-               return $followers;
+       /**
+        * Counts the number of contacts that are known mutuals with the provided public contact.
+        *
+        * @param int   $cid       Public contact id
+        * @param array $condition Additional condition array on the contact table
+        * @return int
+        * @throws Exception
+        */
+       public static function countMutuals(int $cid, array $condition = [])
+       {
+               $condition = DBA::mergeConditions($condition,
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)',
+                       $cid, $cid]
+               );
+
+               return DI::dba()->count('contact', $condition);
+       }
+
+       /**
+        * Returns a paginated list of contacts that are known mutuals with the provided public contact.
+        *
+        * @param int   $cid       Public contact id
+        * @param array $condition Additional condition on the contact table
+        * @param int   $count
+        * @param int   $offset
+        * @param bool  $shuffle
+        * @return array
+        * @throws Exception
+        */
+       public static function listMutuals(int $cid, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
+       {
+               $condition = DBA::mergeConditions($condition,
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)',
+                       $cid, $cid]
+               );
+
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'name' : 'RAND()']]
+               );
+       }
+
+
+       /**
+        * Counts the number of contacts with any relationship with the provided public contact.
+        *
+        * @param int   $cid       Public contact id
+        * @param array $condition Additional condition array on the contact table
+        * @return int
+        * @throws Exception
+        */
+       public static function countAll(int $cid, array $condition = [])
+       {
+               $condition = DBA::mergeConditions($condition,
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       OR `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)',
+                               $cid, $cid]
+               );
+
+               return DI::dba()->count('contact', $condition);
+       }
+
+       /**
+        * Returns a paginated list of contacts with any relationship with the provided public contact.
+        *
+        * @param int   $cid       Public contact id
+        * @param array $condition Additional condition on the contact table
+        * @param int   $count
+        * @param int   $offset
+        * @param bool  $shuffle
+        * @return array
+        * @throws Exception
+        */
+       public static function listAll(int $cid, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
+       {
+               $condition = DBA::mergeConditions($condition,
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       OR `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)',
+                               $cid, $cid]
+               );
+
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'name' : 'RAND()']]
+               );
        }
 
        /**
@@ -332,21 +530,12 @@ class Relation
        public static function countCommon(int $sourceId, int $targetId, array $condition = [])
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-) 
-  AND `id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-)', $sourceId, $targetId]
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ?) 
+                       AND `id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ?)',
+                       $sourceId, $targetId]
                );
 
-               $total = DI::dba()->count('contact', $condition);
-
-               return $total;
+               return DI::dba()->count('contact', $condition);
        }
 
        /**
@@ -365,33 +554,16 @@ class Relation
        public static function listCommon(int $sourceId, int $targetId, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
        {
                $condition = DBA::mergeConditions($condition,
-                       ["`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-) 
-  AND `id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-)", $sourceId, $targetId]
+                       ["`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ?) 
+                       AND `id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ?)",
+                       $sourceId, $targetId]
                );
 
-               $contacts = DI::dba()->selectToArray(
-                       'contact',
-                       $condition,
-                       [
-                               'limit' => [$offset, $count],
-                               'order' => [$shuffle ? 'name' : 'RAND()'],
-                       ]
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'name' : 'RAND()']]
                );
-
-               return $contacts;
        }
 
-
        /**
         * Counts the number of contacts that are followed by both provided public contacts.
         *
@@ -404,23 +576,12 @@ class Relation
        public static function countCommonFollows(int $sourceId, int $targetId, array $condition = [])
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-) 
-  AND `id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-)', $sourceId, $targetId]
+                       ['`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`)',
+                       $sourceId, $targetId]
                );
 
-               $total = DI::dba()->count('contact', $condition);
-
-               return $total;
+               return DI::dba()->count('contact', $condition);
        }
 
        /**
@@ -438,30 +599,14 @@ class Relation
        public static function listCommonFollows(int $sourceId, int $targetId, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
        {
                $condition = DBA::mergeConditions($condition,
-                       ["`id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-) 
-  AND `id` IN (
-    SELECT `relation-cid`
-    FROM `contact-relation`
-    WHERE `cid` = ?
-      AND `follows`
-)", $sourceId, $targetId]
+                       ["`id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `relation-cid` FROM `contact-relation` WHERE `cid` = ? AND `follows`)",
+                       $sourceId, $targetId]
                );
 
-               $contacts = DI::dba()->selectToArray(
-                       'contact',
-                       $condition,
-                       [
-                               'limit' => [$offset, $count],
-                               'order' => [$shuffle ? 'name' : 'RAND()'],
-                       ]
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count], 'order' => [$shuffle ? 'name' : 'RAND()']]
                );
-
-               return $contacts;
        }
 
        /**
@@ -476,23 +621,12 @@ class Relation
        public static function countCommonFollowers(int $sourceId, int $targetId, array $condition = [])
        {
                $condition = DBA::mergeConditions($condition,
-                       ['`id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-      AND `follows`
-) 
-  AND `id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-      AND `follows`
-)', $sourceId, $targetId]
+                       ["`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)",
+                       $sourceId, $targetId]
                );
 
-               $total = DI::dba()->count('contact', $condition);
-
-               return $total;
+               return DI::dba()->count('contact', $condition);
        }
 
        /**
@@ -510,29 +644,13 @@ class Relation
        public static function listCommonFollowers(int $sourceId, int $targetId, array $condition = [], int $count = 30, int $offset = 0, bool $shuffle = false)
        {
                $condition = DBA::mergeConditions($condition,
-                       ["`id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-      AND `follows`
-) 
-  AND `id` IN (
-    SELECT `cid`
-    FROM `contact-relation`
-    WHERE `relation-cid` = ?
-      AND `follows`
-)", $sourceId, $targetId]
+                       ["`id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`) 
+                       AND `id` IN (SELECT `cid` FROM `contact-relation` WHERE `relation-cid` = ? AND `follows`)",
+                       $sourceId, $targetId]
                );
 
-               $contacts = DI::dba()->selectToArray(
-                       'contact',
-                       $condition,
-                       [
-                               'limit' => [$offset, $count],
-                               'order' => [$shuffle ? 'name' : 'RAND()'],
-                       ]
+               return DI::dba()->selectToArray('contact', [], $condition,
+                       ['limit' => [$offset, $count],  'order' => [$shuffle ? 'name' : 'RAND()']]
                );
-
-               return $contacts;
        }
 }