[5.x] Allow any queued class to be silenced (#1241)

* move sileneced logic to job payload

* move fixtures and payload test to feature

* fix tests

* styling

* make methods protected

Author: lioneaglesolutions

src/JobPayload.php

@@ -8,6 +8,7 @@
 use Illuminate\Mail\SendQueuedMailable;
 use Illuminate\Notifications\SendQueuedNotifications;
 use Illuminate\Support\Arr;
+use Laravel\Horizon\Contracts\Silenced;
 
 class JobPayload implements ArrayAccess
 {
@@ -78,6 +79,16 @@ public function retryOf()
         return $this->decoded['retry_of'] ?? null;
     }
 
+    /**
+     * Determine if the job has been silenced.
+     *
+     * @return bool
+     */
+    public function isSilenced()
+    {
+        return $this->decoded['silenced'] ?? false;
+    }
+
     /**
      * Prepare the payload for storage on the queue by adding tags, etc.
      *
@@ -89,6 +100,7 @@ public function prepare($job)
         return $this->set([
             'type' => $this->determineType($job),
             'tags' => $this->determineTags($job),
+            'silenced' => $this->shouldBeSilenced($job),
             'pushedAt' => str_replace(',', '.', microtime(true)),
         ]);
     }
@@ -129,6 +141,48 @@ protected function determineTags($job)
         );
     }
 
+    /**
+     * Determine if the underlying job class should be silenced.
+     *
+     * @param  mixed  $job
+     * @return bool
+     */
+    protected function shouldBeSilenced($job)
+    {
+        if (! $job) {
+            return false;
+        }
+
+        $underlyingJob = $this->underlyingJob($job);
+
+        $jobClass = is_string($underlyingJob) ? $underlyingJob : get_class($underlyingJob);
+
+        return in_array($jobClass, config('horizon.silenced', [])) ||
+               is_a($jobClass, Silenced::class, true);
+    }
+
+    /**
+     * Get the underlying queued job.
+     *
+     * @param  mixed  $job
+     * @return mixed
+     */
+    protected function underlyingJob($job)
+    {
+        switch (true) {
+            case $job instanceof BroadcastEvent:
+                return $job->event;
+            case $job instanceof CallQueuedListener:
+                return $job->class;
+            case $job instanceof SendQueuedMailable:
+                return $job->mailable;
+            case $job instanceof SendQueuedNotifications:
+                return $job->notification;
+            default:
+                return $job;
+        }
+    }
+
     /**
      * Set the given key / value pairs on the payload.
      *

src/Listeners/MarkJobAsComplete.php

@@ -3,7 +3,6 @@
 namespace Laravel\Horizon\Listeners;
 
 use Laravel\Horizon\Contracts\JobRepository;
-use Laravel\Horizon\Contracts\Silenced;
 use Laravel\Horizon\Contracts\TagRepository;
 use Laravel\Horizon\Events\JobDeleted;
 
@@ -44,10 +43,7 @@ public function __construct(JobRepository $jobs, TagRepository $tags)
      */
     public function handle(JobDeleted $event)
     {
-        $isSilenced = in_array($event->payload->commandName(), config('horizon.silenced', [])) ||
-            is_a($event->payload->commandName(), Silenced::class, true);
-
-        $this->jobs->completed($event->payload, $event->job->hasFailed(), $isSilenced);
+        $this->jobs->completed($event->payload, $event->job->hasFailed(), $event->payload->isSilenced());
 
         if (! $event->job->hasFailed() && count($this->tags->monitored($event->payload->tags())) > 0) {
             $this->jobs->remember($event->connectionName, $event->queue, $event->payload);

tests/Unit/Fixtures/FakeEvent.php renamed to tests/Feature/Fixtures/FakeEvent.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeEvent
 {

tests/Unit/Fixtures/FakeEventWithModel.php renamed to tests/Feature/Fixtures/FakeEventWithModel.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeEventWithModel
 {

tests/Unit/Fixtures/FakeJobWithEloquentCollection.php renamed to tests/Feature/Fixtures/FakeJobWithEloquentCollection.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeJobWithEloquentCollection
 {

tests/Unit/Fixtures/FakeJobWithEloquentModel.php renamed to tests/Feature/Fixtures/FakeJobWithEloquentModel.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeJobWithEloquentModel
 {

tests/Unit/Fixtures/FakeJobWithTagsMethod.php renamed to tests/Feature/Fixtures/FakeJobWithTagsMethod.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeJobWithTagsMethod
 {

tests/Unit/Fixtures/FakeListener.php renamed to tests/Feature/Fixtures/FakeListener.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 class FakeListener
 {

tests/Feature/Fixtures/FakeListenerSilenced.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
+
+use Illuminate\Contracts\Events\Dispatcher;
+use Laravel\Horizon\Contracts\Silenced;
+
+class FakeListenerSilenced implements Silenced
+{
+    /**
+     * @var Dispatcher
+     */
+    protected $dispatcher;
+
+    /**
+     * @var FakeEventWithModel
+     */
+    protected $fakeModel;
+
+    public function __construct(Dispatcher $dispatcher)
+    {
+        $this->dispatcher = $dispatcher;
+    }
+
+    public function handle(FakeEventWithModel $fakeEventWithModel): void
+    {
+        $this->fakeModel = $fakeEventWithModel->model;
+    }
+}

tests/Unit/Fixtures/FakeListenerWithProperties.php renamed to tests/Feature/Fixtures/FakeListenerWithProperties.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace Laravel\Horizon\Tests\Unit\Fixtures;
+namespace Laravel\Horizon\Tests\Feature\Fixtures;
 
 use Illuminate\Contracts\Events\Dispatcher;