Process the replies

This commit is contained in:
Michael 2022-07-21 07:08:17 +00:00
parent 4930e77eb3
commit 2e39cebcb9

View File

@ -24,6 +24,7 @@ namespace Friendica\Worker;
use Friendica\Core\Logger; use Friendica\Core\Logger;
use Friendica\Core\Worker; use Friendica\Core\Worker;
use Friendica\Protocol\ActivityPub; use Friendica\Protocol\ActivityPub;
use Friendica\Protocol\ActivityPub\Queue;
use Friendica\Protocol\ActivityPub\Receiver; use Friendica\Protocol\ActivityPub\Receiver;
class FetchMissingActivity class FetchMissingActivity
@ -38,6 +39,7 @@ class FetchMissingActivity
$result = ActivityPub\Processor::fetchMissingActivity($url, $child, $relay_actor, $completion); $result = ActivityPub\Processor::fetchMissingActivity($url, $child, $relay_actor, $completion);
if ($result) { if ($result) {
Logger::info('Successfully fetched missing activity', ['url' => $url]); Logger::info('Successfully fetched missing activity', ['url' => $url]);
Queue::processReplyByUri($url);
} elseif (!Worker::defer()) { } elseif (!Worker::defer()) {
Logger::info('Activity could not be fetched', ['url' => $url]); Logger::info('Activity could not be fetched', ['url' => $url]);
// Possibly we should recursively remove child activities at this point. // Possibly we should recursively remove child activities at this point.