Add webhookId to Webhooks

.gitignore

@@ -4,3 +4,4 @@
 composer.lock
 .php-cs-fixer.cache
 .phpunit.result.cache
+.idea

src/Contracts/Objects/Values/WebhookId.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Osiset\ShopifyApp\Contracts\Objects\Values;
+
+use Funeralzone\ValueObjects\ValueObject;
+
+/**
+ * Webhook ID's value object.
+ */
+interface WebhookId extends ValueObject
+{
+}

src/Contracts/WebhookJob.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Osiset\ShopifyApp\Contracts;
+
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Osiset\ShopifyApp\Contracts\Objects\Values\WebhookId;
+use Osiset\ShopifyApp\Objects\Values\ShopDomain;
+use stdClass;
+
+interface WebhookJob extends ShouldQueue
+{
+    /**
+     * Create a new job instance.
+     *
+     * @param ShopDomain|string $shopId    The shop Domain.
+     * @param WebhookId|string  $webhookId The webhooks ID.
+     * @param stdClass   $data      The webhook payload.
+     *
+     * @return void
+     */
+    public function __construct(string $shopId, string $webhookId, stdClass $data);
+}

src/Messaging/Jobs/AppUninstalledJob.php

@@ -9,15 +9,17 @@
 use Illuminate\Queue\SerializesModels;
 use Osiset\ShopifyApp\Actions\CancelCurrentPlan;
 use Osiset\ShopifyApp\Contracts\Commands\Shop as IShopCommand;
+use Osiset\ShopifyApp\Contracts\Objects\Values\WebhookId;
 use Osiset\ShopifyApp\Contracts\Queries\Shop as IShopQuery;
+use Osiset\ShopifyApp\Contracts\WebhookJob;
 use Osiset\ShopifyApp\Objects\Values\ShopDomain;
 use Osiset\ShopifyApp\Util;
 use stdClass;
 
 /**
  * Webhook job responsible for handling when the app is uninstalled.
  */
-class AppUninstalledJob implements ShouldQueue
+class AppUninstalledJob implements WebhookJob
 {
     use Dispatchable;
     use InteractsWithQueue;
@@ -30,26 +32,33 @@ class AppUninstalledJob implements ShouldQueue
      * @var ShopDomain|string
      */
     protected $domain;
-
     /**
      * The webhook data.
      *
      * @var object
      */
     protected $data;
+    /**
+     * The webhook id
+     *
+     * @var WebhookId|string
+     */
+    protected $webhookId;
 
     /**
      * Create a new job instance.
      *
-     * @param string   $domain The shop domain.
-     * @param stdClass $data   The webhook data (JSON decoded).
+     * @param ShopDomain|string $shopId    The shop Domain.
+     * @param WebhookId|string  $webhookId The webhooks ID.
+     * @param stdClass          $data      The webhook data (JSON decoded).
      *
      * @return void
      */
-    public function __construct(string $domain, stdClass $data)
+    public function __construct(string $domain, string $webhookId, stdClass $data)
     {
         $this->domain = $domain;
         $this->data = $data;
+        $this->webhookId = $webhookId;
     }
 
     /**
@@ -62,8 +71,8 @@ public function __construct(string $domain, stdClass $data)
      * @return bool
      */
     public function handle(
-        IShopCommand $shopCommand,
-        IShopQuery $shopQuery,
+        IShopCommand      $shopCommand,
+        IShopQuery        $shopQuery,
         CancelCurrentPlan $cancelCurrentPlanAction
     ): bool {
         // Convert the domain

src/Traits/WebhookController.php

@@ -28,6 +28,7 @@ public function handle(string $type, Request $request): ResponseResponse
 
         $jobClass::dispatch(
             $request->header('x-shopify-shop-domain'),
+            $request->header('x-shopify-webhook-id'),
             $jobData
         )->onQueue(Util::getShopifyConfig('job_queues')['webhooks']);