$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);
$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);
$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;
$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);
$type = 'Reject';
} elseif ($item['verb'] == ACTIVITY_ATTENDMAYBE) {
$type = 'TentativeAccept';
+ } elseif ($item['verb'] == ACTIVITY_FOLLOW) {
+ $type = 'Follow';
} else {
$type = '';
}
$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 {
* 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
*/
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
*