Fix styling

Author: iamfarhad

.php-cs-fixer.cache

@@ -0,0 +1 @@
+{"php":"8.3.19","version":"3.74.0","indent":"    ","lineEnding":"\n","rules":{"blank_line_after_namespace":true,"braces_position":true,"class_definition":true,"constant_case":true,"control_structure_braces":true,"control_structure_continuation_position":true,"elseif":true,"function_declaration":true,"indentation_type":true,"line_ending":true,"lowercase_keywords":true,"method_argument_space":{"on_multiline":"ensure_fully_multiline","keep_multiple_spaces_after_comma":true},"no_break_comment":true,"no_closing_tag":true,"no_multiple_statements_per_line":true,"no_space_around_double_colon":true,"no_spaces_after_function_name":true,"no_trailing_whitespace":true,"no_trailing_whitespace_in_comment":true,"single_blank_line_at_eof":true,"single_class_element_per_statement":{"elements":["property"]},"single_import_per_statement":true,"single_line_after_imports":true,"single_space_around_construct":{"constructs_followed_by_a_single_space":["abstract","as","case","catch","class","do","else","elseif","final","for","foreach","function","if","interface","namespace","private","protected","public","static","switch","trait","try","use_lambda","while"],"constructs_preceded_by_a_single_space":["as","else","elseif","use_lambda"]},"spaces_inside_parentheses":true,"statement_indentation":true,"switch_case_semicolon_to_colon":true,"switch_case_space":true,"visibility_required":{"elements":["method","property"]},"encoding":true,"full_opening_tag":true,"array_syntax":{"syntax":"short"},"ordered_imports":{"sort_algorithm":"alpha"},"no_unused_imports":true,"not_operator_with_successor_space":true,"trailing_comma_in_multiline":true,"phpdoc_scalar":true,"unary_operator_spaces":true,"binary_operator_spaces":true,"blank_line_before_statement":{"statements":["break","continue","declare","return","throw","try"]},"phpdoc_single_line_var_spacing":true,"phpdoc_var_without_name":true,"class_attributes_separation":{"elements":{"method":"one"}},"single_trait_insert_per_statement":true},"hashes":{"src\/Jobs\/RabbitMQJob.php":"c3afbc43c2505f068ba7d2d64ba4291b","src\/LaravelRabbitQueueServiceProvider.php":"5652444609c18a3ccdaeba6985b6e7b9","src\/Console\/ConsumeCommand.php":"cbc6b4ed6361a6a39f6519c799d729c0","src\/Consumer.php":"0d22cd50a408fb150b1e44b21291e36d","src\/RabbitQueue.php":"946b594c375156d0494d439aae4f4aa9","src\/Connectors\/RabbitMQConnector.php":"88258e9a1e9e67186d5d2fcae2909a16","tests\/Unit\/Jobs\/RabbitMQJobTest.php":"d437204178ea222b5b30ce3cf0e68122","tests\/Unit\/Connectors\/RabbitMQConnectorTest.php":"85a890942d7d01fb7fb2aca1a37eb2b1","tests\/FeatureTestCase.php":"afb73259bdd41338106efaa175bc7270","tests\/Mocks\/TestJobMock.php":"3fe41f6a18136dee6b6290f310d078dc","tests\/UnitTestCase.php":"136c46197b8084cecd8ff16f3b3dcb46","tests\/Feature\/RabbitMQQueueTest.php":"d6bbfbf1e11350fba94a5552136adb83","tests\/Feature\/Connector\/RabbitMQConnectorTest.php":"21de35c448fd6b7936207acd527b1bd4"}}

src/Connectors/RabbitMQConnector.php

@@ -2,13 +2,13 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Connectors;
 
-use Illuminate\Queue\Connectors\ConnectorInterface;
-use PhpAmqpLib\Connection\AMQPConnectionFactory;
-use PhpAmqpLib\Connection\AMQPConnectionConfig;
-use Illuminate\Contracts\Events\Dispatcher;
-use Illuminate\Queue\Events\WorkerStopping;
 use iamfarhad\LaravelRabbitMQ\RabbitQueue;
+use Illuminate\Contracts\Events\Dispatcher;
 use Illuminate\Contracts\Queue\Queue;
+use Illuminate\Queue\Connectors\ConnectorInterface;
+use Illuminate\Queue\Events\WorkerStopping;
+use PhpAmqpLib\Connection\AMQPConnectionConfig;
+use PhpAmqpLib\Connection\AMQPConnectionFactory;
 
 readonly class RabbitMQConnector implements ConnectorInterface
 {
@@ -39,12 +39,12 @@ 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, fn() => $rabbitQueue->close());
+        $this->dispatcher->listen(WorkerStopping::class, fn () => $rabbitQueue->close());
 
         return $rabbitQueue;
     }

src/Console/ConsumeCommand.php

@@ -4,10 +4,10 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Console;
 
-use Symfony\Component\Console\Attribute\AsCommand;
 use Illuminate\Queue\Console\WorkCommand;
 use Illuminate\Support\Str;
 use RuntimeException;
+use Symfony\Component\Console\Attribute\AsCommand;
 
 #[AsCommand(name: 'rabbitmq:consume')]
 final class ConsumeCommand extends WorkCommand
@@ -56,6 +56,7 @@ public function handle(): int
 
         if ($numProcesses < 1) {
             $this->error('Number of processes must be at least 1');
+
             return 1;
         }
 
@@ -65,8 +66,9 @@ public function handle(): int
         }
 
         // Check if pcntl extension is available
-        if (!extension_loaded('pcntl')) {
+        if (! extension_loaded('pcntl')) {
             $this->error('The pcntl extension is required for parallel processing');
+
             return 1;
         }
 
@@ -77,6 +79,7 @@ public function handle(): int
 
             if ($pid === -1) {
                 $this->error("Failed to fork process $i");
+
                 continue;
             }
 
@@ -126,7 +129,7 @@ private function consume(): int
         try {
             $consumer = $this->worker;
 
-            if (!$consumer) {
+            if (! $consumer) {
                 throw new RuntimeException('Worker instance not initialized');
             }
 
@@ -147,6 +150,7 @@ private function consume(): int
             return parent::handle() ?? 0;
         } catch (\Throwable $e) {
             $this->error($e->getMessage());
+
             return 1;
         }
     }

src/Consumer.php

@@ -10,7 +10,6 @@
 use PhpAmqpLib\Exception\AMQPRuntimeException;
 use PhpAmqpLib\Message\AMQPMessage;
 use Throwable;
-use iamfarhad\LaravelRabbitMQ\RabbitQueue;
 
 class Consumer extends Worker
 {
@@ -28,7 +27,6 @@ class Consumer extends Worker
 
     private object|null $currentJob = null;
 
-
     public function setContainer(Container $container): void
     {
         $this->container = $container;
@@ -44,19 +42,16 @@ public function setMaxPriority(int $value): void
         $this->maxPriority = $value;
     }
 
-
     public function setPrefetchSize(int $value): void
     {
         $this->prefetchSize = $value;
     }
 
-
     public function setPrefetchCount(int $value): void
     {
         $this->prefetchCount = $value;
     }
 
-
     /**
      * Listen to the given queue in a loop.
      *
@@ -72,7 +67,7 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
         }
 
         $timestampOfLastQueueRestart = $this->getTimestampOfLastQueueRestart();
-        $startTime     = (hrtime(true) / 1e9);
+        $startTime = (hrtime(true) / 1e9);
         $jobsProcessed = 0;
 
         $connection = $this->manager->connection($connectionName);
@@ -86,7 +81,7 @@ public function daemon($connectionName, $queue, WorkerOptions $options)
             null
         );
 
-        $jobClass  = $connection->getJobClass();
+        $jobClass = $connection->getJobClass();
         $arguments = [];
         if ($this->maxPriority !== 0) {
             $arguments['priority'] = [
@@ -184,10 +179,9 @@ function (AMQPMessage $amqpMessage) use ($connection, $options, $connectionName,
      */
     protected function daemonShouldRun(WorkerOptions $options, $connectionName, $queue): bool
     {
-        return !(($this->isDownForMaintenance)() && ! $options->force) && !$this->paused;
+        return ! (($this->isDownForMaintenance)() && ! $options->force) && ! $this->paused;
     }
 
-
     public function stop($status = 0, $options = []): int
     {
         // Tell the server you are going to stop consuming.

src/Jobs/RabbitMQJob.php

@@ -2,30 +2,29 @@
 
 namespace iamfarhad\LaravelRabbitMQ\Jobs;
 
-use Illuminate\Contracts\Queue\Job as JobContract;
 use iamfarhad\LaravelRabbitMQ\RabbitQueue;
 use Illuminate\Container\Container;
-use PhpAmqpLib\Message\AMQPMessage;
+use Illuminate\Contracts\Queue\Job as JobContract;
 use Illuminate\Queue\Jobs\Job;
 use Illuminate\Support\Arr;
 use JsonException;
+use PhpAmqpLib\Message\AMQPMessage;
 
 final class RabbitMQJob extends Job implements JobContract
 {
     private readonly array $decoded;
 
-
     public function __construct(
         Container $container,
         protected RabbitQueue $rabbitQueue,
         protected AMQPMessage $amqpMessage,
         string $connectionName,
         string $queue
     ) {
-        $this->container      = $container;
+        $this->container = $container;
         $this->connectionName = $connectionName;
-        $this->queue          = $queue;
-        $this->decoded        = $this->payload();
+        $this->queue = $queue;
+        $this->decoded = $this->payload();
     }
 
     /**
@@ -58,7 +57,6 @@ public function attempts(): int
         return ($laravelAttempts + 1);
     }
 
-
     /**
      * @throws JsonException
      */

src/LaravelRabbitQueueServiceProvider.php

@@ -4,7 +4,7 @@
 
 use iamfarhad\LaravelRabbitMQ\Connectors\RabbitMQConnector;
 use iamfarhad\LaravelRabbitMQ\Console\ConsumeCommand;
-use iamfarhad\LaravelRabbitMQ\Consumer; // Added missing import
+// Added missing import
 use Illuminate\Contracts\Debug\ExceptionHandler;
 use Illuminate\Support\ServiceProvider;
 
@@ -19,7 +19,7 @@ public function register(): void
 
         if ($this->app->runningInConsole()) {
             $this->app->singleton('rabbitmq.consumer', function ($app): Consumer {
-                $isDownForMaintenance = fn(): bool => $app->isDownForMaintenance();
+                $isDownForMaintenance = fn (): bool => $app->isDownForMaintenance();
 
                 return new Consumer(
                     $app['queue'],