Add onGroup and withDeduplicator to Queueable trait and PendingDispatch

Author: binaryfire

src/bus/src/PendingDispatch.php

@@ -47,6 +47,30 @@ public function onQueue(UnitEnum|string|null $queue): static
         return $this;
     }
 
+    /**
+     * Set the desired job "group".
+     *
+     * This feature is only supported by some queues, such as Amazon SQS.
+     */
+    public function onGroup(UnitEnum|string $group): static
+    {
+        $this->job->onGroup($group);
+
+        return $this;
+    }
+
+    /**
+     * Set the desired job deduplicator callback.
+     *
+     * This feature is only supported by some queues, such as Amazon SQS FIFO.
+     */
+    public function withDeduplicator(?callable $deduplicator): static
+    {
+        $this->job->withDeduplicator($deduplicator);
+
+        return $this;
+    }
+
     /**
      * Set the desired connection for the chain.
      */

src/bus/src/Queueable.php

@@ -10,6 +10,7 @@
 use Hypervel\Queue\CallQueuedClosure;
 use Hypervel\Support\Arr;
 use Hypervel\Support\Collection;
+use Laravel\SerializableClosure\SerializableClosure;
 use PHPUnit\Framework\Assert as PHPUnit;
 use RuntimeException;
 use Throwable;
@@ -29,6 +30,18 @@ trait Queueable
      */
     public ?string $queue = null;
 
+    /**
+     * The job "group" the job should be sent to.
+     */
+    public ?string $messageGroup = null;
+
+    /**
+     * The job deduplicator callback the job should use to generate the deduplication ID.
+     *
+     * @var \Laravel\SerializableClosure\SerializableClosure|null
+     */
+    public $deduplicator = null;
+
     /**
      * The number of seconds before the job should be made available.
      */
@@ -88,6 +101,32 @@ public function onQueue(UnitEnum|string|null $queue): static
         return $this;
     }
 
+    /**
+     * Set the desired job "group".
+     *
+     * This feature is only supported by some queues, such as Amazon SQS.
+     */
+    public function onGroup(UnitEnum|string $group): static
+    {
+        $this->messageGroup = enum_value($group);
+
+        return $this;
+    }
+
+    /**
+     * Set the desired job deduplicator callback.
+     *
+     * This feature is only supported by some queues, such as Amazon SQS FIFO.
+     */
+    public function withDeduplicator(?callable $deduplicator): static
+    {
+        $this->deduplicator = $deduplicator instanceof Closure
+            ? new SerializableClosure($deduplicator)
+            : $deduplicator;
+
+        return $this;
+    }
+
     /**
      * Set the desired connection for the chain.
      */