[12.x] QueueFake::listenersPushed() (#55063)

* QueueFake::listenersPushed()

* import

* payload

Author: cosmastech

src/Illuminate/Support/Testing/Fakes/QueueFake.php

@@ -5,6 +5,7 @@
 use BadMethodCallException;
 use Closure;
 use Illuminate\Contracts\Queue\Queue;
+use Illuminate\Events\CallQueuedListener;
 use Illuminate\Queue\CallQueuedClosure;
 use Illuminate\Queue\QueueManager;
 use Illuminate\Support\Collection;
@@ -349,6 +350,29 @@ public function pushedRaw($callback = null)
         return (new Collection($this->rawPushes))->filter(fn ($data) => $callback($data['payload'], $data['queue'], $data['options']));
     }
 
+    /**
+     * Get all of the jobs by listener class, passing an optional truth-test callback.
+     *
+     * @param  class-string  $listenerClass
+     * @param  (\Closure(mixed, \Illuminate\Events\CallQueuedListener, string|null, mixed): bool)|null  $callback
+     * @return \Illuminate\Support\Collection<int, \Illuminate\Events\CallQueuedListener>
+     */
+    public function listenersPushed($listenerClass, $callback = null)
+    {
+        if (! $this->hasPushed(CallQueuedListener::class)) {
+            return new Collection;
+        }
+
+        $collection = (new Collection($this->jobs[CallQueuedListener::class]))
+            ->filter(fn ($data) => $data['job']->class === $listenerClass);
+
+        if ($callback) {
+            $collection = $collection->filter(fn ($data) => $callback($data['job']->data[0] ?? null, $data['job'], $data['queue'], $data['data']));
+        }
+
+        return $collection->pluck('job');
+    }
+
     /**
      * Determine if there are any stored jobs for a given class.
      *

tests/Integration/Queue/QueuedListenersTest.php

@@ -25,15 +25,32 @@ public function testListenersCanBeQueuedOptionally()
             return $job->class == QueuedListenersTestListenerShouldQueue::class;
         });
 
+        $this->assertCount(1, Queue::listenersPushed(QueuedListenersTestListenerShouldQueue::class));
+        $this->assertCount(
+            0,
+            Queue::listenersPushed(
+                QueuedListenersTestListenerShouldQueue::class,
+                fn ($event, $handler, $queue, $data) => $queue === 'not-a-real-queue'
+            )
+        );
+        $this->assertCount(
+            1,
+            Queue::listenersPushed(
+                QueuedListenersTestListenerShouldQueue::class,
+                fn (QueuedListenersTestEvent $event) => $event->value === 100
+            )
+        );
+
         Queue::assertNotPushed(CallQueuedListener::class, function ($job) {
             return $job->class == QueuedListenersTestListenerShouldNotQueue::class;
         });
+        $this->assertCount(0, Queue::listenersPushed(QueuedListenersTestListenerShouldNotQueue::class));
     }
 }
 
 class QueuedListenersTestEvent
 {
-    //
+    public int $value = 100;
 }
 
 class QueuedListenersTestListenerShouldQueue implements ShouldQueue