Evo.Grpc.Client.DTA.Pipeline

gRPC client for the DTA pipeline gateway.

Setup

Requires an ICallTokenProvider from Evo.Grpc.Client.Common; the clients hold no static API token. The endpoint is read from URL_DAKOTA_PIPELINE and validated at registration.

services.AddNativeKeycloakAuth(o =>
{
    o.TokenEndpoint = "https://auth.praxx.me/realms/henara/protocol/openid-connect/token";
    o.ClientId      = "henara-main-sso";
});
services.AddDTAPipelineClient();

IDTAGatewayClient

IAsyncEnumerable<DTADispatchResult> DispatchDTAProcess(List<DTAPairRequest> pairs, CancellationToken ct = default);
Task<Result<bool, Failure>> IsPipelineStepRetryDispatched(Guid tickerId);
Task<Result<CustomerRoutingInfo, Failure>> GetCustomerRoutingInfo(string customerId, string? lebIk = null, CancellationToken ct = default);

• DispatchDTAProcess streams one ESOL/AUF pair per request and yields one result per pair. The intake gate authorises each pair by the sender IK carried in the file; a rejected pair returns IsDispatched == false with a Message.
• GetCustomerRoutingInfo takes an 8-digit customer id and an optional LEB-IK and needs no token. Exactly one mapping returns its IKs with IsSelbstabrechner == true; an unmapped id returns empty IKs with IsSelbstabrechner == false. More than one mapping (customer with several LEB-IKs and no LEB-IK given) returns a Failure stating that passing the LEB-IK can resolve it; a malformed id also returns a Failure.