diff options
| author | winter | 2025-05-04 21:04:18 +0100 |
|---|---|---|
| committer | winter | 2025-05-04 21:04:18 +0100 |
| commit | d86f36e4becbe40766598816f837042aad4ce145 (patch) | |
| tree | d56c1e90c8637e0bf2f8ca346493e91ed3d5ed06 /Digitigrade/Job/ProcessIncomingPush.php | |
| parent | 8b4bac25d588720f88d178cfd71fc8a8361e2ff5 (diff) | |
allow following actors with no follow endpoint
Diffstat (limited to 'Digitigrade/Job/ProcessIncomingPush.php')
| -rw-r--r-- | Digitigrade/Job/ProcessIncomingPush.php | 14 |
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 :('); |
