up to date

Signed-off-by: bota <Bota@dotkernel.com>

Author: SergiuBota1

README.md

@@ -3,20 +3,20 @@
 > [!IMPORTANT]
 > Dotkernel component used to queue tasks to be processed asynchronously based on [netglue/laminas-messenger](https://github.com/netglue/laminas-messenger)
 
- A queue system is a vital component in modern web applications that enables the decoupling of certain tasks from the regular request-response cycle.
+A queue system is a vital part in modern web applications that enables the decoupling of certain tasks from the regular request-response cycle.
 
- This is especially useful for time-consuming and resource-intensive operations which are thus handled asynchronously by background workers on a separate system.
+This is especially useful for time-consuming and resource-intensive operations which are thus handled asynchronously by background workers on a separate system.
 
-The greatest benefit is to application responsiveness which allows faster execution, while the heavy lifting is scheduled in the queue based on available resources.
+The greatest benefit is to application responsiveness, which allows faster execution, while the heavy lifting is scheduled in the queue based on available resources.
 
- The queue system uses logs to ensure maintainability and implements retry features for reliability and stability.
+The queue system uses logs to ensure maintainability and implements retry features for reliability and stability.
 
 ![Queue process](https://docs.dotkernel.org/img/queue/schema.png)
 
 ## Badges
 
 ![OSS Lifecycle](https://img.shields.io/osslifecycle/dotkernel/queue)
-![PHP from Packagist (specify version)](https://img.shields.io/packagist/php-v/dotkernel/queue/1.0)
+![PHP from Packagist (specify version)](https://img.shields.io/packagist/php-v/dotkernel/queue/1.0.0)
 
 [![GitHub issues](https://img.shields.io/github/issues/dotkernel/queue)](https://github.com/dotkernel/queue/issues)
 [![GitHub forks](https://img.shields.io/github/forks/dotkernel/queue)](https://github.com/dotkernel/queue/network)
@@ -28,10 +28,6 @@ The greatest benefit is to application responsiveness which allows faster execut
 [![Qodana](https://github.com/dotkernel/queue/actions/workflows/qodana_code_quality.yml/badge.svg?branch=main)](https://github.com/dotkernel/queue/actions/workflows/qodana_code_quality.yml)
 [![PHPStan](https://github.com/dotkernel/queue/actions/workflows/static-analysis.yml/badge.svg?branch=main)](https://github.com/dotkernel/queue/actions/workflows/static-analysis.yml)
 
-## Installation
-
-> Until we have a compiled documentation, read the files from /doc/book/v1 folder
-
 ## Documentation
 
 Documentation is available at: https://docs.dotkernel.org/queue-documentation

composer.json

@@ -55,12 +55,12 @@
     },
     "require-dev": {
         "laminas/laminas-coding-standard": "^3.0",
-        "phpunit/phpunit": "^10.5.45",
-        "roave/security-advisories": "dev-master",
-        "swoole/ide-helper": "~5.0.0",
         "phpstan/phpstan": "^2.0",
         "phpstan/phpstan-doctrine": "^2.0",
-        "phpstan/phpstan-phpunit": "^2.0"
+        "phpstan/phpstan-phpunit": "^2.0",
+        "phpunit/phpunit": "^10.5.45",
+        "roave/security-advisories": "dev-master",
+        "swoole/ide-helper": "~5.0.0"
     },
     "autoload": {
         "psr-4": {

config/autoload/local.php.dist

@@ -9,7 +9,7 @@
 
 declare(strict_types=1);
 
-$baseUrl = 'http://queue.dotkernel.net';
+$baseUrl = 'https://queue.dotkernel.net';
 
 $databases = [
     'default' => [
@@ -43,13 +43,13 @@ return [
             'protocol' => 'tcp',
             'host'     => 'localhost',
             'port'     => '8556',
-            'eof'      => "\n",
+            'eof'      => PHP_EOL,
         ],
     ],
     //delay time until the message is added back to the queue if an error occurs during processing
     'fail-safe' => [
-            'first_retry'  => 3600000,  // 1h
-            'second_retry' => 43200000, // 12h
-            'third_retry'  => 86400000, // 24h
-        ],
+        'first_retry'  => 3600000, // 1h
+        'second_retry' => 43200000, // 12h
+        'third_retry'  => 86400000, // 24h
+    ],
 ];

config/autoload/log.local.php.dist

@@ -1,5 +1,7 @@
 <?php
 
+declare(strict_types=1);
+
 use Dot\Log\Formatter\Json;
 use Dot\Log\Logger;
 
@@ -9,17 +11,17 @@ return [
             'queue-log' => [
                 'writers' => [
                     'FileWriter' => [
-                        'name' => 'stream',
-                        'level'   => \Dot\Log\Logger::ALERT, // this is equal to 1
+                        'name'    => 'stream',
+                        'level'   => Logger::ALERT,
                         'options' => [
-                            'stream' => __DIR__ . '/../../log/queue-log.log',
+                            'stream'    => __DIR__ . '/../../log/queue-log.log',
                             'formatter' => [
                                 'name' => Json::class,
                             ],
                         ],
                     ],
                 ],
-            ]
+            ],
         ],
     ],
 ];

config/autoload/swoole.local.php.dist

@@ -1,9 +1,10 @@
 <?php
 
+declare(strict_types=1);
+
 return [
     'dotkernel-queue-swoole' => [
-        // Available in Swoole 4.1 and up; enables coroutine support
-        // for most I/O operations:
+        // Available in Swoole 4.1 and up; enables coroutine support for most I/O operations:
         'enable_coroutine' => true,
 
         // Configure Swoole TCP Server:
@@ -13,17 +14,17 @@ return [
             'mode' => SWOOLE_BASE, // SWOOLE_BASE or SWOOLE_PROCESS;
             // SWOOLE_BASE is the default
             'protocol' => SWOOLE_SOCK_TCP, // SWOOLE_SSL, // SSL-enable the server
-            'options' => [
+            'options'  => [
                 // Set the SSL certificate and key paths for SSL support:
                 //'ssl_cert_file' => 'path/to/ssl.crt',
                 //'ssl_key_file' => 'path/to/ssl.key',
-                // Whether or not the HTTP server should use coroutines;
+                // Whether the HTTP server should use coroutines;
                 // enabled by default, and generally should not be disabled:
-                'package_eof' => "\n",
-                'open_eof_check' => true,
+                'package_eof'       => PHP_EOL,
+                'open_eof_check'    => true,
                 'open_length_check' => true,
 
-               // in order to run swoole as daemon 
+                // to run swoole as a daemon
                 'daemonize' => true,
 
                 // Overwrite the default location of the pid file;

daemon/messenger.service

@@ -12,4 +12,4 @@ WorkingDirectory=/home/dotkernel/queue/
 ExecStart=/usr/bin/php /home/dotkernel/queue/bin/cli.php messenger:start
 
 [Install]
-WantedBy=swoole.service
+WantedBy=swoole.service

daemon/swoole.service

@@ -12,4 +12,4 @@ WorkingDirectory=/home/dotkernel/queue/
 ExecStart=/usr/bin/php /home/dotkernel/queue/bin/cli.php swoole:start
 
 [Install]
-WantedBy=multi-user.target
+WantedBy=multi-user.target

phpcs.xml

@@ -13,10 +13,10 @@
 
     <!-- Paths to check -->
     <file>config</file>
+    <file>public</file>
     <file>src</file>
     <file>test</file>
     <exclude-pattern>config/config.php</exclude-pattern>
-    <exclude-pattern>config/routes.php</exclude-pattern>
 
     <!-- Include all rules from the Laminas Coding Standard -->
     <rule ref="LaminasCodingStandard">

phpstan.neon

@@ -4,6 +4,8 @@ includes:
 parameters:
     level: 5
     paths:
+        - config
+        - public
         - src
         - test
     treatPhpDocTypesAsCertain: false

public/index.php

@@ -2,6 +2,10 @@
 
 declare(strict_types=1);
 
+use Mezzio\Application;
+use Mezzio\MiddlewareFactory;
+use Psr\Container\ContainerInterface;
+
 // Delegate static file requests back to the PHP built-in webserver
 if (PHP_SAPI === 'cli-server' && $_SERVER['SCRIPT_FILENAME'] !== __FILE__) {
     return false;
@@ -14,17 +18,15 @@
  * Self-called anonymous function that creates its own scope and keeps the global namespace clean.
  */
 (function () {
-    /** @var \Psr\Container\ContainerInterface $container */
+    /** @var ContainerInterface $container */
     $container = require 'config/container.php';
 
-    /** @var \Mezzio\Application $app */
-    $app = $container->get(\Mezzio\Application::class);
-    $factory = $container->get(\Mezzio\MiddlewareFactory::class);
+    /** @var Application $app */
+    $app     = $container->get(Application::class);
+    $factory = $container->get(MiddlewareFactory::class);
 
-    // Execute programmatic/declarative middleware pipeline and routing
-    // configuration statements
+    // Execute programmatic/declarative middleware pipeline and routing configuration statements
     (require 'config/pipeline.php')($app, $factory, $container);
-    (require 'config/routes.php')($app, $factory, $container);
 
     $app->run();
 })();