{

protected function tearDown(): void

{

Mockery::close();

}

public function testProcess()

{

$container = $this->getContainer();

$listener = new OnTaskListener($container);

$id = uniqid();

$event = Mockery::mock(OnTask::class);

$event->task = new Server\Task();

$event->task->data = new Task([Foo::class, 'get'], [$id]);

$event->shouldReceive('setResult')->with(Mockery::any())->andReturnUsing(function ($result) use ($id, $event) {

$this->assertInstanceOf(Finish::class, $result);

$this->assertSame($id, $result->data);

return $event;

});

$listener->process($event);

}

public function testProcessException()

{

$container = $this->getContainer();

$listener = new OnTaskListener($container);

$id = uniqid();

$event = Mockery::mock(OnTask::class);

$event->task = new Server\Task();

$event->task->data = new Task([Foo::class, 'exception'], [$id]);

$event->shouldReceive('setResult')->with(Mockery::any())->andReturnUsing(function ($result) use ($event) {

$this->assertInstanceOf(Finish::class, $result);

$this->assertInstanceOf(Exception::class, $result->data);

$this->assertSame(RuntimeException::class, $result->data->class);

$this->assertSame('Foo::exception failed.', $result->data->attributes['message']);

$this->assertSame(0, $result->data->attributes['code']);

return $event;

});

$listener->process($event);

}

protected function getContainer()

{

$container = Mockery::mock(ContainerInterface::class);

$normalizer = new ExceptionNormalizer();

$container->shouldReceive('get')->with(ExceptionNormalizer::class)->andReturn($normalizer);

$container->shouldReceive('has')->with(Mockery::any())->andReturn(true);

$container->shouldReceive('get')->with(TaskExecutor::class)->andReturn(new TaskExecutor(new ChannelFactory(), $normalizer));

$container->shouldReceive('get')->with(Foo::class)->andReturn(new Foo());

return $container;

}