X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=src%2FProtocol%2FActivityPub%2FTransmitter.php;h=7f5f51c38aedcde640271d4f8bfba59250606102;hb=32f70abf9a7913df1ddb28b9745eb37941d09d80;hp=6ac55dc12317946ca22392cc9a9c3941634cb18c;hpb=61dcd6292122d767ad6907ee3ed1e56815033f25;p=friendica.git

diff --git a/src/Protocol/ActivityPub/Transmitter.php b/src/Protocol/ActivityPub/Transmitter.php
index 6ac55dc123..7f5f51c38a 100644
--- a/src/Protocol/ActivityPub/Transmitter.php
+++ b/src/Protocol/ActivityPub/Transmitter.php
@@ -42,6 +42,7 @@ use Friendica\Model\Tag;
 use Friendica\Model\User;
 use Friendica\Protocol\Activity;
 use Friendica\Protocol\ActivityPub;
+use Friendica\Protocol\Relay;
 use Friendica\Util\DateTimeFormat;
 use Friendica\Util\HTTPSignature;
 use Friendica\Util\JsonLD;
@@ -80,6 +81,27 @@ class Transmitter
 		return $inboxes;
 	}
 
+	/**
+	 * Add relay servers to the list of inboxes
+	 *
+	 * @param array $inboxes
+	 * @return array inboxes with added relay servers
+	 */
+	public static function addRelayServerInboxesForItem(int $item_id, array $inboxes = [])
+	{
+		$relays = Relay::getList($item_id, [], [Protocol::ACTIVITYPUB]);
+		if (empty($relays)) {
+			return $inboxes;
+		}
+
+		foreach ($relays as $relay) {
+			if (!in_array($relay['batch'], $inboxes)) {
+				$inboxes[] = $relay['batch'];
+			}
+		}
+		return $inboxes;
+	}
+
 	/**
 	 * Subscribe to a relay
 	 *
@@ -410,7 +432,12 @@ class Transmitter
 		$activity = json_decode($conversation['source'], true);
 
 		$actor = JsonLD::fetchElement($activity, 'actor', 'id');
-		$profile = APContact::getByURL($actor);
+		if (!empty($actor)) {
+			$permissions['to'][] = $actor;
+			$profile = APContact::getByURL($actor);
+		} else {
+			$profile = [];
+		}
 
 		$item_profile = APContact::getByURL($item['author-link']);
 		$exclude[] = $item['author-link'];
@@ -419,8 +446,6 @@ class Transmitter
 			$exclude[] = $item['owner-link'];
 		}
 
-		$permissions['to'][] = $actor;
-
 		foreach (['to', 'cc', 'bto', 'bcc'] as $element) {
 			if (empty($activity[$element])) {
 				continue;
@@ -645,7 +670,7 @@ class Transmitter
 	 *
 	 * @return boolean "true" if inbox is archived
 	 */
-	private static function archivedInbox($url)
+	public static function archivedInbox($url)
 	{
 		return DBA::exists('inbox-status', ['url' => $url, 'archive' => true]);
 	}
@@ -697,7 +722,7 @@ class Transmitter
 				continue;
 			}
 
-			if ($isforum && ($contact['dfrn'] == Protocol::DFRN)) {
+			if ($isforum && ($contact['network'] == Protocol::DFRN)) {
 				continue;
 			}
 
@@ -995,11 +1020,19 @@ class Transmitter
 			if (!empty($author['nurl'])) {
 				$self = Contact::selectFirst(['uid'], ['nurl' => $author['nurl'], 'self' => true]);
 				if (!empty($self['uid'])) {
-					$item = Item::selectFirst([], ['uri-id' => $item['uri-id'], 'uid' => $self['uid']]);
+					$forum_item = Item::selectFirst([], ['uri-id' => $item['uri-id'], 'uid' => $self['uid']]);
+					if (DBA::isResult($item)) {
+						$item = $forum_item; 
+					}
 				}
 			}
 		}
 
+		if (empty($item['uri-id'])) {
+			Logger::warning('Item without uri-id', ['item' => $item]);
+			return false;
+		}
+
 		if (empty($type)) {
 			$condition = ['item-uri' => $item['uri'], 'protocol' => Conversation::PARCEL_ACTIVITYPUB];
 			$conversation = DBA::selectFirst('conversation', ['source'], $condition);