wip

heyjorgedev · Jul 18, 2024 · 765126a · 765126a
1 parent 77e690c
commit 765126a
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 2 deletions.
diff --git a/src/Contracts/Resources/MessageInterface.php b/src/Contracts/Resources/MessageInterface.php
@@ -2,6 +2,7 @@
 
 namespace HeyJorgeDev\QStash\Contracts\Resources;
 
+use HeyJorgeDev\QStash\Responses\MessageBatchResponse;
 use HeyJorgeDev\QStash\Responses\MessageCancelResponse;
 use HeyJorgeDev\QStash\Responses\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
@@ -14,7 +15,10 @@ public function publish(MessageToPublish $message): MessagePublishResponse;
 
     public function enqueue(string $queueName, MessageToPublish $message): MessageEnqueueResponse;
 
-    public function batch();
+    /**
+     * @param  array<MessageToPublish>  $messages
+     */
+    public function batch(array $messages): MessageBatchResponse;
 
     public function get(string $messageId): Message;
 

diff --git a/src/Resources/MessageResource.php b/src/Resources/MessageResource.php
@@ -5,6 +5,7 @@
 use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
 use HeyJorgeDev\QStash\Contracts\TransporterInterface;
 use HeyJorgeDev\QStash\Exceptions\NotImplementedException;
+use HeyJorgeDev\QStash\Responses\MessageBatchResponse;
 use HeyJorgeDev\QStash\Responses\MessageCancelResponse;
 use HeyJorgeDev\QStash\Responses\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
@@ -66,7 +67,7 @@ public function enqueue(string $queueName, MessageToPublish $message): MessageEn
         );
     }
 
-    public function batch()
+    public function batch(array $messages): MessageBatchResponse
     {
         throw NotImplementedException::askForContributions('batch publish messages');
     }

diff --git a/src/Responses/MessageBatchResponse.php b/src/Responses/MessageBatchResponse.php
@@ -0,0 +1,5 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Responses;
+
+class MessageBatchResponse {}