Feature for gnikyt#177, allow for custom queue name per job

Author: gnikyt

src/ShopifyApp/Services/AuthShopHandler.php

@@ -137,7 +137,7 @@ public function dispatchWebhooks()
     {
         $webhooks = Config::get('shopify-app.webhooks');
         if (count($webhooks) > 0) {
-            WebhookInstaller::dispatch($this->shop);
+            WebhookInstaller::dispatch($this->shop)->onQueue(Config::get('shopify-app.job_queues.webhooks'));
         }
     }
 
@@ -150,7 +150,7 @@ public function dispatchScripttags()
     {
         $scripttags = Config::get('shopify-app.scripttags');
         if (count($scripttags) > 0) {
-            ScripttagInstaller::dispatch($this->shop, $scripttags);
+            ScripttagInstaller::dispatch($this->shop, $scripttags)->onQueue(Config::get('shopify-app.job_queues.scripttags'));
         }
     }
 
@@ -178,7 +178,7 @@ public function dispatchAfterAuthenticate()
                 $job::dispatchNow($this->shop);
             } else {
                 // Run later
-                $job::dispatch($this->shop);
+                $job::dispatch($this->shop)->onQueue(Config::get('shopify-app.job_queues.after_authenticate'));
             }
 
             return true;

src/ShopifyApp/resources/config/shopify-app.php

@@ -266,4 +266,20 @@
             ],
         */
     ],
+
+    /*
+    |--------------------------------------------------------------------------
+    | Job Queues
+    |--------------------------------------------------------------------------
+    |
+    | This option is for setting a specific job queue for webhooks, scripttags
+    | and after_authenticate_job.
+    |
+    */
+
+    'job_queues' => [
+        'webhooks'           => env('WEBHOOKS_JOB_QUEUE', null),
+        'scripttags'         => env('SCRIPTTAGS_JOB_QUEUE', null),
+        'after_authenticate' => env('AFTER_AUTHENTICATE_JOB_QUEUE', null),
+    ],
 ];

tests/Services/AuthShopHandlerTest.php

@@ -169,6 +169,7 @@ public function testJobsRun()
                 'src' => 'https://localhost/scripts/file.js',
             ],
         ]);
+        Config::set('shopify-app.job_queues.webhooks', 'custom-queue');
 
         $jobClass = \App\Jobs\AfterAuthenticateJob::class;
         Config::set('shopify-app.after_authenticate_job', [[
@@ -187,6 +188,7 @@ public function testJobsRun()
         Queue::assertPushed(WebhookInstaller::class);
         Queue::assertPushed(ScripttagInstaller::class);
         Queue::assertPushed($jobClass);
+        Queue::assertPushedOn('custom-queue', WebhookInstaller::class);
     }
 
     public function testAfterAuthenticateSingleJobRuns()