The next generation of
enterprise integration.

public sealed class Hl7LabOrderSplitter
    : PipelineComponentBase<Hl7Config>
{
    public override string Name => "fnHl7LabOrderSplitter";
 
    // Disassemble the HL7 batch, then split per order
    protected override async Task<PipelineComponentOutput> ExecuteAsync(
        PipelineComponentInput input, Hl7Config config, CancellationToken ct)
    {
        var json   = Hl7.Disassemble(input.Body, config.CanonicalSchema);
        var orders = json.SelectTokens("$.orders[*]");
        return PipelineComponentOutput.Split(orders);
    }
}

public sealed class EdiDebatcher
    : PipelineComponentBase<EdiConfig>
{
    public override string Name => "fnEdiDebatcher";
 
    // Decode, debatch the interchange, disassemble by EDI type
    protected override async Task<PipelineComponentOutput> ExecuteAsync(
        PipelineComponentInput input, EdiConfig config, CancellationToken ct)
    {
        var raw         = Convert.FromBase64String(input.AsString());
        var interchange = Edi.Debatch(raw);
        var messages    = interchange.Select(tx => Edi.Disassemble(tx, tx.DetectType()));
        return PipelineComponentOutput.Many(messages);
    }
}

public sealed class BankWireGate
    : PipelineComponentBase<WireConfig>
{
    public override string Name => "fnBankWireGate";
 
    // Decrypt with the key parameter, validate, forward or throw
    protected override async Task<PipelineComponentOutput> ExecuteAsync(
        PipelineComponentInput input, WireConfig config, CancellationToken ct)
    {
        var wire = Crypto.Decrypt(input.Body, config.DecryptionKey);
        if (!Wire.IsValid(wire, out var error))
            throw new PipelineException(error);
        return PipelineComponentOutput.Single(wire);
    }
}