exposure

type EventType string

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

type Filter struct {
	TenantID        *string     // Filter by tenant ID
	AssetID         *string     // Filter by asset ID
	EventTypes      []EventType // Filter by event types
	Severities      []Severity  // Filter by severities
	States          []State     // Filter by states
	Sources         []string    // Filter by sources
	Search          *string     // Full-text search across title and description
	FirstSeenAfter  *int64      // Filter by first seen after (unix timestamp)
	FirstSeenBefore *int64      // Filter by first seen before (unix timestamp)
	LastSeenAfter   *int64      // Filter by last seen after (unix timestamp)
	LastSeenBefore  *int64      // Filter by last seen before (unix timestamp)
}

type ListOptions struct {
	Sort *pagination.SortOption
}

type Repository interface {
	// Create persists a new exposure event.
	Create(ctx context.Context, event *ExposureEvent) error

	// CreateInTx persists a new exposure event within an existing transaction.
	// This is used for the transactional outbox pattern.
	CreateInTx(ctx context.Context, tx *sql.Tx, event *ExposureEvent) error

	// GetByID retrieves an exposure event by its ID.
	GetByID(ctx context.Context, id shared.ID) (*ExposureEvent, error)

	// GetByTenantAndID retrieves an exposure event by tenant and ID (tenant-scoped access control).
	GetByTenantAndID(ctx context.Context, tenantID, id shared.ID) (*ExposureEvent, error)

	// GetByFingerprint retrieves an exposure event by fingerprint within a tenant.
	GetByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (*ExposureEvent, error)

	// Update updates an existing exposure event.
	Update(ctx context.Context, event *ExposureEvent) error

	// Delete removes an exposure event by its ID.
	Delete(ctx context.Context, id shared.ID) error

	// List retrieves exposure events with filtering, sorting, and pagination.
	List(ctx context.Context, filter Filter, opts ListOptions, page pagination.Pagination) (pagination.Result[*ExposureEvent], error)

	// Count returns the total number of exposure events matching the filter.
	Count(ctx context.Context, filter Filter) (int64, error)

	// ListByAsset retrieves all exposure events for an asset.
	ListByAsset(ctx context.Context, assetID shared.ID, page pagination.Pagination) (pagination.Result[*ExposureEvent], error)

	// ExistsByFingerprint checks if an exposure event with the given fingerprint exists.
	ExistsByFingerprint(ctx context.Context, tenantID shared.ID, fingerprint string) (bool, error)

	// Upsert creates or updates an exposure event based on fingerprint.
	// If the fingerprint exists, updates last_seen_at. Otherwise creates a new event.
	Upsert(ctx context.Context, event *ExposureEvent) error

	// BulkUpsert creates or updates multiple exposure events based on fingerprint.
	// Uses batch INSERT with ON CONFLICT for better performance.
	BulkUpsert(ctx context.Context, events []*ExposureEvent) error

	// CountByState returns counts grouped by state for a tenant.
	CountByState(ctx context.Context, tenantID shared.ID) (map[State]int64, error)

	// CountBySeverity returns counts grouped by severity for a tenant.
	CountBySeverity(ctx context.Context, tenantID shared.ID) (map[Severity]int64, error)
}

type Severity string

type State string

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

type StateHistoryRepository interface {
	// Create persists a new state history entry.
	Create(ctx context.Context, history *StateHistory) error

	// ListByExposureEvent retrieves all state history for an exposure event.
	ListByExposureEvent(ctx context.Context, exposureEventID shared.ID) ([]*StateHistory, error)

	// GetLatest retrieves the most recent state change for an exposure event.
	GetLatest(ctx context.Context, exposureEventID shared.ID) (*StateHistory, error)
}