keith/friendica
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Merge pull request #11817 from annando/double-processing

Browse source 
Avoid processing the same activity
This commit is contained in:
Hypolite Petovan 2022-08-05 09:04:33 -04:00 committed by GitHub
commit bd246b8cc2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 44 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -59,6 +59,36 @@ class Processor
{
const CACHEKEY_FETCH_ACTIVITY = 'processor:fetchMissingActivity:';
const CACHEKEY_JUST_FETCHED = 'processor:isJustFetched:';
static $processed = [];
/**
* Add an activity id to the list of processed ids
*
* @param string $id
*
* @return void
*/
public static function addActivityId(string $id)
{
self::$processed[] = $id;
if (count(self::$processed) > 100) {
self::$processed = array_slice(self::$processed, 1);
}
}
/**
* Checks if the given has just been processed
*
* @param string $id
*
* @return boolean
*/
public static function isProcessed(string $id): bool
{
return in_array($id, self::$processed);
}
/**
* Extracts the tag character (#, @, !) from mention links
*
@ -275,6 +305,13 @@ class Processor
*/
public static function createItem(array $activity, bool $fetch_parents = true): array
{
if (self::isProcessed($activity['id'])) {
Logger::info('Id is already processed', ['id' => $activity['id']]);
return [];
}
self::addActivityId($activity['id']);
$item = [];
$item['verb'] = Activity::POST;
$item['thr-parent'] = $activity['reply-to-id'];
@ -308,7 +345,7 @@ class Processor
return [];
}
if (!DI::config()->get('system', 'fetch_parents')) {
if (!in_array(0, $activity['receiver']) && !DI::config()->get('system', 'fetch_parents')) {
$fetch_parents = false;
}
@ -1045,6 +1082,10 @@ class Processor
$success = true;
} else {
Logger::notice('Item insertion aborted', ['uri' => $item['uri'], 'uid' => $item['uid']]);
if (($item['uid'] == 0) && (count($activity['receiver']) > 1)) {
Logger::info('Public item was aborted. We skip for all users.', ['uri' => $item['uri']]);
break;
}
}
if ($item['uid'] == 0) {

3
src/Protocol/ActivityPub/Queue.php
View file

@ -22,6 +22,7 @@
namespace Friendica\Protocol\ActivityPub;
use Friendica\Core\Logger;
use Friendica\Core\System;
use Friendica\Database\Database;
use Friendica\Database\DBA;
use Friendica\DI;
@ -199,7 +200,7 @@ class Queue
}
}
Logger::debug('Processing queue entry', ['id' => $entry['id'], 'type' => $entry['type'], 'object-type' => $entry['object-type'], 'uri' => $entry['object-id'], 'in-reply-to' => $entry['in-reply-to-id']]);
Logger::debug('Processing queue entry', ['id' => $entry['id'], 'type' => $entry['type'], 'object-type' => $entry['object-type'], 'uri' => $entry['object-id'], 'in-reply-to' => $entry['in-reply-to-id'], 'callstack' => System::callstack(20)]);
$activity = json_decode($entry['activity'], true);
$type = $entry['type'];