Add manage job's queue (#7)

* add ability set queue for job not only default

* change ecs config

* fix linter requirements

Co-authored-by: Evgen <[email protected]>

Author: gitHomesPhp

.github/workflows/ci.yml

@@ -63,7 +63,7 @@ jobs:
         run: composer install --prefer-dist --no-progress --no-suggest --optimize-autoloader
         working-directory: './'
       - name: 'Linting PHP source files'
-        run: 'vendor/bin/ecs check --config=ecs.yml .'
+        run: 'vendor/bin/ecs check --config=ecs.php .'
   test:
     strategy:
       fail-fast: false

composer.json

@@ -60,7 +60,7 @@
     },
     "scripts": {
         "lint-fix":[
-            "vendor/bin/ecs check src tests -c ecs.yml --fix"
+            "vendor/bin/ecs check src tests -c ecs.php --fix"
         ]
     },
     "extra": {

database/Laravel/migrations/0000_00_00_000001_create_test_model_table.php

@@ -17,7 +17,8 @@ public function up()
 
                 $table->string('name');
                 $table->string('some_field');
-                $table->float('version')->default(0.0);
+                $table->float('version')
+                    ->default(0.0);
             });
 
             Schema::create('soft_test_models', function (Blueprint $table) {

ecs.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+use PhpCsFixer\Fixer\Operator\BinaryOperatorSpacesFixer;
+use PhpCsFixer\Fixer\PhpUnit\PhpUnitTestAnnotationFixer;
+use PhpCsFixer\Fixer\Strict\DeclareStrictTypesFixer;
+use Symfony\Component\DependencyInjection\Loader\Configurator\ContainerConfigurator;
+
+return static function (ContainerConfigurator $containerConfigurator): void {
+    $containerConfigurator->import(__DIR__ . '/vendor/umbrellio/code-style-php/umbrellio-cs.php');
+
+    $services = $containerConfigurator->services();
+
+    $services->set(PhpUnitTestAnnotationFixer::class)
+        ->call('configure', [[
+            'style' => 'annotation',
+        ]]);
+
+    $services->set(DeclareStrictTypesFixer::class);
+
+    $services->set(BinaryOperatorSpacesFixer::class)
+        ->call('configure', [[
+            'default' => 'single_space',
+        ]]);
+
+    $parameters = $containerConfigurator->parameters();
+
+    $parameters->set('cache_directory', '.ecs_cache');
+
+    $parameters->set('exclude_files', ['vendor/*', 'database/*']);
+};

src/Integration/Laravel/Jobs/PublishJob.php

@@ -4,20 +4,24 @@
 
 namespace Umbrellio\TableSync\Integration\Laravel\Jobs;
 
+use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Support\Facades\App;
+use Illuminate\Support\Facades\Config;
 use Umbrellio\LaravelHeavyJobs\Jobs\ShouldStorePayload;
 use Umbrellio\TableSync\Messages\PublishMessage;
 
 final class PublishJob implements ShouldQueue, ShouldStorePayload
 {
     use HeavyJobsEnabledTrait;
+    use Queueable;
 
     private $publisherClass;
     private $message;
 
     public function __construct(string $publisherClass, PublishMessage $message)
     {
+        $this->queue = Config::get('table_sync.publish_job_queue', '');
         $this->publisherClass = $publisherClass;
         $this->message = $message;
     }

src/Integration/Laravel/Jobs/ReceiveMessage.php

@@ -4,19 +4,23 @@
 
 namespace Umbrellio\TableSync\Integration\Laravel\Jobs;
 
+use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Support\Facades\Config;
 use Umbrellio\LaravelHeavyJobs\Jobs\ShouldStorePayload;
 use Umbrellio\TableSync\Integration\Laravel\Receive\Receiver;
 use Umbrellio\TableSync\Messages\ReceivedMessage;
 
 final class ReceiveMessage implements ShouldQueue, ShouldStorePayload
 {
     use HeavyJobsEnabledTrait;
+    use Queueable;
 
     private $message;
 
     public function __construct(ReceivedMessage $message)
     {
+        $this->queue = Config::get('table_sync.receive_job_queue', '');
         $this->message = $message;
     }
 

src/Integration/Laravel/config/table_sync.php

@@ -52,4 +52,6 @@
     'log' => [
         'channel' => 'table_sync',
     ],
+    'publish_job_queue' => '',
+    'receive_job_queue' => '',
 ];

tests/functional/Laravel/Models/SoftTestModel.php

@@ -17,7 +17,8 @@
  */
 final class SoftTestModel extends Model implements SyncableModel
 {
-    use TableSyncable, SoftDeletes;
+    use TableSyncable;
+    use SoftDeletes;
 
     public $timestamps = false;