pubsub

type DLQRepository interface {
	// Load retrieves a DLQ item by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.DeadLetterQueue, error)

	// Save creates a new DLQ item (if Id=0) or updates an existing one.
	// Returns the saved DLQ item with populated Id.
	Save(ctx context.Context, m model.DeadLetterQueue) (model.DeadLetterQueue, error)

	// Delete permanently removes a DLQ item from storage.
	// Should only be used after successful resolution or manual cleanup.
	Delete(ctx context.Context, m model.DeadLetterQueue) error

	// FindBySubscription retrieves DLQ items for a specific subscription.
	// Results are ordered by created_at DESC (newest first).
	FindBySubscription(ctx context.Context, subscriptionID int64, limit int) ([]model.DeadLetterQueue, error)

	// FindUnresolved retrieves unresolved DLQ items.
	// Results are ordered by created_at ASC (oldest first).
	FindUnresolved(ctx context.Context, limit int) ([]model.DeadLetterQueue, error)

	// FindOlderThan retrieves DLQ items older than the specified threshold.
	// Useful for identifying stuck items requiring attention.
	FindOlderThan(ctx context.Context, threshold time.Duration, limit int) ([]model.DeadLetterQueue, error)

	// FindByMessageID retrieves a DLQ item for a specific message.
	// Returns ErrNoData if not found.
	FindByMessageID(ctx context.Context, messageID int64) (model.DeadLetterQueue, error)

	// GetStats retrieves DLQ statistics including total count, unresolved count,
	// resolution rate, and average age.
	GetStats(ctx context.Context) (model.DLQStats, error)

	// CountUnresolved returns the count of unresolved DLQ items.
	// Useful for dashboard widgets and monitoring.
	CountUnresolved(ctx context.Context) (int, error)
}

type Error struct {
	// Code is a machine-readable error code
	Code string

	// Message is a human-readable error message
	Message string

	// Err is the underlying error (if any)
	Err error
}

type Filter struct {
	SubscriberID int    // Filter by subscriber ID (0 = no filter)
	CbuID        int    // Filter by CBU ID (0 = no filter)
	TopicID      string // Filter by topic ID (empty = no filter)
	IsActive     bool   // Filter by active status
}

type Logger interface {
	// Debugf logs debug-level messages with printf-style formatting.
	Debugf(format string, args ...interface{})

	// Infof logs info-level messages with printf-style formatting.
	Infof(format string, args ...interface{})

	// Warnf logs warning-level messages with printf-style formatting.
	Warnf(format string, args ...interface{})

	// Errorf logs error-level messages with printf-style formatting.
	Errorf(format string, args ...interface{})

	// Info logs info-level messages without formatting.
	Info(message string)
}

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

type MessageDeliveryGateway interface {
	// DeliverMessage sends a message to the subscriber's webhook endpoint.
	// Returns error if delivery fails (network error, non-2xx response, timeout).
	DeliverMessage(ctx context.Context, callbackURL string, message *model.DataMessage) error
}

type MessageRepository interface {
	// Load retrieves a message by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Message, error)

	// Save creates a new message (if Id=0) or updates an existing one.
	// Returns the saved message with populated Id.
	Save(ctx context.Context, m model.Message) (model.Message, error)

	// Delete permanently removes a message from storage.
	// Should only be used for cleanup, not during normal operation.
	Delete(ctx context.Context, m model.Message) error

	// FindOutdatedMessages finds messages older than the specified number of days.
	// Used for cleanup/archival operations.
	FindOutdatedMessages(ctx context.Context, days int) ([]model.Message, error)
}

type NoOpNotificationService struct{}

type NoopLogger struct{}

type NotificationService interface {
	// NotifyDLQItemAdded is called when a message is moved to the Dead Letter Queue.
	// This indicates a message failed after all retry attempts.
	NotifyDLQItemAdded(ctx context.Context, dlq model.DeadLetterQueue) error

	// NotifyDeliveryFailure is called when a message delivery fails.
	// This is informational and happens before moving to DLQ.
	NotifyDeliveryFailure(ctx context.Context, queue *model.Queue, err error) error

	// NotifySubscriptionCreated is called when a new subscription is created.
	NotifySubscriptionCreated(ctx context.Context, subscription model.Subscription) error

	// NotifySubscriptionDeactivated is called when a subscription is deactivated.
	NotifySubscriptionDeactivated(ctx context.Context, subscription model.Subscription) error
}

type Option func(*QueueWorker) error

type PublishRequest struct {
	TopicCode  string // Topic code to publish to
	Identifier string // Message identifier (event type)
	Data       string // Message payload
}

type PublishResult struct {
	MessageID         int64   // Created message ID
	QueueItemsCreated int     // Number of queue items created
	SubscriptionsIDs  []int64 // Subscription IDs that received the message
}

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

type PublisherOption func(*Publisher) error

type PublisherRepository interface {
	// Load retrieves a publisher by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Publisher, error)

	// Save creates a new publisher (if Id=0) or updates an existing one.
	// Returns the saved publisher with populated Id.
	Save(ctx context.Context, m model.Publisher) (model.Publisher, error)

	// GetByPublisherCode retrieves a publisher by its unique code.
	// Returns ErrNoData if not found.
	GetByPublisherCode(ctx context.Context, publisherCode string) (model.Publisher, error)
}

type QueueRepository interface {
	// Load retrieves a queue item by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Queue, error)

	// Save creates a new queue item (if Id=0) or updates an existing one.
	// Returns the saved queue item with populated Id.
	Save(ctx context.Context, m *model.Queue) (*model.Queue, error)

	// Delete permanently removes a queue item from storage.
	Delete(ctx context.Context, m *model.Queue) error

	// FindByMessageID finds a queue item for a specific message and subscription.
	// Returns ErrNoData if not found.
	FindByMessageID(ctx context.Context, subscriptionID, messageID int64) (model.Queue, error)

	// FindBySubscriptionID retrieves all queue items for a subscription.
	// Returns empty slice if none found.
	FindBySubscriptionID(ctx context.Context, subscriptionID int64) ([]model.Queue, error)

	// FindPendingItems finds queue items ready for first-time delivery.
	// Items must have status=PENDING and next_retry_at <= now.
	// Results are ordered by created_at ASC (FIFO).
	FindPendingItems(ctx context.Context, limit int) ([]model.Queue, error)

	// FindRetryableItems finds queue items ready for retry.
	// Items must have status=FAILED and next_retry_at <= now.
	// Results are ordered by created_at ASC (oldest failures first).
	FindRetryableItems(ctx context.Context, limit int) ([]model.Queue, error)

	// FindExpiredItems finds queue items that have expired.
	// Items must have expires_at <= now and status != SENT.
	// Results are ordered by expires_at ASC (oldest first).
	FindExpiredItems(ctx context.Context, limit int) ([]model.Queue, error)

	// UpdateNextRetry updates the retry schedule for a queue item.
	// Used by retry middleware to schedule next delivery attempt.
	UpdateNextRetry(ctx context.Context, id int64, nextRetryAt time.Time, attemptCount int) error
}

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

type SubscribeRequest struct {
	SubscriberID int64  // ID of the subscriber (required, must exist)
	TopicCode    string // Topic code to subscribe to (required, must exist)
	Identifier   string // Event identifier filter (required, e.g., "user-123")
	CallbackURL  string // Webhook URL for message delivery (optional, can be set on subscriber)
}

type SubscriberRepository interface {
	// Load retrieves a subscriber by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Subscriber, error)

	// Save creates a new subscriber (if Id=0) or updates an existing one.
	// Returns the saved subscriber with populated Id.
	Save(ctx context.Context, m model.Subscriber) (model.Subscriber, error)

	// FindByClientID retrieves a subscriber by client ID.
	// Returns ErrNoData if not found.
	FindByClientID(ctx context.Context, clientID int64) (model.Subscriber, error)

	// FindByName retrieves a subscriber by name.
	// Returns ErrNoData if not found.
	FindByName(ctx context.Context, name string) (model.Subscriber, error)
}

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

type SubscriptionManagerOption func(*SubscriptionManager) error

type SubscriptionRepository interface {
	// Load retrieves a subscription by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Subscription, error)

	// Save creates a new subscription (if Id=0) or updates an existing one.
	// Returns the saved subscription with populated Id.
	Save(ctx context.Context, m model.Subscription) (model.Subscription, error)

	// FindActive finds active subscriptions matching the criteria.
	// If subscriberID=0, searches all subscribers.
	// If identifier is empty, searches all identifiers.
	FindActive(ctx context.Context, subscriberID int64, identifier string) ([]model.Subscription, error)

	// List retrieves subscriptions matching the filter criteria.
	// Returns empty slice if none found.
	List(ctx context.Context, filter Filter) ([]model.Subscription, error)

	// FindAllActive retrieves all active subscriptions with full details.
	// Returns SubscriptionFull with joined subscriber and topic information.
	FindAllActive(ctx context.Context) ([]model.SubscriptionFull, error)
}

type TopicRepository interface {
	// Load retrieves a topic by ID.
	// Returns ErrNoData if not found.
	Load(ctx context.Context, id int64) (model.Topic, error)

	// Save creates a new topic (if Id=0) or updates an existing one.
	// Returns the saved topic with populated Id.
	Save(ctx context.Context, m model.Topic) (model.Topic, error)

	// GetByTopicCode retrieves a topic by its unique code.
	// Returns ErrNoData if not found.
	GetByTopicCode(ctx context.Context, topicCode string) (model.Topic, error)
}

type TransmitterProvider interface {
	// GetCallbackUrl retrieves the webhook URL for a subscriber.
	// Returns ErrNoData if subscriber not found.
	GetCallbackUrl(ctx context.Context, subscriberID int64) (string, error)
}