Merge pull request #36 from run-as-root/feature/#35-rename-message-table

[#35] - Rename the message table

Author: cristiano-pacheco

composer.json

@@ -62,6 +62,7 @@
         "sniffer": "vendor/bin/phpcs --colors -p ./src --standard=phpcs-ruleset.xml",
         "fix-style": "vendor/bin/phpcbf --colors -p ./src --standard=phpcs-ruleset.xml",
         "sniffer:php8.1": "vendor/bin/phpcs -p ./src --standard=vendor/phpcompatibility/php-compatibility/PHPCompatibility --runtime-set testVersion 8.1",
+        "sniffer:php8.2": "vendor/bin/phpcs -p ./src --standard=vendor/phpcompatibility/php-compatibility/PHPCompatibility --runtime-set testVersion 8.2",
         "mess-detector": "vendor/bin/phpmd src html phpmd-ruleset.xml --exclude \"Test\" --strict --reportfile reports/phpmd/phpmd.html"
     }
 }

src/Api/Data/MessageInterface.php renamed to src/Api/Data/QueueErrorMessageInterface.php

@@ -4,9 +4,9 @@
 
 namespace RunAsRoot\MessageQueueRetry\Api\Data;
 
-interface MessageInterface
+interface QueueErrorMessageInterface
 {
-    public const TABLE_NAME = 'run_as_root_message';
+    public const TABLE_NAME = 'run_as_root_queue_error_message';
     public const ENTITY_ID = 'entity_id';
     public const TOPIC_NAME = 'topic_name';
     public const MESSAGE_BODY = 'message_body';

src/Builder/MessageBodyDownloadFileNameBuilder.php

@@ -4,11 +4,11 @@
 
 namespace RunAsRoot\MessageQueueRetry\Builder;
 
-use RunAsRoot\MessageQueueRetry\Model\Message;
+use RunAsRoot\MessageQueueRetry\Model\QueueErrorMessage;
 
 class MessageBodyDownloadFileNameBuilder
 {
-    public function build(Message $message): string
+    public function build(QueueErrorMessage $message): string
     {
         return $message->getTopicName() . '_' . $message->getId() . '.json';
     }

src/Controller/Adminhtml/Index/Index.php

@@ -24,7 +24,7 @@ public function execute(): Page
     {
         /** @var \Magento\Backend\Model\View\Result\Page $resultPage */
         $resultPage = $this->resultPageFactory->create();
-        $resultPage->getConfig()->getTitle()->prepend(__('Messages')->render());
+        $resultPage->getConfig()->getTitle()->prepend(__('Queue Error Messages')->render());
         $resultPage->setActiveMenu('RunAsRoot_MessageQueueRetry::message_queue_retry');
 
         return $resultPage;

src/Controller/Adminhtml/Message/Download.php

@@ -10,18 +10,18 @@
 use Magento\Framework\Controller\Result\RawFactory;
 use RunAsRoot\MessageQueueRetry\Exception\EmptyQueueMessageBodyException;
 use RunAsRoot\MessageQueueRetry\Exception\MessageNotFoundException;
-use RunAsRoot\MessageQueueRetry\Mapper\MessageToRawResponseMapper;
-use RunAsRoot\MessageQueueRetry\Repository\MessageRepository;
+use RunAsRoot\MessageQueueRetry\Mapper\QueueErrorMessageToRawResponseMapper;
+use RunAsRoot\MessageQueueRetry\Repository\QueueErrorMessageRepository;
 
 class Download extends Action
 {
     public const ADMIN_RESOURCE = 'RunAsRoot_MessageQueueRetry::download';
 
     public function __construct(
         Context $context,
-        private MessageRepository $messageRepository,
+        private QueueErrorMessageRepository $messageRepository,
         private RawFactory $rawFactory,
-        private MessageToRawResponseMapper $messageToRawResponseMapper
+        private QueueErrorMessageToRawResponseMapper $messageToRawResponseMapper
     ) {
         parent::__construct($context);
     }

src/Controller/Adminhtml/Message/MassDelete.php

@@ -8,20 +8,21 @@
 use Magento\Backend\App\Action\Context;
 use Magento\Framework\Controller\Result\Redirect;
 use Magento\Framework\Controller\Result\RedirectFactory;
+use Magento\Framework\Data\Collection\AbstractDb;
 use Magento\Ui\Component\MassAction\Filter;
-use RunAsRoot\MessageQueueRetry\Model\Message;
-use RunAsRoot\MessageQueueRetry\Model\ResourceModel\Message\MessageCollectionFactory;
-use RunAsRoot\MessageQueueRetry\Repository\MessageRepository;
+use RunAsRoot\MessageQueueRetry\Model\QueueErrorMessage;
+use RunAsRoot\MessageQueueRetry\Model\ResourceModel\QueueErrorMessage\QueueErrorMessageCollectionFactory;
+use RunAsRoot\MessageQueueRetry\Repository\QueueErrorMessageRepository;
 
 class MassDelete extends Action
 {
     public const ADMIN_RESOURCE = 'RunAsRoot_MessageQueueRetry::mass_delete';
 
     public function __construct(
         Context $context,
-        private MessageRepository $messageRepository,
+        private QueueErrorMessageRepository $messageRepository,
         private RedirectFactory $redirectFactory,
-        private MessageCollectionFactory $collectionFactory,
+        private QueueErrorMessageCollectionFactory $collectionFactory,
         private Filter $filter
     ) {
         parent::__construct($context);
@@ -32,10 +33,12 @@ public function execute(): Redirect
         $redirect = $this->redirectFactory->create();
 
         try {
-            $collection = $this->filter->getCollection($this->collectionFactory->create());
+            /** @var AbstractDb $messageCollection */
+            $messageCollection = $this->collectionFactory->create();
+            $collection = $this->filter->getCollection($messageCollection);
 
             foreach ($collection->getItems() as $message) {
-                if (!$message instanceof Message) {
+                if (!$message instanceof QueueErrorMessage) {
                     continue;
                 }
 

src/Controller/Adminhtml/Message/MassRequeue.php

@@ -8,9 +8,10 @@
 use Magento\Backend\App\Action\Context;
 use Magento\Framework\Controller\Result\Redirect;
 use Magento\Framework\Controller\Result\RedirectFactory;
+use Magento\Framework\Data\Collection\AbstractDb;
 use Magento\Ui\Component\MassAction\Filter;
-use RunAsRoot\MessageQueueRetry\Model\Message;
-use RunAsRoot\MessageQueueRetry\Model\ResourceModel\Message\MessageCollectionFactory;
+use RunAsRoot\MessageQueueRetry\Model\QueueErrorMessage;
+use RunAsRoot\MessageQueueRetry\Model\ResourceModel\QueueErrorMessage\QueueErrorMessageCollectionFactory;
 use RunAsRoot\MessageQueueRetry\Service\PublishMessageToQueueService;
 
 class MassRequeue extends Action
@@ -21,7 +22,7 @@ public function __construct(
         Context $context,
         private PublishMessageToQueueService $publishMessageToQueueService,
         private RedirectFactory $redirectFactory,
-        private MessageCollectionFactory $collectionFactory,
+        private QueueErrorMessageCollectionFactory $collectionFactory,
         private Filter $filter
     ) {
         parent::__construct($context);
@@ -32,10 +33,12 @@ public function execute(): Redirect
         $redirect = $this->redirectFactory->create();
 
         try {
-            $collection = $this->filter->getCollection($this->collectionFactory->create());
+            /** @var AbstractDb $messageCollection */
+            $messageCollection = $this->collectionFactory->create();
+            $collection = $this->filter->getCollection($messageCollection);
 
             foreach ($collection->getItems() as $message) {
-                if (!$message instanceof Message) {
+                if (!$message instanceof QueueErrorMessage) {
                     continue;
                 }
 

src/Mapper/MessageToRawResponseMapper.php renamed to src/Mapper/QueueErrorMessageToRawResponseMapper.php

@@ -7,9 +7,9 @@
 use Magento\Framework\Controller\Result\Raw as RawResponse;
 use RunAsRoot\MessageQueueRetry\Builder\MessageBodyDownloadFileNameBuilder;
 use RunAsRoot\MessageQueueRetry\Exception\EmptyQueueMessageBodyException;
-use RunAsRoot\MessageQueueRetry\Model\Message;
+use RunAsRoot\MessageQueueRetry\Model\QueueErrorMessage;
 
-class MessageToRawResponseMapper
+class QueueErrorMessageToRawResponseMapper
 {
     public function __construct(
         private MessageBodyDownloadFileNameBuilder $messageBodyDownloadFileNameBuilder
@@ -19,7 +19,7 @@ public function __construct(
     /**
      * @throws EmptyQueueMessageBodyException
      */
-    public function map(Message $message, RawResponse $rawResponse): RawResponse
+    public function map(QueueErrorMessage $message, RawResponse $rawResponse): RawResponse
     {
         $messageBody = $message->getMessageBody();
 

src/Model/Message.php renamed to src/Model/QueueErrorMessage.php

@@ -5,11 +5,11 @@
 namespace RunAsRoot\MessageQueueRetry\Model;
 
 use Magento\Framework\Model\AbstractModel;
-use RunAsRoot\MessageQueueRetry\Api\Data\MessageInterface;
-use RunAsRoot\MessageQueueRetry\Model\ResourceModel\Message\MessageCollection;
-use RunAsRoot\MessageQueueRetry\Model\ResourceModel\MessageResource;
+use RunAsRoot\MessageQueueRetry\Api\Data\QueueErrorMessageInterface;
+use RunAsRoot\MessageQueueRetry\Model\ResourceModel\QueueErrorMessage\QueueErrorMessageCollection;
+use RunAsRoot\MessageQueueRetry\Model\ResourceModel\QueueErrorMessageResource;
 
-class Message extends AbstractModel implements MessageInterface
+class QueueErrorMessage extends AbstractModel implements QueueErrorMessageInterface
 {
     public function getTopicName(): string
     {
@@ -73,7 +73,7 @@ public function setCreatedAt(string $value): void
 
     protected function _construct(): void
     {
-        $this->_init(MessageResource::class);
-        $this->_collectionName = MessageCollection::class;
+        $this->_init(QueueErrorMessageResource::class);
+        $this->_collectionName = QueueErrorMessageCollection::class;
     }
 }