[1.x] [extensibility] feat: allow classes that extends AbstractJob to be placed on a specified queue (#4026)

* feat: allow classes that extends AbstractJob to be placed on a specific queue

* Apply fixes from StyleCI

* php 7.3 compat

* Apply fixes from StyleCI

* change  to  to avoid conflicts with extensions that already do this

* chore: add docblock explaining that this solution only works for Redis queues

* Apply fixes from StyleCI

* chore: update docblock

* Apply fixes from StyleCI

---------

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

Author: imorland

extensions/mentions/src/Job/SendMentionsNotificationsJob.php

@@ -47,6 +47,8 @@ class SendMentionsNotificationsJob extends AbstractJob
 
     public function __construct(CommentPost $post, array $userMentions, array $postMentions, array $groupMentions)
     {
+        parent::__construct();
+
         $this->post = $post;
         $this->userMentions = $userMentions;
         $this->postMentions = $postMentions;

extensions/package-manager/src/Job/ComposerCommandJob.php

@@ -32,6 +32,8 @@ class ComposerCommandJob extends AbstractJob implements ShouldBeUnique
 
     public function __construct(AbstractActionCommand $command, string $phpVersion)
     {
+        parent::__construct();
+
         $this->command = $command;
         $this->phpVersion = $phpVersion;
     }

extensions/pusher/src/SendPusherNotificationsJob.php

@@ -28,6 +28,8 @@ class SendPusherNotificationsJob extends AbstractJob
 
     public function __construct(BlueprintInterface $blueprint, array $recipients)
     {
+        parent::__construct();
+
         $this->blueprint = $blueprint;
         $this->recipients = $recipients;
     }

framework/core/src/Mail/Job/SendRawEmailJob.php

@@ -21,6 +21,8 @@ class SendRawEmailJob extends AbstractJob
 
     public function __construct(string $email, string $subject, string $body)
     {
+        parent::__construct();
+
         $this->email = $email;
         $this->subject = $subject;
         $this->body = $body;

framework/core/src/Notification/Job/SendEmailNotificationJob.php

@@ -28,6 +28,8 @@ class SendEmailNotificationJob extends AbstractJob
 
     public function __construct(MailableInterface $blueprint, User $recipient)
     {
+        parent::__construct();
+
         $this->blueprint = $blueprint;
         $this->recipient = $recipient;
     }

framework/core/src/Notification/Job/SendNotificationsJob.php

@@ -28,6 +28,8 @@ class SendNotificationsJob extends AbstractJob
 
     public function __construct(BlueprintInterface $blueprint, array $recipients = [])
     {
+        parent::__construct();
+
         $this->blueprint = $blueprint;
         $this->recipients = $recipients;
     }

framework/core/src/Queue/AbstractJob.php

@@ -19,4 +19,20 @@ class AbstractJob implements ShouldQueue
     use InteractsWithQueue;
     use Queueable;
     use SerializesModels;
+
+    /**
+     * The name of the queue on which the job should be placed.
+     *
+     * This is only effective on jobs that extend `\Flarum\Queue\AbstractJob` and dispatched via Redis.
+     *
+     * @var string|null
+     */
+    public static $sendOnQueue = null;
+
+    public function __construct()
+    {
+        if (static::$sendOnQueue) {
+            $this->onQueue(static::$sendOnQueue);
+        }
+    }
 }

framework/core/src/User/Job/RequestPasswordResetJob.php

@@ -27,6 +27,8 @@ class RequestPasswordResetJob extends AbstractJob
 
     public function __construct(string $email)
     {
+        parent::__construct();
+
         $this->email = $email;
     }