15
15
16
16
use ApiPlatform \Core \Bridge \Symfony \Messenger \DataPersister ;
17
17
use ApiPlatform \Core \Bridge \Symfony \Messenger \RemoveStamp ;
18
+ use ApiPlatform \Core \Bridge \Symfony \Messenger \ContextStamp ;
18
19
use ApiPlatform \Core \Exception \ResourceClassNotFoundException ;
19
20
use ApiPlatform \Core \Metadata \Resource \Factory \ResourceMetadataFactoryInterface ;
20
21
use ApiPlatform \Core \Metadata \Resource \ResourceMetadata ;
@@ -56,7 +57,9 @@ public function testPersist()
56
57
$ dummy = new Dummy ();
57
58
58
59
$ messageBus = $ this ->prophesize (MessageBusInterface::class);
59
- $ messageBus ->dispatch ($ dummy )->willReturn (new Envelope ($ dummy ))->shouldBeCalled ();
60
+ $ messageBus ->dispatch (Argument::that (function (Envelope $ envelope ) use ($ dummy ) {
61
+ return $ dummy === $ envelope ->getMessage () && null !== $ envelope ->last (ContextStamp::class);
62
+ }))->willReturn (new Envelope ($ dummy ))->shouldBeCalled ();
60
63
61
64
$ dataPersister = new DataPersister ($ this ->prophesize (ResourceMetadataFactoryInterface::class)->reveal (), $ messageBus ->reveal ());
62
65
$ this ->assertSame ($ dummy , $ dataPersister ->persist ($ dummy ));
@@ -67,6 +70,7 @@ public function testRemove()
67
70
$ dummy = new Dummy ();
68
71
69
72
$ messageBus = $ this ->prophesize (MessageBusInterface::class);
73
+
70
74
$ messageBus ->dispatch (Argument::that (function (Envelope $ envelope ) use ($ dummy ) {
71
75
return $ dummy === $ envelope ->getMessage () && null !== $ envelope ->last (RemoveStamp::class);
72
76
}))->willReturn (new Envelope ($ dummy ))->shouldBeCalled ();
@@ -80,7 +84,9 @@ public function testHandle()
80
84
$ dummy = new Dummy ();
81
85
82
86
$ messageBus = $ this ->prophesize (MessageBusInterface::class);
83
- $ messageBus ->dispatch ($ dummy )->willReturn ((new Envelope ($ dummy ))->with (new HandledStamp ($ dummy , 'DummyHandler::__invoke ' )))->shouldBeCalled ();
87
+ $ messageBus ->dispatch (Argument::that (function (Envelope $ envelope ) use ($ dummy ) {
88
+ return $ dummy === $ envelope ->getMessage () && null !== $ envelope ->last (ContextStamp::class);
89
+ }))->willReturn ((new Envelope ($ dummy ))->with (new HandledStamp ($ dummy , 'DummyHandler::__invoke ' )))->shouldBeCalled ();
84
90
85
91
$ dataPersister = new DataPersister ($ this ->prophesize (ResourceMetadataFactoryInterface::class)->reveal (), $ messageBus ->reveal ());
86
92
$ this ->assertSame ($ dummy , $ dataPersister ->persist ($ dummy ));
0 commit comments