Tarantool\JobQueue\Executor\CallbackExecutor

Complexity

Total Complexity

2

Size/Duplication

Total Lines	24
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	13	1
A	__construct()	0	4	1

<?php

namespace Tarantool\JobQueue\Executor;

use ArgumentsResolver\InDepthArgumentsResolver;
use Tarantool\JobQueue\Executor\CallbackResolver\CallbackResolver;
use Tarantool\JobQueue\JobBuilder\JobOptions;
use Tarantool\Queue\Queue;

class CallbackExecutor implements Executor
{
    private $callbackResolver;
    private $autowiredArgs;

    public function __construct(CallbackResolver $callbackResolver, array $autowiredArgs = [])
    {
        $this->callbackResolver = $callbackResolver;
        $this->autowiredArgs = $autowiredArgs;
    }

    public function execute($payload, Queue $queue): void
    {
        $callback = $this->callbackResolver->resolve($payload);
        $args = $payload[JobOptions::PAYLOAD_SERVICE_ARGS] ?? [];

        $args = array_merge($args, [
            $payload,
            $queue,
        ], $this->autowiredArgs);

        $args = (new InDepthArgumentsResolver($callback))->resolve($args);

        $callback(...$args);
    }
}