outbox

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

type EventFilter struct {
	TenantID      *shared.ID
	Status        *EventStatus
	EventType     string
	AggregateType string
	AggregateID   *uuid.UUID
	Limit         int
	Offset        int
}

type EventParams struct {
	ID                    ID
	TenantID              shared.ID
	EventType             string
	AggregateType         string
	AggregateID           *uuid.UUID
	Title                 string
	Body                  string
	Severity              Severity
	URL                   string
	Metadata              map[string]any
	Status                EventStatus
	IntegrationsTotal     int
	IntegrationsMatched   int
	IntegrationsSucceeded int
	IntegrationsFailed    int
	SendResults           []SendResult
	LastError             string
	RetryCount            int
	CreatedAt             time.Time
	ProcessedAt           time.Time
}

type EventRepository interface {

	// Create inserts a new event.
	Create(ctx context.Context, event *Event) error

	// GetByID retrieves an event by ID.
	GetByID(ctx context.Context, id ID) (*Event, error)

	// Delete removes an event.
	Delete(ctx context.Context, id ID) error

	// ListByTenant retrieves events for a tenant with pagination.
	ListByTenant(ctx context.Context, tenantID shared.ID, filter EventFilter) ([]*Event, int64, error)

	// GetStats returns aggregated statistics for events.
	GetStats(ctx context.Context, tenantID *shared.ID) (*EventStats, error)

	// ListByIntegration retrieves events that were sent to a specific integration.
	// Uses JSONB query on send_results array.
	ListByIntegration(ctx context.Context, integrationID string, limit, offset int) ([]*Event, int64, error)

	// DeleteOldEvents removes events older than the specified days.
	// If retentionDays <= 0, no deletion is performed (unlimited retention).
	DeleteOldEvents(ctx context.Context, retentionDays int) (int64, error)
}

type EventStats struct {
	Completed int64
	Failed    int64
	Skipped   int64
	Total     int64
}

type EventStatus string

type ID = shared.ID

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

type OutboxFilter struct {
	TenantID      *shared.ID
	Status        *OutboxStatus
	EventType     string
	AggregateType string
	Limit         int
	Offset        int
}

type OutboxParams struct {
	TenantID      shared.ID
	EventType     string
	AggregateType string
	AggregateID   *uuid.UUID
	Title         string
	Body          string
	Severity      Severity
	URL           string
	Metadata      map[string]any
	MaxRetries    int        // Optional, defaults to 3
	ScheduledAt   *time.Time // Optional, defaults to now
}

type OutboxRepository interface {

	// Create inserts a new outbox entry.
	Create(ctx context.Context, outbox *Outbox) error

	// CreateInTx inserts a new outbox entry within an existing transaction.
	// This is the key method for the transactional outbox pattern.
	// The tx parameter should be a *sql.Tx from the same database connection.
	CreateInTx(ctx context.Context, tx *sql.Tx, outbox *Outbox) error

	// GetByID retrieves an outbox entry by ID.
	GetByID(ctx context.Context, id ID) (*Outbox, error)

	// Update updates an outbox entry.
	Update(ctx context.Context, outbox *Outbox) error

	// Delete removes an outbox entry.
	Delete(ctx context.Context, id ID) error

	// FetchPendingBatch retrieves and locks a batch of pending outbox entries.
	// Uses FOR UPDATE SKIP LOCKED for concurrent worker safety.
	// Returns entries where scheduled_at <= now and status = 'pending'.
	FetchPendingBatch(ctx context.Context, workerID string, batchSize int) ([]*Outbox, error)

	// UnlockStale releases locks on entries that have been processing for too long.
	// This handles worker crashes or timeouts.
	UnlockStale(ctx context.Context, olderThanMinutes int) (int64, error)

	// DeleteOldCompleted removes completed entries older than the specified days.
	DeleteOldCompleted(ctx context.Context, olderThanDays int) (int64, error)

	// DeleteOldFailed removes failed/dead entries older than the specified days.
	DeleteOldFailed(ctx context.Context, olderThanDays int) (int64, error)

	// List retrieves outbox entries with filtering and pagination.
	List(ctx context.Context, filter OutboxFilter, page pagination.Pagination) (pagination.Result[*Outbox], error)

	// GetStats returns aggregated statistics for outbox entries.
	GetStats(ctx context.Context, tenantID *shared.ID) (*OutboxStats, error)

	// ListByTenant retrieves outbox entries for a tenant with pagination.
	ListByTenant(ctx context.Context, tenantID shared.ID, filter OutboxFilter) ([]*Outbox, int64, error)

	// CountByStatus returns counts grouped by status for a tenant.
	CountByStatus(ctx context.Context, tenantID shared.ID) (map[OutboxStatus]int64, error)

	// GetByAggregateID retrieves outbox entries for a specific aggregate.
	GetByAggregateID(ctx context.Context, aggregateType string, aggregateID string) ([]*Outbox, error)
}

type OutboxStats struct {
	Pending    int64
	Processing int64
	Completed  int64
	Failed     int64
	Dead       int64
	Total      int64
}

type OutboxStatus string

type ProcessingResults struct {
	IntegrationsTotal     int
	IntegrationsMatched   int
	IntegrationsSucceeded int
	IntegrationsFailed    int
	SendResults           []SendResult
}

type SendResult struct {
	IntegrationID   string    `json:"integration_id"`
	IntegrationName string    `json:"name"`
	Provider        string    `json:"provider"`
	Status          string    `json:"status"` // success, failed
	MessageID       string    `json:"message_id,omitempty"`
	Error           string    `json:"error,omitempty"`
	SentAt          time.Time `json:"sent_at"`
}

type Severity string