Umbrellio\Jaravel\Middleware\JobTracingMiddleware

Complexity

Total Complexity

2

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	handle()	0	22	1

<?php

declare(strict_types=1);

namespace Umbrellio\Jaravel\Middleware;

use Illuminate\Support\Facades\Config;
use Umbrellio\Jaravel\Services\Caller;
use Umbrellio\Jaravel\Services\Span\SpanCreator;
use Umbrellio\Jaravel\Services\Span\SpanTagHelper;
use Umbrellio\Jaravel\Services\TraceIdHeaderRetriever;

class JobTracingMiddleware
{
    public const JOB_TRACING_CONTEXT_FIELD = 'tracingContext';

    private SpanCreator $spanCreator;
    private TraceIdHeaderRetriever $traceIdHeaderRetriever;

    public function __construct(SpanCreator $spanCreator, TraceIdHeaderRetriever $traceIdHeaderRetriever)
    {
        $this->spanCreator = $spanCreator;
        $this->traceIdHeaderRetriever = $traceIdHeaderRetriever;
    }

    public function handle($job, callable $next)
    {
        $payload = $job->{self::JOB_TRACING_CONTEXT_FIELD} ?? [];

        $traceIdHeader = $this->traceIdHeaderRetriever->retrieve($payload);

        $span = $this->spanCreator->create(
            Caller::call(Config::get('jaravel.job.span_name'), [$job, $job->job ?? null]),
            $traceIdHeader
        );
        $scope = $span->activate();

        $next($job);

        $callableConfig = Config::get('jaravel.job.tags', fn () => [
            'type' => 'job',
        ]);

        SpanTagHelper::setTags($span, Caller::call($callableConfig, [$job, $job->job ?? null]));

        $span->end();
        $scope->detach();
    }
}