tobias/friendica
1
0
Fork 0
Code Pull requests Activity

Only store the inbox-queue on activated background processing

Browse source
This commit is contained in:
Michael 2022-07-31 08:10:47 +00:00
parent 371f20a1aa
commit 06a124338a
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/Protocol/ActivityPub/Processor.php
View file

@ -311,7 +311,9 @@ class Processor
$result = self::fetchMissingActivity($activity['reply-to-id'], $activity, '', Receiver::COMPLETION_AUTO); $result = self::fetchMissingActivity($activity['reply-to-id'], $activity, '', Receiver::COMPLETION_AUTO);
if (empty($result) && self::isActivityGone($activity['reply-to-id'])) { if (empty($result) && self::isActivityGone($activity['reply-to-id'])) {
// Recursively delete this and all depending entries // Recursively delete this and all depending entries
Queue::deleteById($activity['entry-id']); if (!empty($activity['entry-id'])) {
Queue::deleteById($activity['entry-id']);
}
return []; return [];
} }
$fetch_by_worker = empty($result); $fetch_by_worker = empty($result);
@ -366,9 +368,10 @@ class Processor
if (!empty($activity['raw'])) { if (!empty($activity['raw'])) {
$item['source'] = $activity['raw']; $item['source'] = $activity['raw'];
$item['protocol'] = Conversation::PARCEL_ACTIVITYPUB;
} }
$item['protocol'] = Conversation::PARCEL_ACTIVITYPUB;
if (isset($activity['push'])) { if (isset($activity['push'])) {
$item['direction'] = $activity['push'] ? Conversation::PUSH : Conversation::PULL; $item['direction'] = $activity['push'] ? Conversation::PUSH : Conversation::PULL;
} }

2
src/Protocol/ActivityPub/Receiver.php
View file

@ -583,7 +583,7 @@ class Receiver
$object_data['object_activity'] = $activity; $object_data['object_activity'] = $activity;
} }
if ($trust_source || DI::config()->get('debug', 'ap_inbox_store_untrusted')) { if (DI::config()->get('system', 'decoupled_receiver') && ($trust_source || DI::config()->get('debug', 'ap_inbox_store_untrusted'))) {
$object_data = Queue::add($object_data, $type, $uid, $http_signer, $push, $trust_source); $object_data = Queue::add($object_data, $type, $uid, $http_signer, $push, $trust_source);
} }