TechDeCo\ElasticApmAgent\Convenience\Middleware\TransactionMiddleware

Complexity

Total Complexity

3

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	process()	0	22	1
A	getCorrelationId()	0	8	2

<?php
declare(strict_types=1);

namespace TechDeCo\ElasticApmAgent\Convenience\Middleware;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Ramsey\Uuid\Exception\InvalidUuidStringException;
use Ramsey\Uuid\Uuid;
use Ramsey\Uuid\UuidInterface;
use TechDeCo\ElasticApmAgent\Convenience\HttplugHttpClient\HttpClientWrapper;
use TechDeCo\ElasticApmAgent\Convenience\OpenTransaction;
use TechDeCo\ElasticApmAgent\Exception\ClientException;
use TechDeCo\ElasticApmAgent\Message\Timestamp;
use TechDeCo\ElasticApmAgent\Request\Transaction;
use function sprintf;

final class TransactionMiddleware extends Middleware
{
    public const TRANSACTION_ATTRIBUTE = 'apm-transaction';

    /**
     * @throws ClientException
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $openTransaction = new OpenTransaction(
            Uuid::uuid4(),
            sprintf('%s %s', $request->getMethod(), $request->getUri()->__toString()),
            new Timestamp(),
            'request',
            $this->getCorrelationId($request)
        );

        try {
            $request = $request->withAttribute(self::TRANSACTION_ATTRIBUTE, $openTransaction);

Consider using a different name than the parameter $request. This often makes code more readable.

            return $handler->handle($request);
        } finally {
            $transaction = (new Transaction($this->service, $openTransaction->toTransaction()))
                ->onSystem($this->system)
                ->inProcess($this->process);

            $this->client->sendTransaction($transaction);
        }
    }

    private function getCorrelationId(ServerRequestInterface $request): UuidInterface
    {
        try {
            return Uuid::fromString($request->getHeaderLine(HttpClientWrapper::CORRELATION_ID_HEADER));
        } catch (InvalidUuidStringException $e) {
            return Uuid::uuid4();
        }
    }
}