wip

src/Contracts/Resources/MessageInterface.php

@@ -2,6 +2,7 @@
 
 namespace HeyJorgeDev\QStash\Contracts\Resources;
 
+use HeyJorgeDev\QStash\Responses\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
 use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;
@@ -10,7 +11,7 @@ interface MessageInterface
 {
     public function publish(MessageToPublish $message): MessagePublishResponse;
 
-    public function enqueue();
+    public function enqueue(string $queueName, MessageToPublish $message): MessageEnqueueResponse;
 
     public function batch();
 

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\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
 use HeyJorgeDev\QStash\ValueObjects\MessageToPublish;
@@ -39,9 +40,29 @@ public function publish(MessageToPublish $message): MessagePublishResponse
         );
     }
 
-    public function enqueue()
+    public function enqueue(string $queueName, MessageToPublish $message): MessageEnqueueResponse
     {
-        throw NotImplementedException::askForContributions('enqueue messages');
+        $upstashHeaders = $message->toUpstashHeaders();
+
+        $request = Request::POST("/publish/{$queueName}/{$message->destination->toString()}")
+            ->withBody($message->body)
+            ->appendHeaders($upstashHeaders);
+
+        $response = $this->transporter->send($request);
+
+        if (! $response->isSuccessful()) {
+            return new MessageEnqueueResponse(
+                $response->statusCode,
+                [],
+                $response->body
+            );
+        }
+
+        return new MessageEnqueueResponse(
+            $response->statusCode,
+            $response->body,
+            []
+        );
     }
 
     public function batch()

src/Responses/MessageEnqueueResponse.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Responses;
+
+use HeyJorgeDev\QStash\Contracts\ResponseWithDataInterface;
+use HeyJorgeDev\QStash\ValueObjects\Message;
+
+class MessageEnqueueResponse implements ResponseWithDataInterface
+{
+    public function __construct(
+        protected int $statusCode,
+        protected array $data,
+        protected array $errors,
+    ) {}
+
+    public function isSuccessful(): bool
+    {
+        return $this->statusCode === 200;
+    }
+
+    public function getErrors(): array
+    {
+        return $this->errors;
+    }
+
+    public function getData(): Message
+    {
+        return new Message(
+            id: $this->data['messageId'],
+            deduplicated: $this->data['deduplicated'] ?? false,
+        );
+    }
+}

src/Responses/MessagePublishResponse.php

@@ -25,6 +25,9 @@ public function getErrors(): array
 
     public function getData(): Message
     {
-        return new Message(id: $this->data['messageId']);
+        return new Message(
+            id: $this->data['messageId'],
+            deduplicated: $this->data['deduplicated'] ?? false,
+        );
     }
 }

src/ValueObjects/Message.php

@@ -6,6 +6,7 @@ class Message
 {
     public function __construct(
         public readonly string $id,
+        public readonly bool $deduplicated = false,
     ) {}
 
     public static function to(Url|TopicName $url): MessageToPublish

src/ValueObjects/Transporter/Request.php

@@ -43,7 +43,7 @@ public static function DELETE(string|Url $url): self
     public function withMethod(string $method): self
     {
         return new self(
-            method: $method,
+            method: strtoupper($method),
             url: $this->url,
             headers: $this->headers,
             body: $this->body,