From 765126ae9edde0fa0ab4357fc3bffd0152060e1b Mon Sep 17 00:00:00 2001
From: Jorge Lapa <2780099+heyjorgedev@users.noreply.github.com>
Date: Thu, 18 Jul 2024 16:56:12 +0100
Subject: [PATCH] wip

---
 src/Contracts/Resources/MessageInterface.php | 6 +++++-
 src/Resources/MessageResource.php            | 3 ++-
 src/Responses/MessageBatchResponse.php       | 5 +++++
 3 files changed, 12 insertions(+), 2 deletions(-)
 create mode 100644 src/Responses/MessageBatchResponse.php

diff --git a/src/Contracts/Resources/MessageInterface.php b/src/Contracts/Resources/MessageInterface.php
index 64eef66..0ec78c6 100644
--- 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
index 05a78f9..e238dbd 100644
--- 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
new file mode 100644
index 0000000..105fe48
--- /dev/null
+++ b/src/Responses/MessageBatchResponse.php
@@ -0,0 +1,5 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Responses;
+
+class MessageBatchResponse {}