From 9d1f3f257112d57b678b91aa7cb46939ea18fde5 Mon Sep 17 00:00:00 2001 From: Jorge Lapa <2780099+heyjorgedev@users.noreply.github.com> Date: Sat, 13 Jul 2024 13:22:15 +0100 Subject: [PATCH] wip --- src/Contracts/Resources/MessageInterface.php | 3 ++- src/Resources/MessageResource.php | 5 +++-- src/Responses/MessagePublishResponse.php | 23 ++++++++++++++++++++ 3 files changed, 28 insertions(+), 3 deletions(-) create mode 100644 src/Responses/MessagePublishResponse.php diff --git a/src/Contracts/Resources/MessageInterface.php b/src/Contracts/Resources/MessageInterface.php index 583f546..970e13a 100644 --- a/src/Contracts/Resources/MessageInterface.php +++ b/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(); diff --git a/src/Resources/MessageResource.php b/src/Resources/MessageResource.php index cd81e0e..626f0a5 100644 --- a/src/Resources/MessageResource.php +++ b/src/Resources/MessageResource.php @@ -4,6 +4,7 @@ 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; @@ -11,9 +12,9 @@ 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() diff --git a/src/Responses/MessagePublishResponse.php b/src/Responses/MessagePublishResponse.php new file mode 100644 index 0000000..56ec8db --- /dev/null +++ b/src/Responses/MessagePublishResponse.php @@ -0,0 +1,23 @@ +