Merge pull request #6565 from annando/ap-follow-note

[friendica.git] / src / Protocol / ActivityPub / Transmitter.php

diff --git a/src/Protocol/ActivityPub/Transmitter.php b/src/Protocol/ActivityPub/Transmitter.php
index 41239b3afdfa76c8f6a2b4950d8dd12eb8b998d6..fa8bdc0439d997ec5009e95b76fa20f6691c311a 100644 (file)
--- a/src/Protocol/ActivityPub/Transmitter.php
+++ b/src/Protocol/ActivityPub/Transmitter.php
@@ -333,7 +333,11 @@ class Transmitter
 
                $data = ['to' => [], 'cc' => [], 'bcc' => []];
 
-               $actor_profile = APContact::getByURL($item['author-link']);
+               if ($item['gravity'] == GRAVITY_PARENT) {
+                       $actor_profile = APContact::getByURL($item['owner-link']);
+               } else {
+                       $actor_profile = APContact::getByURL($item['author-link']);
+               }
 
                $terms = Term::tagArrayFromItemId($item['id'], TERM_MENTION);
 
@@ -341,9 +345,6 @@ class Transmitter
                        $data = array_merge($data, self::fetchPermissionBlockFromConversation($item));
 
                        $data['to'][] = ActivityPub::PUBLIC_COLLECTION;
-                       if (!empty($actor_profile['followers'])) {
-                               $data['cc'][] = $actor_profile['followers'];
-                       }
 
                        foreach ($terms as $term) {
                                $profile = APContact::getByURL($term['url'], false);
@@ -378,6 +379,29 @@ class Transmitter
 
                $parents = Item::select(['id', 'author-link', 'owner-link', 'gravity', 'uri'], ['parent' => $item['parent']]);
                while ($parent = Item::fetch($parents)) {
+                       if ($parent['gravity'] == GRAVITY_PARENT) {
+                               $profile = APContact::getByURL($parent['owner-link'], false);
+                               if (!empty($profile)) {
+                                       if ($item['gravity'] != GRAVITY_PARENT) {
+                                               // Comments to forums are directed to the forum
+                                               // But comments to forums aren't directed to the followers collection
+                                               if ($profile['type'] == 'Group') {
+                                                       $data['to'][] = $profile['url'];
+                                               } else {
+                                                       $data['cc'][] = $profile['url'];
+                                                       if (!$item['private']) {
+                                                               $data['cc'][] = $actor_profile['followers'];
+                                                       }
+                                               }
+                                       } else {
+                                               // Public thread parent post always are directed to the followes
+                                               if (!$item['private']) {
+                                                       $data['cc'][] = $actor_profile['followers'];
+                                               }
+                                       }
+                               }
+                       }
+
                        // Don't include data from future posts
                        if ($parent['id'] >= $last_id) {
                                continue;
@@ -385,21 +409,12 @@ class Transmitter
 
                        $profile = APContact::getByURL($parent['author-link'], false);
                        if (!empty($profile)) {
-                               if ($parent['uri'] == $item['thr-parent']) {
+                               if (($profile['type'] == 'Group') || ($parent['uri'] == $item['thr-parent'])) {
                                        $data['to'][] = $profile['url'];
                                } else {
                                        $data['cc'][] = $profile['url'];
                                }
                        }
-
-                       if ($item['gravity'] != GRAVITY_PARENT) {
-                               continue;
-                       }
-
-                       $profile = APContact::getByURL($parent['owner-link'], false);
-                       if (!empty($profile)) {
-                               $data['cc'][] = $profile['url'];
-                       }
                }
                DBA::close($parents);
 
@@ -586,6 +601,8 @@ class Transmitter
                        $type = 'Reject';
                } elseif ($item['verb'] == ACTIVITY_ATTENDMAYBE) {
                        $type = 'TentativeAccept';
+               } elseif ($item['verb'] == ACTIVITY_FOLLOW) {
+                       $type = 'Follow';
                } else {
                        $type = '';
                }
@@ -686,6 +703,8 @@ class Transmitter
                        $data['object'] = self::createNote($item);
                } elseif ($data['type'] == 'Announce') {
                        $data = self::createAnnounce($item, $data);
+               } elseif ($data['type'] == 'Follow') {
+                       $data['object'] = $item['parent-uri'];
                } elseif ($data['type'] == 'Undo') {
                        $data['object'] = self::createActivityFromItem($item_id, true);
                } else {
@@ -1054,8 +1073,9 @@ class Transmitter
         * Creates an announce object entry
         *
         * @param array $item
+        * @param array $data activity data
         *
-        * @return string with announced object url
+        * @return array with activity data
         * @throws \Friendica\Network\HTTPException\InternalServerErrorException
         * @throws \ImagickException
         */
@@ -1259,6 +1279,38 @@ class Transmitter
                return HTTPSignature::transmit($signed, $profile['inbox'], $uid);
        }
 
+       /**
+        * Transmits a "follow object" activity to a target
+        * This is a preparation for sending automated "follow" requests when receiving "Announce" messages
+        *
+        * @param string  $object Object URL
+        * @param string  $target Target profile
+        * @param integer $uid    User ID
+        * @return bool
+        * @throws \Friendica\Network\HTTPException\InternalServerErrorException
+        * @throws \ImagickException
+        * @throws \Exception
+        */
+       public static function sendFollowObject($object, $target, $uid)
+       {
+               $profile = APContact::getByURL($target);
+
+               $owner = User::getOwnerDataById($uid);
+
+               $data = ['@context' => ActivityPub::CONTEXT,
+                       'id' => System::baseUrl() . '/activity/' . System::createGUID(),
+                       'type' => 'Follow',
+                       'actor' => $owner['url'],
+                       'object' => $object,
+                       'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
+                       'to' => [$profile['url']]];
+
+               Logger::log('Sending follow ' . $object . ' to ' . $target . ' for user ' . $uid, Logger::DEBUG);
+
+               $signed = LDSignature::sign($data, $owner);
+               return HTTPSignature::transmit($signed, $profile['inbox'], $uid);
+       }
+
        /**
         * Transmit a message that the contact request had been accepted
         *