Shlinkio\Shlink\EventDispatcher\Async\TaskRunner::__invoke()

Complexity

Conditions	4
Paths	5

Size

Total Lines	24
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	16
CRAP Score	4

Importance

Changes

0

<?php
    public function __invoke(HttpServer $server, int $taskId, int $fromId, $task): void
    {
        if (! $task instanceof TaskInterface) {
            $this->logger->warning('Invalid task provided to task worker: {type}. Task ignored', [
                'type' => is_object($task) ? get_class($task) : gettype($task),
            ]);
            $server->finish('');
            return;
        }

        $this->logger->notice('Starting work on task {taskId}: {task}', [
            'taskId' => $taskId,
            'task' => $task->toString(),
        ]);

        try {
            $task->run($this->container);
        } catch (Throwable $e) {
            $this->logger->error('Error processing task {taskId}: {e}', [
                'taskId' => $taskId,
                'e' => $e,
            ]);
        } finally {
            $server->finish('');
        }