We engineerthat scale.

// GenifySoft.Ordering.Api

public sealed class OrderPipelineService(

IOrderRepository orders,

IPublishEndpoint bus,

IDistributedCache cache)

: IOrderPipelineService

{

public async Task<Result<OrderDto>> SubmitAsync(

SubmitOrderCommand cmd, CancellationToken ct)

{

var policy = await cache.GetAsync<CreditPolicy>(

$"tenant:{cmd.TenantId}", ct);

var order = OrderAggregate.Create(cmd.Lines);

if (!policy!.Allows(order.Total))

return Result.Fail<OrderDto>("CREDIT_EXCEEDED");

await orders.UnitOfWork.ExecuteAsync(async () =>

{

await orders.AddAsync(order, ct);

await bus.Publish(new OrderSubmittedEvent(order.Id), ct);

}, ct);

return Result.Ok(order.ToDto());

}

}