add some tests and fix consumer bug

Author: Farhad.Zand

composer.json

@@ -7,7 +7,8 @@
         "php": "^8.1",
         "illuminate/queue": "^9.0|^10.0",
         "php-amqplib/php-amqplib": "^3.6.0",
-        "illuminate/support": "^9.18|^10.0"
+        "illuminate/support": "^9.18|^10.0",
+        "ext-pcntl": "Required to use all features of the queue consumer."
     },
     "require-dev": {
         "ext-json": "*",
@@ -44,6 +45,5 @@
     ],
     "minimum-stability": "dev",
     "suggest": {
-        "ext-pcntl": "Required to use all features of the queue consumer."
     }
 }

src/Console/ConsumeCommand.php

@@ -45,20 +45,21 @@ public function handle(): int|null
                 // Error handling
                 echo "Could not fork process \n";
                 exit(1);
-            } elseif ($pid === 0) {
+            }
+
+            if ($pid === 0) {
                 // This is the child process
                 $this->consume();
                 exit(0);
             }
         }
 
         // Wait for all child processes to finish
-        while (pcntl_waitpid(0, $status) !== -1) {
+//        while (pcntl_waitpid(0, $status) !== -1) {
             // Handle exit status if needed
-        }
+//        }
 
         return 0;
-        ;
     }
 
     private function consume(): void

tests/Feature/RabbitMQQueueTest.php

@@ -4,8 +4,11 @@
 
 use iamfarhad\LaravelRabbitMQ\Tests\FeatureTestCase;
 use iamfarhad\LaravelRabbitMQ\Tests\Mocks\TestJobMock;
+use iamfarhad\LaravelRabbitMQ\Connectors\RabbitMQConnector;
+use Illuminate\Contracts\Events\Dispatcher;
+use Illuminate\Queue\Events\WorkerStopping;
 use Illuminate\Support\Facades\Bus;
-use Illuminate\Support\Facades\Queue;
+use Illuminate\Queue\Queue;
 use iamfarhad\LaravelRabbitMQ\Consumer;
 use Mockery;
 
@@ -21,7 +24,42 @@ protected function setUp(): void
         $this->connection = $getQueueInstance->connection('rabbitmq');
     }
 
-    public function testConsumeMethod()
+    public function testConnect(): void
+    {
+        $dispatcher = Mockery::mock(Dispatcher::class);
+
+        $dispatcher->expects('listen')
+            ->with(WorkerStopping::class, Mockery::any());
+
+        $connector = new RabbitMQConnector($dispatcher);
+        $config = [
+            'hosts' => [
+                'host' => 'localhost',
+                'port' => 5672,
+                'user' => 'guest',
+                'password' => 'guest',
+                'vhost' => '/',
+                'lazy' => false,
+                'keepalive' => false,
+                'heartbeat' => 60,
+            ],
+            'options' => [
+                'ssl_options' => [
+                    'cafile' => 'path/to/cafile',
+                    'local_cert' => 'path/to/local_cert',
+                    'local_key' => 'path/to/local_key',
+                    'verify_peer' => true,
+                    'passphrase' => 'your_passphrase',
+                ],
+            ],
+        ];
+
+        $queue = $connector->connect($config);
+
+        $this->assertInstanceOf(Queue::class, $queue);
+    }
+
+    public function testConsumeMethod(): void
     {
         // Create a Mockery mock of the Consumer class
         $consumerMock = Mockery::mock(Consumer::class);