configurable connection and queue (#159)

spatie · Jun 6, 2023 · 9f8246a · 9f8246a
1 parent 2387f0d
commit 9f8246a
Show file tree

Hide file tree

Showing 3 changed files with 35 additions and 1 deletion.
diff --git a/config/stripe-webhooks.php b/config/stripe-webhooks.php
@@ -37,6 +37,12 @@
      */
     'profile' => \Spatie\StripeWebhooks\StripeWebhookProfile::class,
 
+    /*
+     * Specify a connection and or a queue to process the webhooks
+     */
+    'connection' => env('STRIPE_WEBHOOK_CONNECTION'),
+    'queue' => env('STRIPE_WEBHOOK_QUEUE'),
+
     /*
      * When disabled, the package will not verify if the signature is valid.
      * This can be handy in local environments.

diff --git a/src/ProcessStripeWebhookJob.php b/src/ProcessStripeWebhookJob.php
@@ -4,9 +4,17 @@
 
 use Spatie\StripeWebhooks\Exceptions\WebhookFailed;
 use Spatie\WebhookClient\Jobs\ProcessWebhookJob;
+use Spatie\WebhookClient\Models\WebhookCall;
 
 class ProcessStripeWebhookJob extends ProcessWebhookJob
 {
+    public function __construct(WebhookCall $webhookCall)
+    {
+        parent::__construct($webhookCall);
+        $this->onConnection(config('stripe-webhooks.connection'));
+        $this->onQueue(config('stripe-webhooks.queue'));
+    }
+
     public function handle()
     {
         if (! isset($this->webhookCall->payload['type']) || $this->webhookCall->payload['type'] === '') {
@@ -31,7 +39,7 @@ public function handle()
     protected function determineJobClass(string $eventType): string
     {
         $jobConfigKey = str_replace('.', '_', $eventType);
-        
+
         $defaultJob = config('stripe-webhooks.default_job', '');
 
         return config("stripe-webhooks.jobs.{$jobConfigKey}", $defaultJob);

diff --git a/tests/StripeWebhookCallTest.php b/tests/StripeWebhookCallTest.php
@@ -88,4 +88,24 @@ public function it_will_dispatch_events_even_when_no_corresponding_job_is_config
 
         $this->assertNull(cache('dummyjob'));
     }
+
+    /** @test */
+    public function it_can_specify_a_connection_in_the_config()
+    {
+        config(['stripe-webhooks.connection' => 'some-connection']);
+
+        $processStripeWebhookJob = new ProcessStripeWebhookJob($this->webhookCall);
+
+        $this->assertEquals('some-connection', $processStripeWebhookJob->connection);
+    }
+
+    /** @test */
+    public function it_can_specify_a_queue_in_the_config()
+    {
+        config(['stripe-webhooks.queue' => 'some-queue']);
+
+        $processStripeWebhookJob = new ProcessStripeWebhookJob($this->webhookCall);
+
+        $this->assertEquals('some-queue', $processStripeWebhookJob->queue);
+    }
 }