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();

All interfaces below resolve to one scoped client.

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. A pair is rejected when a non-admin caller does not own the customer id or the (customer id, Leistungserbringer-IK, AZ-IK) mapping read from the files is missing; a rejected pair returns IsDispatched == false with a Message.
• IsPipelineStepRetryDispatched resets the ticker so its step runs again.
• GetCustomerRoutingInfo takes a customer id of the form 2013xxxx and an optional Leistungserbringer-IK (lebIk) 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 and no lebIk, or a malformed id, returns a Failure.

IDTAGatewayResultClient

DispatchDTAProcess as above, returning transport and server errors as one final Failure element with a user-facing message.

IDTAMailRegexClient

Task<Result<IEnumerable<StoredMailSubjectInfo>, Failure>> GetStoredMailSubjects(string fromAddress, int limit, CancellationToken ct = default);
Task<Result<MailRegexPreviewResult, Failure>> PreviewMailRegex(string subject, string positivePattern, string negativePattern, CancellationToken ct = default);
Task<Result<MailReparseResult, Failure>> ReparseUnlinkedMails(CancellationToken ct = default);
Task<Result<bool, Failure>> ReopenConfirmation(Guid processId, CancellationToken ct = default);

IDTAMailRelinkClient

Task<Result<MailRelinkResult, Failure>> RelinkLinkedMails(CancellationToken ct = default);

IDTAOwnAzClient, IDTAEnvironmentClient

Task<Result<string, Failure>> GetOwnAzIk(CancellationToken ct = default);
Task<Result<bool, Failure>> GetIsTestEnvironment(CancellationToken ct = default);