Browse Source

Update FederationController

Daniel Supernault 2 years ago
parent
commit
2865f59a79
1 changed files with 4 additions and 4 deletions
  1. 4 4
      app/Http/Controllers/FederationController.php

+ 4 - 4
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(isset($obj['object']) && isset($obj['object']['type']) && isset($obj['object']['id'])) {
 				if($obj['object']['type'] === 'Person') {
 				if($obj['object']['type'] === 'Person') {
 					if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) {
 					if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) {
-						dispatch(new DeleteWorker($headers, $payload))->onQueue('delete');
+						dispatch(new DeleteWorker($headers, $payload))->onQueue('inbox');
 						return;
 						return;
 					}
 					}
 				}
 				}
@@ -170,7 +170,7 @@ class FederationController extends Controller
 				}
 				}
 
 
 				if($obj['object']['type'] === 'Story') {
 				if($obj['object']['type'] === 'Story') {
-					dispatch(new DeleteWorker($headers, $payload))->onQueue('delete');
+					dispatch(new DeleteWorker($headers, $payload))->onQueue('story');
 					return;
 					return;
 				}
 				}
 			}
 			}
@@ -215,7 +215,7 @@ class FederationController extends Controller
 			if(isset($obj['object']) && isset($obj['object']['type']) && isset($obj['object']['id'])) {
 			if(isset($obj['object']) && isset($obj['object']['type']) && isset($obj['object']['id'])) {
 				if($obj['object']['type'] === 'Person') {
 				if($obj['object']['type'] === 'Person') {
 					if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) {
 					if(Profile::whereRemoteUrl($obj['object']['id'])->exists()) {
-						dispatch(new DeleteWorker($headers, $payload))->onQueue('delete');
+						dispatch(new DeleteWorker($headers, $payload))->onQueue('inbox');
 						return;
 						return;
 					}
 					}
 				}
 				}
@@ -228,7 +228,7 @@ class FederationController extends Controller
 				}
 				}
 
 
 				if($obj['object']['type'] === 'Story') {
 				if($obj['object']['type'] === 'Story') {
-					dispatch(new DeleteWorker($headers, $payload))->onQueue('delete');
+					dispatch(new DeleteWorker($headers, $payload))->onQueue('story');
 					return;
 					return;
 				}
 				}
 			}
 			}