From 2865f59a79fabc9c7bb5ff0add79871b652ec6f3 Mon Sep 17 00:00:00 2001 From: Daniel Supernault Date: Sat, 24 Dec 2022 05:57:19 -0700 Subject: [PATCH] Update FederationController --- app/Http/Controllers/FederationController.php | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/app/Http/Controllers/FederationController.php b/app/Http/Controllers/FederationController.php index 42988ec9..358f3093 100644 --- a/app/Http/Controllers/FederationController.php +++ b/app/Http/Controllers/FederationController.php @@ -157,7 +157,7 @@ class FederationController extends Controller if(isset($obj['object']) && isset($obj['object']['type']) && isset($obj['object']['id'])) { if($obj['object']['type'] === 'Person') { if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) { - dispatch(new DeleteWorker($headers, $payload))->onQueue('delete'); + dispatch(new DeleteWorker($headers, $payload))->onQueue('inbox'); return; } } @@ -170,7 +170,7 @@ class FederationController extends Controller } if($obj['object']['type'] === 'Story') { - dispatch(new DeleteWorker($headers, $payload))->onQueue('delete'); + dispatch(new DeleteWorker($headers, $payload))->onQueue('story'); return; } } @@ -215,7 +215,7 @@ class FederationController extends Controller if(isset($obj['object']) && isset($obj['object']['type']) && isset($obj['object']['id'])) { if($obj['object']['type'] === 'Person') { if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) { - dispatch(new DeleteWorker($headers, $payload))->onQueue('delete'); + dispatch(new DeleteWorker($headers, $payload))->onQueue('inbox'); return; } } @@ -228,7 +228,7 @@ class FederationController extends Controller } if($obj['object']['type'] === 'Story') { - dispatch(new DeleteWorker($headers, $payload))->onQueue('delete'); + dispatch(new DeleteWorker($headers, $payload))->onQueue('story'); return; } }