From b0634bfd8f7ae31f1b100077d123ecbcc2d5c336 Mon Sep 17 00:00:00 2001 From: Daniel Supernault Date: Thu, 25 May 2023 01:23:57 -0600 Subject: [PATCH] Add temp logging --- app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php | 3 +++ app/Util/ActivityPub/Inbox.php | 5 +++++ 2 files changed, 8 insertions(+) diff --git a/app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php b/app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php index 980a88b7..c9d168fd 100644 --- a/app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php +++ b/app/Jobs/StatusPipeline/StatusRemoteUpdatePipeline.php @@ -33,9 +33,12 @@ class StatusRemoteUpdatePipeline implements ShouldQueue */ public function handle(): void { + $ts = (string) microtime(true); + \Log::info('AP:inbox Update:Job invoked ' . $ts); $activity = $this->activity; $status = Status::with('media')->whereObjectUrl($activity['id'])->first(); if(!$status) { + \Log::info('AP:inbox Update:Job notFound ' . $ts . ' activity: ' . $activity); return; } $this->createPreviousEdit($status); diff --git a/app/Util/ActivityPub/Inbox.php b/app/Util/ActivityPub/Inbox.php index 325d9b0c..c4922f8a 100644 --- a/app/Util/ActivityPub/Inbox.php +++ b/app/Util/ActivityPub/Inbox.php @@ -1211,14 +1211,19 @@ class Inbox public function handleUpdateActivity() { + $ts = (string) microtime(true); + \Log::info('AP:inbox Update ' . $ts); $activity = $this->payload['object']; if(!isset($activity['type'], $activity['id'])) { + \Log::info('AP:inbox Update ma ' . $ts); return; } if($activity['type'] === 'Note') { + \Log::info('AP:inbox Update at:Note ' . $ts); if(Status::whereObjectUrl($activity['id'])->exists()) { + \Log::info('AP:inbox Update at:Note:exists ' . $ts); StatusRemoteUpdatePipeline::dispatch($activity); } }