Skip to content

Commit a7d1814

Browse files
authored
Allow assertions against pushed string based pushed jobs (#42676)
1 parent 6cef8cb commit a7d1814

File tree

2 files changed

+16
-1
lines changed

2 files changed

+16
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -253,7 +253,7 @@ public function pushed($job, $callback = null)
253253
$callback = $callback ?: fn () => true;
254254

255255
return collect($this->jobs[$job])->filter(
256-
fn ($data) => $callback($data['job'], $data['queue'])
256+
fn ($data) => $callback($data['job'], $data['queue'], $data['data'])
257257
)->pluck('job');
258258
}
259259

@@ -306,6 +306,7 @@ public function push($job, $data = '', $queue = null)
306306
$this->jobs[is_object($job) ? get_class($job) : $job][] = [
307307
'job' => $job,
308308
'queue' => $queue,
309+
'data' => $data,
309310
];
310311
} else {
311312
is_object($job) && isset($job->connection)

tests/Support/SupportTestingQueueFakeTest.php

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,20 @@ public function testAssertPushed()
5252
$this->fake->assertPushed(JobStub::class);
5353
}
5454

55+
public function testItCanAssertAgainstDataWithPush()
56+
{
57+
$data = null;
58+
$this->fake->push(JobStub::class, ['foo' => 'bar'], 'redis');
59+
60+
$this->fake->assertPushed(JobStub::class, function ($job, $queue, $jobData) use (&$data) {
61+
$data = $jobData;
62+
63+
return true;
64+
});
65+
66+
$this->assertSame(['foo' => 'bar'], $data);
67+
}
68+
5569
public function testAssertPushedWithIgnore()
5670
{
5771
$job = new JobStub;

0 commit comments

Comments
 (0)