wip

composer.json

@@ -18,6 +18,7 @@
         "php": "^8.1"
     },
     "require-dev": {
+        "guzzlehttp/guzzle": "^7.8.1",
         "pestphp/pest": "^2.20",
         "laravel/pint": "^1.0",
         "spatie/ray": "^1.28"

src/Client.php

@@ -2,7 +2,31 @@
 
 namespace HeyJorgeDev\QStash;
 
-class Client
+use HeyJorgeDev\QStash\Contracts\ClientInterface;
+use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
+use HeyJorgeDev\QStash\Contracts\Resources\QueueInterface;
+use HeyJorgeDev\QStash\Contracts\Resources\ScheduleInterface;
+use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+use HeyJorgeDev\QStash\Resources\MessageResource;
+use HeyJorgeDev\QStash\Resources\QueueResource;
+use HeyJorgeDev\QStash\Resources\ScheduleResource;
+
+class Client implements ClientInterface
 {
-    public function __construct(string $token) {}
+    public function __construct(private readonly TransporterInterface $transporter) {}
+
+    public function queues(): QueueInterface
+    {
+        return new QueueResource($this->transporter);
+    }
+
+    public function schedules(): ScheduleInterface
+    {
+        return new ScheduleResource($this->transporter);
+    }
+
+    public function messages(): MessageInterface
+    {
+        return new MessageResource($this->transporter);
+    }
 }

src/Contracts/ClientInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts;
+
+use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
+use HeyJorgeDev\QStash\Contracts\Resources\QueueInterface;
+use HeyJorgeDev\QStash\Contracts\Resources\ScheduleInterface;
+
+interface ClientInterface
+{
+    public function queues(): QueueInterface;
+
+    public function schedules(): ScheduleInterface;
+
+    public function messages(): MessageInterface;
+}

src/Contracts/ReceiverInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts;
+
+interface ReceiverInterface
+{
+    public function verify(): bool;
+}

src/Contracts/Resources/MessageInterface.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts\Resources;
+
+interface MessageInterface
+{
+    public function publish();
+
+    public function enqueue();
+
+    public function batch();
+
+    public function get(string $messageId);
+
+    public function cancel(string $messageId);
+
+    /**
+     * @param  array<string>  $messageIds
+     */
+    public function bulkCancel(array $messageIds);
+}

src/Contracts/Resources/QueueInterface.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts\Resources;
+
+interface QueueInterface
+{
+    public function list();
+
+    public function get(string $queueName);
+
+    public function delete(string $queueName);
+}

src/Contracts/Resources/ScheduleInterface.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts\Resources;
+
+interface ScheduleInterface
+{
+    public function list();
+
+    public function get(string $scheduleName);
+
+    public function delete(string $scheduleName);
+
+    // public function create(string $scheduleName, string $scheduleTime);
+}

src/Contracts/TransporterInterface.php

@@ -0,0 +1,5 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Contracts;
+
+interface TransporterInterface {}

src/Factory.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace HeyJorgeDev\QStash;
+
+use HeyJorgeDev\QStash\Transporters\HttpTransporter;
+use Psr\Http\Client\ClientInterface as HttpClientInterface;
+
+class Factory
+{
+    private ?string $apiKey = null;
+
+    private ?HttpClientInterface $httpClient = null;
+
+    public function withApiKey(string $apiKey): Factory
+    {
+        $this->apiKey = $apiKey;
+
+        return $this;
+    }
+
+    public function make(): Client
+    {
+        return new Client(new HttpTransporter());
+    }
+}

src/QStash.php

@@ -4,8 +4,15 @@
 
 class QStash
 {
-    public static function client(string $token): Client
+    public static function client(string $apiKey): Client
     {
-        return new Client($token);
+        return self::factory()
+            ->withApiKey($apiKey)
+            ->make();
+    }
+
+    public static function factory(): Factory
+    {
+        return new Factory();
     }
 }

src/Receiver.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace HeyJorgeDev\QStash;
+
+use HeyJorgeDev\QStash\Contracts\ReceiverInterface;
+
+class Receiver implements ReceiverInterface
+{
+    public function verify(): bool
+    {
+        return false;
+    }
+}

src/Resources/MessageResource.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Resources;
+
+use HeyJorgeDev\QStash\Contracts\Resources\MessageInterface;
+use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+
+class MessageResource implements MessageInterface
+{
+    public function __construct(private readonly TransporterInterface $transporter) {}
+
+    public function publish()
+    {
+        // TODO: Implement publish() method.
+    }
+
+    public function enqueue()
+    {
+        // TODO: Implement enqueue() method.
+    }
+
+    public function batch()
+    {
+        // TODO: Implement batch() method.
+    }
+
+    public function get(string $messageId)
+    {
+        // TODO: Implement get() method.
+    }
+
+    public function cancel(string $messageId)
+    {
+        // TODO: Implement cancel() method.
+    }
+
+    public function bulkCancel(array $messageIds)
+    {
+        // TODO: Implement bulkCancel() method.
+    }
+}

src/Resources/QueueResource.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Resources;
+
+use HeyJorgeDev\QStash\Contracts\Resources\QueueInterface;
+use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+
+class QueueResource implements QueueInterface
+{
+    public function __construct(private readonly TransporterInterface $transporter) {}
+
+    public function list()
+    {
+        // TODO: Implement list() method.
+    }
+
+    public function get(string $queueName)
+    {
+        // TODO: Implement get() method.
+    }
+
+    public function delete(string $queueName)
+    {
+        // TODO: Implement delete() method.
+    }
+}

src/Resources/ScheduleResource.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Resources;
+
+use HeyJorgeDev\QStash\Contracts\Resources\ScheduleInterface;
+use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+
+class ScheduleResource implements ScheduleInterface
+{
+    public function __construct(private readonly TransporterInterface $transporter) {}
+
+    public function list()
+    {
+        // TODO: Implement list() method.
+    }
+
+    public function get(string $scheduleName)
+    {
+        // TODO: Implement get() method.
+    }
+
+    public function delete(string $scheduleName)
+    {
+        // TODO: Implement delete() method.
+    }
+}

src/Transporters/HttpTransporter.php

@@ -0,0 +1,7 @@
+<?php
+
+namespace HeyJorgeDev\QStash\Transporters;
+
+use HeyJorgeDev\QStash\Contracts\TransporterInterface;
+
+class HttpTransporter implements TransporterInterface {}