wip

src/Contracts/Resources/MessageInterface.php

@@ -2,12 +2,13 @@
 
 namespace HeyJorgeDev\QStash\Contracts\Resources;
 
+use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
 use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;
 
 interface MessageInterface
 {
-    public function publish(MessageToPublish $message);
+    public function publish(MessageToPublish $message): MessagePublishResponse;
 
     public function enqueue();
 

src/Resources/MessageResource.php

@@ -4,16 +4,17 @@
 
 use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
 use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
 use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;
 
 class MessageResource implements MessageInterface
 {
     public function __construct(private readonly TransporterInterface $transporter) {}
 
-    public function publish(MessageToPublish $message)
+    public function publish(MessageToPublish $message): MessagePublishResponse
     {
-        // TODO: Implement publish() method.
+        return new MessagePublishResponse();
     }
 
     public function enqueue()

src/Responses/MessagePublishResponse.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Responses;
+
+use HeyJorgeDev\QStash\Contracts\ResponseWithDataInterface;
+
+class MessagePublishResponse implements ResponseWithDataInterface
+{
+    public function isSuccessful(): bool
+    {
+        // TODO: Implement isSuccessful() method.
+    }
+
+    public function getErrors(): array
+    {
+        // TODO: Implement getErrors() method.
+    }
+
+    public function getData()
+    {
+        // TODO: Implement getData() method.
+    }
+}