3961: Commands cleanup

Author: jekuaitk

README.md

@@ -26,7 +26,9 @@ composer require os2web/os2web_audit
 drush pm:enable os2web_audit
 ```
 
-### Drush
+## Drush
+
+### Test audit log
 
 The module provides a Drush command named audit:log. This command enables you
 to log a test message to the configured logger. The audit:log command accepts a
@@ -39,6 +41,15 @@ and once as an error message.
 drush audit:log 'This is a test message'
 ```
 
+### Retry jobs
+
+The module also comes with method for retrying failed jobs. This will retry,
+all failed jobs in the `os2web_audit` queue.
+
+```shell
+drush audit:retry-jobs
+```
+
 ## Usage
 
 The module exposes a simple `Logger` service which can log an `info` and `error`

src/Drush/Commands/Commands.php renamed to src/Drush/Commands/LogMessageCommand.php

@@ -2,8 +2,6 @@
 
 namespace Drupal\os2web_audit\Drush\Commands;
 
-use Drupal\Core\Database\Connection;
-use Drupal\advancedqueue\Job;
 use Drupal\os2web_audit\Service\Logger;
 use Drush\Attributes\Argument;
 use Drush\Attributes\Command;
@@ -15,20 +13,17 @@
 /**
  * Simple command to send log message into audit log.
  */
-class Commands extends DrushCommands {
+class LogMessageCommand extends DrushCommands {
 
   /**
    * Commands constructor.
    *
    * @param \Drupal\os2web_audit\Service\Logger $auditLogger
    *   Audit logger service.
-   * @param \Drupal\Core\Database\Connection $connection
-   *   The database connection.
    */
   public function __construct(
     #[Autowire(service: 'os2web_audit.logger')]
     protected readonly Logger $auditLogger,
-    protected Connection $connection,
   ) {
     parent::__construct();
   }
@@ -39,7 +34,6 @@ public function __construct(
   public static function create(ContainerInterface $container): self {
     return new static(
       $container->get('os2web_audit.logger'),
-      $container->get('database'),
     );
   }
 
@@ -60,24 +54,4 @@ public function logMessage(string $log_message): void {
     $this->auditLogger->error('test', $log_message, TRUE, ['from' => 'drush']);
   }
 
-  /**
-  * Retries all failed jobs in the os2web_audit queue.
-  */
-  #[Command(name: 'audit:retry-jobs')]
-  public function retryJobs(): void {
-
-    try {
-      $this->connection->update('advancedqueue')
-        ->fields(['state' => Job::STATE_QUEUED])
-        ->condition('queue_id', 'os2web_audit')
-        ->condition('state', Job::STATE_FAILURE)
-        ->execute();
-
-      $this->output()->writeln('Successfully retried all failed jobs.');
-    }
-    catch (\Exception $e) {
-      $this->output()->writeln($e->getMessage());
-    }
-  }
-
 }

src/Drush/Commands/RetryFailedQueueCommand.php

@@ -0,0 +1,57 @@
+<?php
+
+namespace Drupal\os2web_audit\Drush\Commands;
+
+use Drupal\Core\Database\Connection;
+use Drupal\advancedqueue\Job;
+use Drush\Attributes\Command;
+use Drush\Commands\DrushCommands;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+
+/**
+ * Simple command to send log message into audit log.
+ */
+class RetryFailedQueueCommand extends DrushCommands {
+
+  /**
+   * Commands constructor.
+   *
+   * @param \Drupal\Core\Database\Connection $connection
+   *   The database connection.
+   */
+  public function __construct(
+    protected Connection $connection,
+  ) {
+    parent::__construct();
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public static function create(ContainerInterface $container): self {
+    return new static(
+      $container->get('database'),
+    );
+  }
+
+  /**
+   * Retries all failed jobs in the os2web_audit queue.
+   */
+  #[Command(name: 'audit:retry-jobs')]
+  public function retryJobs(): void {
+
+    try {
+      $this->connection->update('advancedqueue')
+        ->fields(['state' => Job::STATE_QUEUED])
+        ->condition('queue_id', 'os2web_audit')
+        ->condition('state', Job::STATE_FAILURE)
+        ->execute();
+
+      $this->output()->writeln('Successfully retried all failed jobs.');
+    }
+    catch (\Exception $e) {
+      $this->output()->writeln($e->getMessage());
+    }
+  }
+
+}