Yiisoft\Yii\Sentry\Tracing\SentryConsoleTransactionAdapter

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	setData()	0	5	1
A	__construct()	0	4	2
A	setName()	0	5	1
A	commit()	0	13	2
A	begin()	0	25	2

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Sentry\Tracing;

use Psr\Log\LoggerInterface;
use Sentry\SentrySdk;
use Sentry\Tracing\SpanContext;
use Sentry\Tracing\TransactionContext;
use Yiisoft\Log\Logger;
use Yiisoft\Yii\Console\Event\ApplicationShutdown;

final class SentryConsoleTransactionAdapter
{
    protected ?Logger $logger = null;

    public function __construct(LoggerInterface $logger, private SentryTraceConsoleListener $consoleListener)
    {
        if ($logger instanceof Logger) {
            $this->logger = $logger;
        }
    }

    public function begin(?string $sentryTraceString = null): self
    {
        $hub = SentrySdk::getCurrentHub();
        if ($sentryTraceString) {
            $context = TransactionContext::fromSentryTrace($sentryTraceString);
        } else {
            $context = new TransactionContext();
        }
        $context->setOp('console sub task');

        $context->setStartTimestamp(microtime(true));

It seems like microtime(true) can also be of type string; however, parameter $startTimestamp of Sentry\Tracing\SpanContext::setStartTimestamp() does only seem to accept double|null, maybe add an additional type check?

        $transaction = $hub->startTransaction($context);
        $transaction->setName('undefined command');
        $hub->setSpan($transaction);
        $this->consoleListener->setTransaction($transaction);

        $appContextStart = new SpanContext();
        $appContextStart->setOp('handle');
        $appContextStart->setStartTimestamp(microtime(true));
        $appSpan = $transaction->startChild($appContextStart);
        SentrySdk::getCurrentHub()->setSpan($appSpan);
        $this->consoleListener->setAppSpan($appSpan);

        return $this;
    }

    public function setName(string $name): self
    {
        SentrySdk::getCurrentHub()->getTransaction()?->setName($name);

        return $this;
    }

    /**
     * @param array<string, mixed> $data
     *
     * @return $this
     */
    public function setData(array $data): self
    {
        SentrySdk::getCurrentHub()->getTransaction()?->setData($data);

        return $this;
    }

    public function commit(): ?string
    {
        $this->logger?->info('sentry force commit');
        $sentryTraceString = SentrySdk::getCurrentHub()->getSpan()?->toTraceparent();
        if (SentrySdk::getCurrentHub()->getTransaction() !== null) {
            $this->logger?->flush(true);
        }

        $this->consoleListener->listenCommandTerminate(null);
        $this->consoleListener->listenShutdown(new ApplicationShutdown(0));
        $this->consoleListener->setTransaction(null);

        return $sentryTraceString;
    }
}