common

Documentation

Index

• Variables
• func GetAccountRepository(uow repository.UnitOfWork, log *slog.Logger) (account.Repository, error)
• func GetTransactionRepository(uow repository.UnitOfWork, log *slog.Logger) (transaction.Repository, error)
• func GetUserRepository(uow repository.UnitOfWork, log *slog.Logger) (user.Repository, error)
• func WithIdempotency(handler eventbus.HandlerFunc, tracker *IdempotencyTracker, ...) eventbus.HandlerFunc
• type IdempotencyTracker
  • func NewIdempotencyTracker() *IdempotencyTracker
  • func (t *IdempotencyTracker) Delete(key string)
  • func (t *IdempotencyTracker) IsProcessed(key string) bool
  • func (t *IdempotencyTracker) Store(key string)
• type KeyExtractor
• type TransactionLookupResult
  • func LookupTransactionByPaymentOrID(ctx context.Context, txRepo transaction.Repository, paymentID *string, ...) TransactionLookupResult

Variables

var ErrInvalidRepositoryType = errors.New("invalid repository type")

Functions

func GetAccountRepository

func GetAccountRepository(
	uow repository.UnitOfWork,
	log *slog.Logger,
) (
	account.Repository,
	error,
)

func GetTransactionRepository

func GetTransactionRepository(
	uow repository.UnitOfWork,
	log *slog.Logger,
) (
	transaction.Repository,
	error,
)

func GetUserRepository

func GetUserRepository(
	uow repository.UnitOfWork,
	log *slog.Logger,
) (
	user.Repository,
	error,
)

func WithIdempotency

func WithIdempotency(
	handler eventbus.HandlerFunc,
	tracker *IdempotencyTracker,
	keyExtractor KeyExtractor,
	handlerName string,
	logger *slog.Logger,
) eventbus.HandlerFunc

WithIdempotency wraps a handler with idempotency checking middleware. The middleware checks if the event has been processed before calling the handler, and marks it as processed after successful execution.

Types

type IdempotencyTracker

type IdempotencyTracker struct {
	// contains filtered or unexported fields
}

IdempotencyTracker tracks processed events by key

func NewIdempotencyTracker

func NewIdempotencyTracker() *IdempotencyTracker

NewIdempotencyTracker creates a new idempotency tracker

func (*IdempotencyTracker) Delete

func (t *IdempotencyTracker) Delete(key string)

Delete removes a key from the tracker

func (*IdempotencyTracker) IsProcessed

func (t *IdempotencyTracker) IsProcessed(key string) bool

func (*IdempotencyTracker) Store

func (t *IdempotencyTracker) Store(key string)

Store marks a key as processed

type KeyExtractor

type KeyExtractor func(events.Event) string

KeyExtractor extracts an idempotency key from an event

type TransactionLookupResult

type TransactionLookupResult struct {
	Transaction   *dto.TransactionRead
	TransactionID uuid.UUID
	Found         bool
	Error         error
}

TransactionLookupResult contains transaction lookup result

func LookupTransactionByPaymentOrID

func LookupTransactionByPaymentOrID(
	ctx context.Context,
	txRepo transaction.Repository,
	paymentID *string,
	transactionID uuid.UUID,
	log *slog.Logger,
) TransactionLookupResult

LookupTransactionByPaymentOrID looks up a transaction by payment ID or transaction ID