1515
1616use PHPUnit \Framework \TestCase ;
1717use Tarantool \JobQueue \JobBuilder \JobBuilder ;
18- use Tarantool \JobQueue \JobBuilder \JobBuilders ;
1918use Tarantool \JobQueue \JobBuilder \JobEmitter ;
2019use Tarantool \Queue \Queue ;
2120use Tarantool \Queue \States ;
2221use Tarantool \Queue \Task ;
2322
2423final class JobEmitterTest extends TestCase
2524{
25+ use PhpUnitCompat;
26+
2627 public function testEmitNoJobs () : void
2728 {
2829 $ queue = $ this ->createMock (Queue::class);
2930 $ queue ->expects (self ::never ())->method ('put ' );
3031
3132 $ emitter = new JobEmitter ();
32- $ tasks = $ emitter ->emit (new JobBuilders ([]) , $ queue );
33+ $ tasks = $ emitter ->emit ([] , $ queue );
3334
3435 self ::assertSame ([], $ tasks );
3536 }
3637
3738 public function testEmitOneJob () : void
3839 {
3940 $ builder = JobBuilder::fromPayload ('task_data ' );
40- $ task = Task::createFromTuple ([42 , States::READY , 'task_data ' ]);
41+ $ task = Task::fromTuple ([42 , States::READY , 'task_data ' ]);
4142
4243 $ queue = $ this ->createMock (Queue::class);
4344 $ queue ->expects (self ::once ())->method ('put ' )
44- ->with (' task_data ' , [])
45+ ->with ([ ' payload ' => ' task_data '] , [])
4546 ->willReturn ($ task );
4647
4748 $ emitter = new JobEmitter ();
48- $ tasks = $ emitter ->emit (new JobBuilders ( [$ builder ]) , $ queue );
49+ $ tasks = $ emitter ->emit ([$ builder ], $ queue );
4950
5051 self ::assertSame ($ task , reset ($ tasks ));
5152 }
@@ -55,19 +56,22 @@ public function testEmitMultipleJobsArray() : void
5556 $ builder1 = JobBuilder::fromPayload ('task_data1 ' );
5657 $ builder2 = JobBuilder::fromPayload ('task_data2 ' );
5758
58- $ task1 = Task::createFromTuple ([42 , States::READY , 'task_data1 ' ]);
59- $ task2 = Task::createFromTuple ([43 , States::READY , 'task_data2 ' ]);
59+ $ task1 = Task::fromTuple ([42 , States::READY , 'task_data1 ' ]);
60+ $ task2 = Task::fromTuple ([43 , States::READY , 'task_data2 ' ]);
6061
6162 $ queue = $ this ->createMock (Queue::class);
6263 $ queue ->expects (self ::once ())->method ('call ' )
63- ->with ('put_many ' , [[['task_data1 ' , []], ['task_data2 ' , []]]])
64+ ->with ('put_many ' , [
65+ [['payload ' => 'task_data1 ' ], []],
66+ [['payload ' => 'task_data2 ' ], []],
67+ ])
6468 ->willReturn ([[
6569 [42 , States::READY , 'task_data1 ' ],
6670 [43 , States::READY , 'task_data2 ' ],
6771 ]]);
6872
6973 $ emitter = new JobEmitter ();
70- $ tasks = $ emitter ->emit (new JobBuilders ( [$ builder1 , $ builder2 ]) , $ queue );
74+ $ tasks = $ emitter ->emit ([$ builder1 , $ builder2 ], $ queue );
7175
7276 self ::assertEquals ([$ task1 , $ task2 ], $ tasks );
7377 }
@@ -77,19 +81,22 @@ public function testEmitMultipleJobsMap() : void
7781 $ builder1 = JobBuilder::fromPayload ('task_data1 ' );
7882 $ builder2 = JobBuilder::fromPayload ('task_data2 ' );
7983
80- $ task1 = Task::createFromTuple ([42 , States::READY , 'task_data1 ' ]);
81- $ task2 = Task::createFromTuple ([43 , States::READY , 'task_data2 ' ]);
84+ $ task1 = Task::fromTuple ([42 , States::READY , 'task_data1 ' ]);
85+ $ task2 = Task::fromTuple ([43 , States::READY , 'task_data2 ' ]);
8286
8387 $ queue = $ this ->createMock (Queue::class);
8488 $ queue ->expects (self ::once ())->method ('call ' )
85- ->with ('put_many ' , [[['task_data1 ' , []], 'key ' => ['task_data2 ' , []]]])
89+ ->with ('put_many ' , [
90+ [['payload ' => 'task_data1 ' ], []],
91+ 'key ' => [['payload ' => 'task_data2 ' ], []],
92+ ])
8693 ->willReturn ([[[
8794 [42 , States::READY , 'task_data1 ' ],
8895 'key ' => [43 , States::READY , 'task_data2 ' ],
8996 ]]]);
9097
9198 $ emitter = new JobEmitter ();
92- $ tasks = $ emitter ->emit (new JobBuilders ( [$ builder1 , 'key ' => $ builder2 ]) , $ queue );
99+ $ tasks = $ emitter ->emit ([$ builder1 , 'key ' => $ builder2 ], $ queue );
93100
94101 self ::assertEquals ([$ task1 , 'key ' => $ task2 ], $ tasks );
95102 }
@@ -104,9 +111,9 @@ public function testThrowOnInvalidCallResult() : void
104111 ->willReturn (['invalid_response ' ]);
105112
106113 $ this ->expectException (\UnexpectedValueException::class);
107- $ this ->expectExceptionMessageRegExp ('/Unable to parse call response as (map|array)\./ ' );
114+ $ this ->expectExceptionMessageMatches ('/Unable to parse call response as (map|array)\./ ' );
108115
109116 $ emitter = new JobEmitter ();
110- $ emitter ->emit (new JobBuilders ( [$ builder1 , $ builder2 ]) , $ queue );
117+ $ emitter ->emit ([$ builder1 , $ builder2 ], $ queue );
111118 }
112119}
0 commit comments