TransactionalOutbox.cs

using MyCompany.ECommerce.TechnicalStuff.ProcessModel;

namespace MyCompany.ECommerce.TechnicalStuff.Outbox;

public class TransactionalOutbox
{
    private readonly List<OutboxMessage> _messages = new();
    private readonly TransactionalOutboxRepository _repository;

    protected TransactionalOutbox(TransactionalOutboxes outboxes, TransactionalOutboxRepository repository)
    {
        outboxes.Register(this);
        _repository = repository;
    }

    public Task Save() => _repository.Save(_messages);

    protected void Add(string partitionKey, string processorType, string messageTypeId, string payload) =>
        _messages.Add(new OutboxMessage(Guid.NewGuid(), partitionKey, processorType, messageTypeId, payload));
}

public abstract class TransactionalOutbox<TMessage>(
    TransactionalOutboxes outboxes,
    TransactionalOutboxRepository repository,
    MessageTypes messageTypes)
    : TransactionalOutbox(outboxes, repository)
    where TMessage : Message
{
    public void Add(TMessage message)
    {
        var partitionKey = GetPartitionKeyFor(message);
        var processorType = GetProcessorTypeFor(message);
        var messageTypeId = messageTypes.GetTypeIdFor(message);
        var payload = CreatePayloadFrom(message);
        Add(partitionKey, processorType, messageTypeId, payload);
    }

    protected abstract string GetPartitionKeyFor(TMessage message);

    protected abstract string GetProcessorTypeFor(TMessage message);

    protected abstract string CreatePayloadFrom(TMessage message);
}