feat: allow configuration of key parameters for the queue (#5)

* feat: allow configuration of key parameters for the queue

* Apply fixes from StyleCI

---------

Co-authored-by: StyleCI Bot <bot@styleci.io>

extend.php

@@ -12,6 +12,7 @@
 
 namespace Blomstra\DatabaseQueue;
 
+use Blomstra\DatabaseQueue\Console\WorkerArgs;
 use Flarum\Extend;
 use Illuminate\Console\Scheduling\Event;
 
@@ -30,8 +31,14 @@
 
     (new Extend\Console())
         ->command(Console\DatabaseWorkCommand::class)
-        ->schedule('queue:work --stop-when-empty', function (Event $e) {
+        ->schedule('queue:work', function (Event $e) {
             $e->everyMinute();
-        }),
-
+        }, resolve(WorkerArgs::class)->args()),
+
+    (new Extend\Settings())
+        ->default('blomstra-database-queue.retries', 1)
+        ->default('blomstra-database-queue.timeout', 60)
+        ->default('blomstra-database-queue.rest', 0)
+        ->default('blomstra-database-queue.memory', 128)
+        ->default('blomstra-database-queue.backoff', 0),
 ];

resources/locale/en.yml

@@ -1,5 +1,21 @@
 blomstra-database-queue:
   admin:
+    settings:
+      backoff_label: Backoff
+      backoff_help: |
+        The number of seconds to wait before retrying a job that encountered an uncaught exception.
+      memory_label: Memory
+      memory_help: |
+        The memory limit in megabytes.
+      rest_label: Rest
+      rest_help: |
+        The number of seconds to rest between jobs.
+      retries_label: Retries
+      retries_help: |
+        The number of times to attempt a job before logging it failed.
+      timeout_label: Timeout
+      timeout_help: |
+        The number of seconds a child process can run.
     stats:
       auto_refresh: Auto Refresh
       heading: Queue Overview

src/Console/WorkerArgs.php

@@ -0,0 +1,43 @@
+<?php
+
+/*
+ * This file is part of blomstra/database-queue
+ *
+ * Copyright (c) 2023 Blomstra Ltd.
+ *
+ * For the full copyright and license information, please view the LICENSE.md
+ * file that was distributed with this source code.
+ *
+ */
+
+namespace Blomstra\DatabaseQueue\Console;
+
+use Flarum\Settings\SettingsRepositoryInterface;
+
+class WorkerArgs
+{
+    /**
+     * @var SettingsRepositoryInterface
+     */
+    protected $settings;
+
+    public function __construct(SettingsRepositoryInterface $settings)
+    {
+        $this->settings = $settings;
+    }
+
+    public function args(): array
+    {
+        $args = [
+            '--stop-when-empty',
+        ];
+
+        $args['--tries'] = $this->settings->get('blomstra-database-queue.retries');
+        $args['--timeout'] = $this->settings->get('blomstra-database-queue.timeout');
+        $args['--rest'] = $this->settings->get('blomstra-database-queue.rest');
+        $args['--memory'] = $this->settings->get('blomstra-database-queue.memory');
+        $args['--backoff'] = $this->settings->get('blomstra-database-queue.backoff');
+
+        return $args;
+    }
+}