X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FProtocol%2FActivityPub%2FTransmitter.php;h=f09c18165b26055cade2bf67c3ab905d27228c62;hb=1a702359f10e34230e1cfae90d335752f8576e70;hp=a94b7f59fde0c9b18aaaf50eec92b7860232531d;hpb=fea48fa85e3707f41f4b1d4469ffb5a5938d6c21;p=friendica.git

diff --git a/src/Protocol/ActivityPub/Transmitter.php b/src/Protocol/ActivityPub/Transmitter.php
index a94b7f59fd..f09c18165b 100644
--- a/src/Protocol/ActivityPub/Transmitter.php
+++ b/src/Protocol/ActivityPub/Transmitter.php
@@ -6,6 +6,7 @@ namespace Friendica\Protocol\ActivityPub;
 
 use Friendica\BaseObject;
 use Friendica\Database\DBA;
+use Friendica\Core\Logger;
 use Friendica\Core\System;
 use Friendica\Util\HTTPSignature;
 use Friendica\Core\Protocol;
@@ -26,6 +27,7 @@ use Friendica\Protocol\ActivityPub;
 use Friendica\Protocol\Diaspora;
 use Friendica\Core\Cache;
 use Friendica\Util\Map;
+use Friendica\Util\Network;
 
 require_once 'include/api.php';
 
@@ -33,15 +35,7 @@ require_once 'include/api.php';
  * @brief ActivityPub Transmitter Protocol class
  *
  * To-Do:
- *
- * Missing object types:
- * - Event
- *
- * Complicated object types:
  * - Undo Announce
- *
- * General:
- * - Queueing unsucessful deliveries
  */
 class Transmitter
 {
@@ -289,9 +283,8 @@ class Transmitter
 
 			foreach ($activity[$element] as $receiver) {
 				if ($receiver == $profile['followers'] && !empty($item_profile['followers'])) {
-					$receiver = $item_profile['followers'];
-				}
-				if (!in_array($receiver, $exclude)) {
+					$permissions[$element][] = $item_profile['followers'];
+				} elseif (!in_array($receiver, $exclude)) {
 					$permissions[$element][] = $receiver;
 				}
 			}
@@ -303,10 +296,11 @@ class Transmitter
 	 * Creates an array of permissions from an item thread
 	 *
 	 * @param array $item
+	 * @param boolean $blindcopy
 	 *
 	 * @return array with permission data
 	 */
-	private static function createPermissionBlockForItem($item)
+	private static function createPermissionBlockForItem($item, $blindcopy)
 	{
 		// Will be activated in a later step
 		// $networks = [Protocol::ACTIVITYPUB, Protocol::DFRN, Protocol::DIASPORA, Protocol::OSTATUS];
@@ -314,15 +308,15 @@ class Transmitter
 		// For now only send to these contacts:
 		$networks = [Protocol::ACTIVITYPUB, Protocol::OSTATUS];
 
-		$data = ['to' => [], 'cc' => []];
-
-		$data = array_merge($data, self::fetchPermissionBlockFromConversation($item));
+		$data = ['to' => [], 'cc' => [], 'bcc' => []];
 
 		$actor_profile = APContact::getByURL($item['author-link']);
 
 		$terms = Term::tagArrayFromItemId($item['id'], TERM_MENTION);
 
 		if (!$item['private']) {
+			$data = array_merge($data, self::fetchPermissionBlockFromConversation($item));
+
 			$data['to'][] = ActivityPub::PUBLIC_COLLECTION;
 			if (!empty($actor_profile['followers'])) {
 				$data['cc'][] = $actor_profile['followers'];
@@ -352,6 +346,8 @@ class Transmitter
 			foreach ($receiver_list as $receiver) {
 				$contact = DBA::selectFirst('contact', ['url'], ['id' => $receiver, 'network' => $networks]);
 				if (DBA::isResult($contact) && !empty($profile = APContact::getByURL($contact['url'], false))) {
+					// BCC is currently deactivated, due to Pleroma and Mastodon not reacting like expected
+					// $data['bcc'][] = $profile['url'];
 					$data['cc'][] = $profile['url'];
 				}
 			}
@@ -386,6 +382,7 @@ class Transmitter
 
 		$data['to'] = array_unique($data['to']);
 		$data['cc'] = array_unique($data['cc']);
+		$data['bcc'] = array_unique($data['bcc']);
 
 		if (($key = array_search($item['author-link'], $data['to'])) !== false) {
 			unset($data['to'][$key]);
@@ -395,13 +392,33 @@ class Transmitter
 			unset($data['cc'][$key]);
 		}
 
+		if (($key = array_search($item['author-link'], $data['bcc'])) !== false) {
+			unset($data['bcc'][$key]);
+		}
+
 		foreach ($data['to'] as $to) {
 			if (($key = array_search($to, $data['cc'])) !== false) {
 				unset($data['cc'][$key]);
 			}
+
+			if (($key = array_search($to, $data['bcc'])) !== false) {
+				unset($data['bcc'][$key]);
+			}
 		}
 
-		return ['to' => array_values($data['to']), 'cc' => array_values($data['cc'])];
+		foreach ($data['cc'] as $cc) {
+			if (($key = array_search($cc, $data['bcc'])) !== false) {
+				unset($data['bcc'][$key]);
+			}
+		}
+
+		$receivers = ['to' => array_values($data['to']), 'cc' => array_values($data['cc']), 'bcc' => array_values($data['bcc'])];
+
+		if (!$blindcopy) {
+			unset($receivers['bcc']);
+		}
+
+		return $receivers;
 	}
 
 	/**
@@ -430,6 +447,10 @@ class Transmitter
 
 		$contacts = DBA::select('contact', ['url'], $condition);
 		while ($contact = DBA::fetch($contacts)) {
+			if (Network::isUrlBlocked($contact['url'])) {
+				continue;
+			}
+
 			$profile = APContact::getByURL($contact['url'], false);
 			if (!empty($profile)) {
 				if (empty($profile['sharedinbox']) || $personal) {
@@ -456,7 +477,7 @@ class Transmitter
 	 */
 	public static function fetchTargetInboxes($item, $uid, $personal = false)
 	{
-		$permissions = self::createPermissionBlockForItem($item);
+		$permissions = self::createPermissionBlockForItem($item, true);
 		if (empty($permissions)) {
 			return [];
 		}
@@ -474,13 +495,19 @@ class Transmitter
 				continue;
 			}
 
+			$blindcopy = in_array($element, ['bto', 'bcc']);
+
 			foreach ($permissions[$element] as $receiver) {
+				if (Network::isUrlBlocked($receiver)) {
+					continue;
+				}
+
 				if ($receiver == $item_profile['followers']) {
-					$inboxes = self::fetchTargetInboxesforUser($uid, $personal);
+					$inboxes = array_merge($inboxes, self::fetchTargetInboxesforUser($uid, $personal));
 				} else {
 					$profile = APContact::getByURL($receiver, false);
 					if (!empty($profile)) {
-						if (empty($profile['sharedinbox']) || $personal) {
+						if (empty($profile['sharedinbox']) || $personal || $blindcopy) {
 							$target = $profile['inbox'];
 						} else {
 							$target = $profile['sharedinbox'];
@@ -532,20 +559,24 @@ class Transmitter
 	 * Creates the activity or fetches it from the cache
 	 *
 	 * @param integer $item_id
+	 * @param boolean $force   Force new cache entry
 	 *
 	 * @return array with the activity
 	 */
-	public static function createCachedActivityFromItem($item_id)
+	public static function createCachedActivityFromItem($item_id, $force = false)
 	{
 		$cachekey = 'APDelivery:createActivity:' . $item_id;
-		$data = Cache::get($cachekey);
-		if (!is_null($data)) {
-			return $data;
+
+		if (!$force) {
+			$data = Cache::get($cachekey);
+			if (!is_null($data)) {
+				return $data;
+			}
 		}
 
 		$data = ActivityPub\Transmitter::createActivityFromItem($item_id);
 
-		Cache::set($cachekey, $data, CACHE_QUARTER_HOUR);
+		Cache::set($cachekey, $data, Cache::QUARTER_HOUR);
 		return $data;
 	}
 
@@ -596,7 +627,7 @@ class Transmitter
 
 		$data['instrument'] = ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()];
 
-		$data = array_merge($data, self::createPermissionBlockForItem($item));
+		$data = array_merge($data, self::createPermissionBlockForItem($item, false));
 
 		if (in_array($data['type'], ['Create', 'Update', 'Delete'])) {
 			$data['object'] = self::createNote($item);
@@ -606,10 +637,13 @@ class Transmitter
 			$data['object'] = self::createActivityFromItem($item_id, true);
 		} else {
 			$data['diaspora:guid'] = $item['guid'];
+			if (!empty($item['signed_text'])) {
+				$data['diaspora:like'] = $item['signed_text'];
+			}
 			$data['object'] = $item['thr-parent'];
 		}
 
-		$owner = User::getOwnerDataById($item['uid']);
+		$owner = User::getOwnerDataById($item['contact-uid']);
 
 		if (!$object_mode) {
 			return LDSignature::sign($data, $owner);
@@ -830,6 +864,32 @@ class Transmitter
 		return DBA::exists('term', $condition);
 	}
 
+	/**
+	 * Creates event data
+	 *
+	 * @param array $item
+	 *
+	 * @return array with the event data
+	 */
+	public static function createEvent($item)
+	{
+		$event = [];
+		$event['name'] = $item['event-summary'];
+		$event['content'] = BBCode::convert($item['event-desc'], false, 7);
+		$event['startTime'] = DateTimeFormat::utc($item['event-start'] . '+00:00', DateTimeFormat::ATOM);
+
+		if (!$item['event-nofinish']) {
+			$event['endTime'] = DateTimeFormat::utc($item['event-finish'] . '+00:00', DateTimeFormat::ATOM);
+		}
+
+		if (!empty($item['event-location'])) {
+			$item['location'] = $item['event-location'];
+			$event['location'] = self::createLocation($item);
+		}
+
+		return $event;
+	}
+
 	/**
 	 * Creates a note/article object array
 	 *
@@ -839,7 +899,9 @@ class Transmitter
 	 */
 	public static function createNote($item)
 	{
-		if (!empty($item['title'])) {
+		if ($item['event-type'] == 'event') {
+			$type = 'Event';
+		} elseif (!empty($item['title'])) {
 			$type = 'Article';
 		} else {
 			$type = 'Note';
@@ -887,10 +949,15 @@ class Transmitter
 			$body = self::removePictures($body);
 		}
 
-		$regexp = "/[@!]\[url\=([^\[\]]*)\].*?\[\/url\]/ism";
-		$body = preg_replace_callback($regexp, ['self', 'mentionCallback'], $body);
+		if ($type == 'Event') {
+			$data = array_merge($data, self::createEvent($item));
+		} else {
+			$regexp = "/[@!]\[url\=([^\[\]]*)\].*?\[\/url\]/ism";
+			$body = preg_replace_callback($regexp, ['self', 'mentionCallback'], $body);
+
+			$data['content'] = BBCode::convert($body, false, 7);
+		}
 
-		$data['content'] = BBCode::convert($body, false, 7);
 		$data['source'] = ['content' => $item['body'], 'mediaType' => "text/bbcode"];
 
 		if (!empty($item['signed_text']) && ($item['uri'] != $item['thr-parent'])) {
@@ -900,7 +967,7 @@ class Transmitter
 		$data['attachment'] = self::createAttachmentList($item, $type);
 		$data['tag'] = self::createTagList($item);
 
-		if (!empty($item['coord']) || !empty($item['location'])) {
+		if (empty($data['location']) && (!empty($item['coord']) || !empty($item['location']))) {
 			$data['location'] = self::createLocation($item);
 		}
 
@@ -908,7 +975,7 @@ class Transmitter
 			$data['generator'] = ['type' => 'Application', 'name' => $item['app']];
 		}
 
-		$data = array_merge($data, self::createPermissionBlockForItem($item));
+		$data = array_merge($data, self::createPermissionBlockForItem($item, false));
 
 		return $data;
 	}
@@ -930,21 +997,41 @@ class Transmitter
 		return $announce['plink'];
 	}
 
+	/**
+	 * Creates an activity id for a given contact id
+	 *
+	 * @param integer $cid Contact ID of target
+	 *
+	 * @return bool|string activity id
+	 */
+	public static function activityIDFromContact($cid)
+	{
+		$contact = DBA::selectFirst('contact', ['uid', 'id', 'created'], ['id' => $cid]);
+		if (!DBA::isResult($contact)) {
+			return false;
+		}
+
+		$hash = hash('ripemd128', $contact['uid'].'-'.$contact['id'].'-'.$contact['created']);
+		$uuid = substr($hash, 0, 8). '-' . substr($hash, 8, 4) . '-' . substr($hash, 12, 4) . '-' . substr($hash, 16, 4) . '-' . substr($hash, 20, 12);
+		return System::baseUrl() . '/activity/' . $uuid;
+	}
+
 	/**
 	 * Transmits a contact suggestion to a given inbox
 	 *
 	 * @param integer $uid User ID
 	 * @param string $inbox Target inbox
 	 * @param integer $suggestion_id Suggestion ID
+	 *
+	 * @return boolean was the transmission successful?
 	 */
 	public static function sendContactSuggestion($uid, $inbox, $suggestion_id)
 	{
 		$owner = User::getOwnerDataById($uid);
-		$profile = APContact::getByURL($owner['url']);
 
 		$suggestion = DBA::selectFirst('fsuggest', ['url', 'note', 'created'], ['id' => $suggestion_id]);
 
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
 			'type' => 'Announce',
 			'actor' => $owner['url'],
@@ -956,8 +1043,36 @@ class Transmitter
 
 		$signed = LDSignature::sign($data, $owner);
 
-		logger('Deliver profile deletion for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', LOGGER_DEBUG);
-		HTTPSignature::transmit($signed, $inbox, $uid);
+		Logger::log('Deliver profile deletion for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', Logger::DEBUG);
+		return HTTPSignature::transmit($signed, $inbox, $uid);
+	}
+
+	/**
+	 * Transmits a profile relocation to a given inbox
+	 *
+	 * @param integer $uid User ID
+	 * @param string $inbox Target inbox
+	 *
+	 * @return boolean was the transmission successful?
+	 */
+	public static function sendProfileRelocation($uid, $inbox)
+	{
+		$owner = User::getOwnerDataById($uid);
+
+		$data = ['@context' => ActivityPub::CONTEXT,
+			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
+			'type' => 'dfrn:relocate',
+			'actor' => $owner['url'],
+			'object' => $owner['url'],
+			'published' => DateTimeFormat::utcNow(DateTimeFormat::ATOM),
+			'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
+			'to' => [ActivityPub::PUBLIC_COLLECTION],
+			'cc' => []];
+
+		$signed = LDSignature::sign($data, $owner);
+
+		Logger::log('Deliver profile relocation for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', Logger::DEBUG);
+		return HTTPSignature::transmit($signed, $inbox, $uid);
 	}
 
 	/**
@@ -965,13 +1080,14 @@ class Transmitter
 	 *
 	 * @param integer $uid User ID
 	 * @param string $inbox Target inbox
+	 *
+	 * @return boolean was the transmission successful?
 	 */
 	public static function sendProfileDeletion($uid, $inbox)
 	{
 		$owner = User::getOwnerDataById($uid);
-		$profile = APContact::getByURL($owner['url']);
 
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
 			'type' => 'Delete',
 			'actor' => $owner['url'],
@@ -983,8 +1099,8 @@ class Transmitter
 
 		$signed = LDSignature::sign($data, $owner);
 
-		logger('Deliver profile deletion for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', LOGGER_DEBUG);
-		HTTPSignature::transmit($signed, $inbox, $uid);
+		Logger::log('Deliver profile deletion for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', Logger::DEBUG);
+		return HTTPSignature::transmit($signed, $inbox, $uid);
 	}
 
 	/**
@@ -992,13 +1108,15 @@ class Transmitter
 	 *
 	 * @param integer $uid User ID
 	 * @param string $inbox Target inbox
+	 *
+	 * @return boolean was the transmission successful?
 	 */
 	public static function sendProfileUpdate($uid, $inbox)
 	{
 		$owner = User::getOwnerDataById($uid);
 		$profile = APContact::getByURL($owner['url']);
 
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
 			'type' => 'Update',
 			'actor' => $owner['url'],
@@ -1010,8 +1128,8 @@ class Transmitter
 
 		$signed = LDSignature::sign($data, $owner);
 
-		logger('Deliver profile update for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', LOGGER_DEBUG);
-		HTTPSignature::transmit($signed, $inbox, $uid);
+		Logger::log('Deliver profile update for user ' . $uid . ' to ' . $inbox . ' via ActivityPub', Logger::DEBUG);
+		return HTTPSignature::transmit($signed, $inbox, $uid);
 	}
 
 	/**
@@ -1020,22 +1138,27 @@ class Transmitter
 	 * @param array $activity
 	 * @param string $target Target profile
 	 * @param integer $uid User ID
+	 * @param string $id activity id
 	 */
-	public static function sendActivity($activity, $target, $uid)
+	public static function sendActivity($activity, $target, $uid, $id = '')
 	{
 		$profile = APContact::getByURL($target);
 
 		$owner = User::getOwnerDataById($uid);
 
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
-			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
+		if (empty($id)) {
+			$id = System::baseUrl() . '/activity/' . System::createGUID();
+		}
+
+		$data = ['@context' => ActivityPub::CONTEXT,
+			'id' => $id,
 			'type' => $activity,
 			'actor' => $owner['url'],
 			'object' => $profile['url'],
 			'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
 			'to' => $profile['url']];
 
-		logger('Sending activity ' . $activity . ' to ' . $target . ' for user ' . $uid, LOGGER_DEBUG);
+		Logger::log('Sending activity ' . $activity . ' to ' . $target . ' for user ' . $uid, Logger::DEBUG);
 
 		$signed = LDSignature::sign($data, $owner);
 		HTTPSignature::transmit($signed, $profile['inbox'], $uid);
@@ -1053,7 +1176,7 @@ class Transmitter
 		$profile = APContact::getByURL($target);
 
 		$owner = User::getOwnerDataById($uid);
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
 			'type' => 'Accept',
 			'actor' => $owner['url'],
@@ -1063,7 +1186,7 @@ class Transmitter
 			'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
 			'to' => $profile['url']];
 
-		logger('Sending accept to ' . $target . ' for user ' . $uid . ' with id ' . $id, LOGGER_DEBUG);
+		Logger::log('Sending accept to ' . $target . ' for user ' . $uid . ' with id ' . $id, Logger::DEBUG);
 
 		$signed = LDSignature::sign($data, $owner);
 		HTTPSignature::transmit($signed, $profile['inbox'], $uid);
@@ -1081,7 +1204,7 @@ class Transmitter
 		$profile = APContact::getByURL($target);
 
 		$owner = User::getOwnerDataById($uid);
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => System::baseUrl() . '/activity/' . System::createGUID(),
 			'type' => 'Reject',
 			'actor' => $owner['url'],
@@ -1091,7 +1214,7 @@ class Transmitter
 			'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
 			'to' => $profile['url']];
 
-		logger('Sending reject to ' . $target . ' for user ' . $uid . ' with id ' . $id, LOGGER_DEBUG);
+		Logger::log('Sending reject to ' . $target . ' for user ' . $uid . ' with id ' . $id, Logger::DEBUG);
 
 		$signed = LDSignature::sign($data, $owner);
 		HTTPSignature::transmit($signed, $profile['inbox'], $uid);
@@ -1101,26 +1224,32 @@ class Transmitter
 	 * Transmits a message that we don't want to follow this contact anymore
 	 *
 	 * @param string $target Target profile
+	 * @param integer $cid Contact ID of target
 	 * @param integer $uid User ID
 	 */
-	public static function sendContactUndo($target, $uid)
+	public static function sendContactUndo($target, $cid, $uid)
 	{
 		$profile = APContact::getByURL($target);
 
+		$object_id = self::activityIDFromContact($cid);
+		if (empty($object_id)) {
+			return;
+		}
+
 		$id = System::baseUrl() . '/activity/' . System::createGUID();
 
 		$owner = User::getOwnerDataById($uid);
-		$data = ['@context' => 'https://www.w3.org/ns/activitystreams',
+		$data = ['@context' => ActivityPub::CONTEXT,
 			'id' => $id,
 			'type' => 'Undo',
 			'actor' => $owner['url'],
-			'object' => ['id' => $id, 'type' => 'Follow',
+			'object' => ['id' => $object_id, 'type' => 'Follow',
 				'actor' => $owner['url'],
 				'object' => $profile['url']],
 			'instrument' => ['type' => 'Service', 'name' => BaseObject::getApp()->getUserAgent()],
 			'to' => $profile['url']];
 
-		logger('Sending undo to ' . $target . ' for user ' . $uid . ' with id ' . $id, LOGGER_DEBUG);
+		Logger::log('Sending undo to ' . $target . ' for user ' . $uid . ' with id ' . $id, Logger::DEBUG);
 
 		$signed = LDSignature::sign($data, $owner);
 		HTTPSignature::transmit($signed, $profile['inbox'], $uid);