Distribuição DF-e de CT-e

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

try {
    $byNsu = $cte->distributeDfe()
        ->forOperation('dist-nsu-1')
        ->inHomologation()
        ->authorizerUf(new Uf('RS'))
        ->cnpj($cnpj)
        ->fromUltNsu('0') // alias: ultNsu()
        ->handle();
} catch (InfrastructureException $e) {
    $failure = $e->toFailure('distribute_dfe');
    // Host: alertar; filar retry conforme $failure->retryPolicy; não avançar ultNSU às cegas
    throw $e;
}

$failure = $byNsu->failure();
if ($failure === null) {
    // Host: persistir ultNsu / maxNsu; processar procDocuments() e eventDocuments()
} else {
    $policy = $byNsu->retryPolicy();
    match ($policy?->mode) {
        RetryMode::AfterDelay, RetryMode::Immediate => /* filar nova sync */,
        RetryMode::Never, null => /* alertar; não corromper cursor NSU */,
        default => /* seguir recoveryGuide */,
    };
}

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

try {
    $byKey = $cte->distributeDfe()
        ->forOperation('dist-key-1')
        ->inHomologation()
        ->authorizerUf(new Uf('RS'))
        ->cnpj($cnpj)
        ->forAccessKey($chave44)
        ->handle();
} catch (InfrastructureException $e) {
    $failure = $e->toFailure('distribute_dfe');
    // Host: alertar; filar retry conforme $failure->retryPolicy
    throw $e;
}

$failure = $byKey->failure();
if ($failure === null) {
    // Host: persistir documentos encontrados; atualizar cursor NSU se aplicável
} else {
    $policy = $byKey->retryPolicy();
    match ($policy?->mode) {
        RetryMode::AfterDelay, RetryMode::Immediate => /* filar nova busca */,
        RetryMode::Never, null => /* não inventar documento; alertar */,
        default => /* seguir recoveryGuide */,
    };
}