aboutsummaryrefslogtreecommitdiffhomepage
path: root/Digitigrade/Job/ProcessIncomingPush.php
diff options
context:
space:
mode:
authorwinter2025-05-04 21:04:18 +0100
committerwinter2025-05-04 21:04:18 +0100
commitd86f36e4becbe40766598816f837042aad4ce145 (patch)
treed56c1e90c8637e0bf2f8ca346493e91ed3d5ed06 /Digitigrade/Job/ProcessIncomingPush.php
parent8b4bac25d588720f88d178cfd71fc8a8361e2ff5 (diff)
allow following actors with no follow endpoint
Diffstat (limited to 'Digitigrade/Job/ProcessIncomingPush.php')
-rw-r--r--Digitigrade/Job/ProcessIncomingPush.php14
1 files changed, 10 insertions, 4 deletions
diff --git a/Digitigrade/Job/ProcessIncomingPush.php b/Digitigrade/Job/ProcessIncomingPush.php
index 600972c..16dd1ce 100644
--- a/Digitigrade/Job/ProcessIncomingPush.php
+++ b/Digitigrade/Job/ProcessIncomingPush.php
@@ -34,15 +34,21 @@ class ProcessIncomingPush extends Job {
break;
case 'note':
$log->info('importing note with uri ' . $this->object->self);
+ $alreadyExisted = Note::countWhere('uri = ?', [$this->object->self]) > 0;
$note = Note::importFromReceivedObject($this->object);
- $note?->processTimelineAdditions();
- $note?->processNotifications();
+ if (!$alreadyExisted) {
+ $note?->processTimelineAdditions();
+ $note?->processNotifications();
+ }
break;
case 'interaction':
$log->info('importing interaction with uri ' . $this->object->self);
+ $alreadyExisted = Interaction::countWhere('uri = ?', [$this->object->self]) > 0;
$interaction = Interaction::importFromReceivedObject($this->object);
- $interaction?->processTimelineAdditions();
- $interaction?->processNotifications();
+ if (!$alreadyExisted) {
+ $interaction?->processTimelineAdditions();
+ $interaction?->processNotifications();
+ }
break;
case 'extension':
throw new \RuntimeException('object type ' . $this->object->type . ' not yet implemented :(');