Laravel Bridge

composer require suot/fiscal-laravel
php artisan vendor:publish --tag=fiscal-config

use Suot\Fiscal\Cte\Application\Cte;
use Suot\Fiscal\Core\Exception\InfrastructureException;
use Suot\Fiscal\Core\Result\RetryMode;

final class EmitirCteAction
{
    public function __construct(
        private readonly Cte $cte,
    ) {}

    public function __invoke(): void
    {
        try {
            $result = $this->cte
                ->issue()
                ->forOperation('transport-order-123')
                ->inHomologation()
                // … cadeia tipada …
                ->handle();
        } catch (InfrastructureException $e) {
            $failure = $e->toFailure('issue');
            // Host: alertar; filar retry conforme $failure->retryPolicy (timeout ambíguo → QueryBeforeRetry)
            throw $e;
        }

        if ($result->isAuthorized()) {
            // Host: persistir accessKey, protocolNumber, submittedDocumentXml, responseXml, receivedAt, operationId
        }

        if ($result->isRejected()) {
            $failure = $result->failure();
            $policy = $result->retryPolicy();
            match ($policy?->mode) {
                RetryMode::AfterCorrection => /* remontar issue() com dados corrigidos + novo forOperation */,
                RetryMode::QueryBeforeRetry => /* byAccessKey() antes de reemitir */,
                RetryMode::AfterDelay, RetryMode::Immediate => /* filar conforme política */,
                RetryMode::Never, null => /* definitivo; não reenviar */,
            };
        }

        if ($result->isProcessing()) {
            // Host: consultar por chave/protocolo; não emitir de novo às cegas
        }
    }
}

use Suot\Fiscal\Cte\Application\Command\Issue\IssueCteCommand;
use Suot\Fiscal\Cte\Application\Command\Issue\IssueCteHandler;
use Suot\Fiscal\Core\Exception\InfrastructureException;
use Suot\Fiscal\Core\Result\RetryMode;

final class EmitirViaHandler
{
    public function __construct(
        private readonly IssueCteHandler $issueHandler,
    ) {}

    public function __invoke(IssueCteCommand $command): void
    {
        try {
            $result = $this->issueHandler->handle($command);
        } catch (InfrastructureException $e) {
            $failure = $e->toFailure('issue');
            // Host: alertar; filar retry conforme $failure->retryPolicy
            throw $e;
        }

        if ($result->isAuthorized()) {
            // Host: persistir accessKey, protocolNumber, submittedDocumentXml, responseXml, receivedAt, operationId
        }

        if ($result->isRejected()) {
            $failure = $result->failure();
            $policy = $result->retryPolicy();
            match ($policy?->mode) {
                RetryMode::AfterCorrection => /* $command->revise()->withOperationId(…)->…->build() + handle de novo */,
                RetryMode::QueryBeforeRetry => /* consultar por chave antes de reemitir */,
                RetryMode::AfterDelay, RetryMode::Immediate => /* filar conforme política */,
                RetryMode::Never, null => /* definitivo; não reenviar */,
            };
        }

        if ($result->isProcessing()) {
            // Host: consultar por chave/protocolo; não emitir de novo às cegas
        }
    }
}

use Suot\Fiscal\CteOs\Application\CteOs;
use Suot\Fiscal\Core\Exception\InfrastructureException;
use Suot\Fiscal\Core\Result\RetryMode;

final class EmitirCteOsAction
{
    public function __construct(
        private readonly CteOs $cteOs,
    ) {}

    public function __invoke(): void
    {
        try {
            $result = $this->cteOs
                ->serviceStatus()
                ->forOperation('charter-status')
                ->forUf('TO')
                ->inHomologation()
                ->handle();
        } catch (InfrastructureException $e) {
            $failure = $e->toFailure('service_status');
            // Host: alertar; filar retry conforme $failure->retryPolicy
            throw $e;
        }

        if ($result->isOperational()) {
            // Host: seguir para $this->cteOs->issue()…->handle()
        }
    }
}

use Suot\Fiscal\Bpe\Application\Bpe;
use Suot\Fiscal\Core\Exception\InfrastructureException;
use Suot\Fiscal\Core\Result\RetryMode;
use Suot\Fiscal\Core\ValueObject\Uf;

final class EmitirBpeAction
{
    public function __construct(
        private readonly Bpe $bpe,
    ) {}

    public function __invoke(): void
    {
        try {
            $result = $this->bpe
                ->serviceStatus()
                ->forOperation('ticket-status')
                ->inHomologation()
                ->issuerUf(new Uf('TO'))
                ->handle();
        } catch (InfrastructureException $e) {
            $failure = $e->toFailure('service_status');
            // Host: alertar; filar retry conforme $failure->retryPolicy
            throw $e;
        }

        if ($result->isOperational()) {
            // Host: seguir para $this->bpe->issue()…->handle()
        }
    }
}

use Suot\Fiscal\Mdfe\Application\Mdfe;
use Suot\Fiscal\Core\Exception\InfrastructureException;
use Suot\Fiscal\Core\Result\RetryMode;
use Suot\Fiscal\Core\ValueObject\Uf;

final class EmitirMdfeAction
{
    public function __construct(
        private readonly Mdfe $mdfe,
    ) {}

    public function __invoke(): void
    {
        try {
            $result = $this->mdfe
                ->serviceStatus()
                ->forOperation('manifest-status')
                ->inHomologation()
                ->issuerUf(new Uf('RS'))
                ->handle();
        } catch (InfrastructureException $e) {
            $failure = $e->toFailure('service_status');
            // Host: alertar; filar retry conforme $failure->retryPolicy
            throw $e;
        }

        if ($result->isOperational()) {
            // Host: seguir para $this->mdfe->issue()…->handle()
        }
    }
}