From 06c10401c80235e71a9a509492771d7c457bb675 Mon Sep 17 00:00:00 2001
From: Daniel Supernault <danielsupernault@gmail.com>
Date: Mon, 19 Dec 2022 23:17:24 -0700
Subject: [PATCH] Update InboxPipeline

---
 app/Jobs/InboxPipeline/InboxValidator.php | 4 +++-
 app/Jobs/InboxPipeline/InboxWorker.php    | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/app/Jobs/InboxPipeline/InboxValidator.php b/app/Jobs/InboxPipeline/InboxValidator.php
index 21c43612d..c983519d3 100644
--- a/app/Jobs/InboxPipeline/InboxValidator.php
+++ b/app/Jobs/InboxPipeline/InboxValidator.php
@@ -17,6 +17,7 @@ use Illuminate\Queue\SerializesModels;
 use App\Jobs\DeletePipeline\DeleteRemoteProfilePipeline;
 use Illuminate\Support\Facades\Http;
 use Illuminate\Http\Client\ConnectionException;
+use Illuminate\Support\Lottery;
 
 class InboxValidator implements ShouldQueue
 {
@@ -81,7 +82,8 @@ class InboxValidator implements ShouldQueue
             if(isset($payload['type']) && in_array($payload['type'], ['Follow', 'Accept']) ) {
                 ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('follow');
             } else {
-                ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('inbox');
+                $onQueue = Lottery::odds(1, 12)->winner(fn () => 'high')->loser(fn () => 'inbox')->choose();
+                ActivityHandler::dispatch($headers, $profile, $payload)->onQueue($onQueue);
             }
             return;
         } else {
diff --git a/app/Jobs/InboxPipeline/InboxWorker.php b/app/Jobs/InboxPipeline/InboxWorker.php
index 4cef8b95b..9ce14bd94 100644
--- a/app/Jobs/InboxPipeline/InboxWorker.php
+++ b/app/Jobs/InboxPipeline/InboxWorker.php
@@ -66,7 +66,7 @@ class InboxWorker implements ShouldQueue
         }
 
         if($this->verifySignature($headers, $payload) == true) {
-            ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('inbox');
+            ActivityHandler::dispatch($headers, $profile, $payload)->onQueue('shared');
             return;
         } else {
             return;