initial test

Author: iamfarhad

composer.json

@@ -5,13 +5,16 @@
     "type": "library",
     "require": {
         "php": "^8.1",
+      "illuminate/queue": "^9.0",
         "php-amqplib/php-amqplib": "^3.4",
-        "illuminate/queue": "^9.0"
+        "illuminate/support": "^9.18"
     },
     "require-dev": {
         "ext-json": "*",
         "phpunit/phpunit": "^9.5",
-        "squizlabs/php_codesniffer": "^3.7"
+        "squizlabs/php_codesniffer": "^3.7",
+        "mockery/mockery": "^1.5.1",
+        "dg/bypass-finals": "dev-master"
     },
     "autoload": {
         "psr-4": {
@@ -20,7 +23,7 @@
     },
     "autoload-dev": {
         "psr-4": {
-            "iamfarhad\\LaravelRabbitMQ\\Tests\\Unit\\": "tests/Unit"
+            "iamfarhad\\LaravelRabbitMQ\\Tests\\": "tests/"
         }
     },
     "extra": {

Config/RabbitMQConnectionConfig.php renamed to config/RabbitMQConnectionConfig.php

@@ -1,8 +1,11 @@
 <?xml version="1.0"?>
 <ruleset name="PHP_CodeSniffer">
     <description>The coding standard for our project.</description>
+    <file>src</file>
+    <file>tests</file>
+
     <rule ref="PSR12"/>
-    <exclude-pattern>tests/*</exclude-pattern>
+
 
     <!-- Show progression -->
     <arg value="p"/>
@@ -12,6 +15,4 @@
         <exclude name="Generic.WhiteSpace.DisallowTabIndent"/>
         <exclude name="Generic.Files.LineLength"/>
     </rule>
-
-    <file>src</file>
 </ruleset>

phpcs.xml

@@ -14,12 +14,13 @@
     </coverage>
     <testsuites>
         <testsuite name="Package Test Suite">
-            <directory suffix=".php">./tests/</directory>
+            <directory suffix="Test.php">./tests/</directory>
         </testsuite>
     </testsuites>
     <php>
-        <env name="HOST" value="127.0.0.1"/>
-        <env name="PORT" value="5672"/>
+        <env name="RABBITMQ_HOST" value="127.0.0.1"/>
+        <env name="QUEUE_CONNECTION" value="rabbitmq"/>
+        <env name="RABBITMQ_PORT" value="5672"/>
         <env name="PORT_SSL" value="5671"/>
         <env name="RABBITMQ_SSL_CAFILE" value="./tests/files/rootCA.pem"/>
     </php>

phpunit.xml.dist

@@ -10,11 +10,12 @@
 use PhpAmqpLib\Connection\AMQPConnectionConfig;
 use PhpAmqpLib\Connection\AMQPConnectionFactory;
 
-final class RabbitMQConnector implements ConnectorInterface
+class RabbitMQConnector implements ConnectorInterface
 {
     public function __construct(private readonly Dispatcher $dispatcher)
     {
-    }
+    }//end __construct()
+
 
     public function connect(array $config = []): Queue
     {
@@ -31,7 +32,6 @@ public function connect(array $config = []): Queue
         $amqpConnectionConfig->setKeepalive(config('queue.connections.rabbitmq.hosts.keepalive'));
         $amqpConnectionConfig->setHeartbeat(config('queue.connections.rabbitmq.hosts.heartbeat'));
 
-
         // set SSL Options
         $amqpConnectionConfig->setSslCaCert(config('queue.connections.rabbitmq.options.ssl_options.cafile'));
         $amqpConnectionConfig->setSslCert(config('queue.connections.rabbitmq.options.ssl_options.local_cert'));
@@ -40,15 +40,13 @@ public function connect(array $config = []): Queue
         $amqpConnectionConfig->setSslPassPhrase(config('queue.connections.rabbitmq.options.ssl_options.passphrase'));
 
         // Create AMQP Connection
-        $connection = AMQPConnectionFactory::create($amqpConnectionConfig);
+        $connection   = AMQPConnectionFactory::create($amqpConnectionConfig);
         $defaultQueue = config('queue.connections.rabbitmq.queue');
 
         $rabbitQueue = new RabbitQueue($connection, $defaultQueue);
 
-        $this->dispatcher->listen(WorkerStopping::class, static function () use ($rabbitQueue): void {
-            $rabbitQueue->close();
-        });
+        $this->dispatcher->listen(WorkerStopping::class, fn() => $rabbitQueue->close());
 
         return $rabbitQueue;
-    }
-}
+    }//end connect()
+}//end class

src/Connectors/RabbitMQConnector.php

@@ -34,9 +34,12 @@ final class ConsumeCommand extends WorkCommand
 
     protected $description = 'Consume messages';
 
+
     public function handle(): void
     {
-        /** @var Consumer $consumer */
+        /*
+         * @var Consumer $consumer
+         */
         $consumer = $this->worker;
 
         $consumer->setContainer($this->laravel);
@@ -47,20 +50,24 @@ public function handle(): void
         $consumer->setPrefetchCount((int) $this->option('prefetch-count'));
 
         parent::handle();
-    }
+    }//end handle()
+
 
     private function consumerTag(): string
     {
         if ($consumerTag = $this->option('consumer-tag')) {
             return $consumerTag;
         }
 
-        $consumerTag = implode('_', [
-            Str::slug(config('app.name', 'laravel')),
-            Str::slug($this->option('name')),
-            md5(serialize($this->options()) . Str::random(16) . getmypid()),
-        ]);
+        $consumerTag = implode(
+            '_',
+            [
+                Str::slug(config('app.name', 'laravel')),
+                Str::slug($this->option('name')),
+                md5(serialize($this->options()) . Str::random(16) . getmypid()),
+            ]
+        );
 
         return Str::substr($consumerTag, 0, 255);
-    }
-}
+    }//end consumerTag()
+}//end class

src/Console/ConsumeCommand.php

@@ -12,7 +12,7 @@
 use Throwable;
 use iamfarhad\LaravelRabbitMQ\RabbitQueue;
 
-final class Consumer extends Worker
+class Consumer extends Worker
 {
     private Container $container;
 
@@ -26,38 +26,44 @@ final class Consumer extends Worker
 
     private AMQPChannel $amqpChannel;
 
-    private ?object $currentJob = null;
+    private object|null $currentJob = null;
+
 
     public function setContainer(Container $container): void
     {
         $this->container = $container;
-    }
+    }//end setContainer()
+
 
     public function setConsumerTag(string $value): void
     {
         $this->consumerTag = $value;
-    }
+    }//end setConsumerTag()
+
 
     public function setMaxPriority(int $value): void
     {
         $this->maxPriority = $value;
-    }
+    }//end setMaxPriority()
+
 
     public function setPrefetchSize(int $value): void
     {
         $this->prefetchSize = $value;
-    }
+    }//end setPrefetchSize()
+
 
     public function setPrefetchCount(int $value): void
     {
         $this->prefetchCount = $value;
-    }
+    }//end setPrefetchCount()
+
 
     /**
      * Listen to the given queue in a loop.
      *
-     * @param  string  $connectionName
-     * @param  string  $queue
+     * @param  string $connectionName
+     * @param  string $queue
      * @return int
      * @throws Throwable
      */
@@ -68,7 +74,7 @@ public function daemon($connectionName, $queue, WorkerOptions $workerOptions)
         }
 
         $timestampOfLastQueueRestart = $this->getTimestampOfLastQueueRestart();
-        $startTime = hrtime(true) / 1e9;
+        $startTime     = (hrtime(true) / 1e9);
         $jobsProcessed = 0;
 
         $connection = $this->manager->connection($connectionName);
@@ -82,10 +88,13 @@ public function daemon($connectionName, $queue, WorkerOptions $workerOptions)
             null
         );
 
-        $jobClass = $connection->getJobClass();
+        $jobClass  = $connection->getJobClass();
         $arguments = [];
         if ($this->maxPriority !== 0) {
-            $arguments['priority'] = ['I', $this->maxPriority];
+            $arguments['priority'] = [
+                'I',
+                $this->maxPriority,
+            ];
         }
 
         $this->amqpChannel->basic_consume(
@@ -166,19 +175,21 @@ function (AMQPMessage $amqpMessage) use ($connection, $workerOptions, $connectio
             }
 
             $this->currentJob = null;
-        }
-    }
+        }//end while
+    }//end daemon()
+
 
     /**
      * Determine if the daemon should process on this iteration.
      *
-     * @param  string  $connectionName
-     * @param  string  $queue
+     * @param string $connectionName
+     * @param string $queue
      */
     protected function daemonShouldRun(WorkerOptions $workerOptions, $connectionName, $queue): bool
     {
         return !(($this->isDownForMaintenance)() && ! $workerOptions->force) && !$this->paused;
-    }
+    }//end daemonShouldRun()
+
 
     public function stop($status = 0, $options = []): int
     {
@@ -187,5 +198,5 @@ public function stop($status = 0, $options = []): int
         $this->amqpChannel->basic_cancel($this->consumerTag, false, true);
 
         return parent::stop($status);
-    }
-}
+    }//end stop()
+}//end class