wip

src/Contracts/Resources/MessageInterface.php

@@ -2,6 +2,7 @@
 
 namespace HeyJorgeDev\QStash\Contracts\Resources;
 
+use HeyJorgeDev\QStash\Responses\MessageCancelResponse;
 use HeyJorgeDev\QStash\Responses\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
@@ -17,7 +18,7 @@ public function batch();
 
     public function get(string $messageId): Message;
 
-    public function cancel(string $messageId);
+    public function cancel(string $messageId): MessageCancelResponse;
 
     /**
      * @param  array<string>  $messageIds

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\MessageCancelResponse;
 use HeyJorgeDev\QStash\Responses\MessageEnqueueResponse;
 use HeyJorgeDev\QStash\Responses\MessagePublishResponse;
 use HeyJorgeDev\QStash\ValueObjects\Message;
@@ -75,9 +76,23 @@ public function get(string $messageId): Message
         throw NotImplementedException::askForContributions('get single message');
     }
 
-    public function cancel(string $messageId)
+    public function cancel(string $messageId): MessageCancelResponse
     {
-        throw NotImplementedException::askForContributions('cancel a message');
+        $request = Request::DELETE("/messages/{$messageId}");
+
+        $response = $this->transporter->send($request);
+
+        if (! $response->isSuccessful()) {
+            return new MessageCancelResponse(
+                $response->statusCode,
+                $response->body
+            );
+        }
+
+        return new MessageCancelResponse(
+            $response->statusCode,
+            []
+        );
     }
 
     public function bulkCancel(array $messageIds)

src/Responses/MessageCancelResponse.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Responses;
+
+use HeyJorgeDev\QStash\Contracts\ResponseInterface;
+
+class MessageCancelResponse implements ResponseInterface
+{
+    public function __construct(
+        protected int $statusCode,
+        protected array $errors,
+    ) {}
+
+    public function isSuccessful(): bool
+    {
+        return $this->statusCode === 202;
+    }
+
+    public function getErrors(): array
+    {
+        return $this->errors;
+    }
+}