notification

type CreateNotificationInput struct {
	Recipients []Recipient            `json:"recipients" validate:"required,min=1"`
	Type       string                 `json:"type" validate:"required"`
	Title      string                 `json:"title" validate:"required,max=255"`
	Message    string                 `json:"message" validate:"required"`
	Data       map[string]interface{} `json:"data,omitempty"`
}

type ExternalNotifier interface {
	DispatchToTeam(ctx context.Context, teamID, notificationType, title, message string, data map[string]interface{})
}

type ListResult struct {
	Notifications []*Notification `json:"notifications"`
	Total         int             `json:"total"`
	NextCursor    string          `json:"next_cursor,omitempty"`
}

type Notification struct {
	ID            string                 `json:"id"`
	UserID        string                 `json:"user_id"`
	RecipientType string                 `json:"recipient_type"`
	RecipientID   string                 `json:"recipient_id"`
	Type          string                 `json:"type"`
	Title         string                 `json:"title"`
	Message       string                 `json:"message"`
	Data          map[string]interface{} `json:"data,omitempty"`
	Read          bool                   `json:"read"`
	ReadAt        *time.Time             `json:"read_at,omitempty"`
	CreatedAt     time.Time              `json:"created_at"`
}

type NotificationFilter struct {
	UserID   string
	Type     string
	ReadOnly *bool
	Cursor   string
	Limit    int
	Offset   int
}

type NotificationSummary struct {
	UnreadCount int `json:"unread_count"`
	TotalCount  int `json:"total_count"`
}

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

type Recipient struct {
	Type string `json:"type"`
	ID   string `json:"id"`
}

type Repository interface {
	CreateBatch(ctx context.Context, userRecipients map[string]Recipient, input CreateNotificationInput, batchSize int) (int, error)
	Get(ctx context.Context, id string) (*Notification, error)
	List(ctx context.Context, filter NotificationFilter) ([]*Notification, int, error)
	ListWithCursor(ctx context.Context, filter NotificationFilter) (*ListResult, error)
	GetSummary(ctx context.Context, userID string) (*NotificationSummary, error)
	MarkAsRead(ctx context.Context, id string) error
	MarkAllAsRead(ctx context.Context, userID string) error
	MarkAllAsReadChunked(ctx context.Context, userID string, chunkSize int) error
	Delete(ctx context.Context, id string) error
	DeleteAllRead(ctx context.Context, userID string) error
	DeleteOlderThan(ctx context.Context, before time.Time) (int64, error)
	DeleteReadOlderThan(ctx context.Context, before time.Time) (int64, error)
	EnforcePerUserLimit(ctx context.Context, maxPerUser int) (int64, error)
}

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

type ServiceConfig struct {
	MaxWorkers         int
	QueueSize          int
	BatchSize          int
	PruneAge           time.Duration
	PruneReadAge       time.Duration
	PruneInterval      time.Duration
	MaxPerUser         int
	AggregateWindow    time.Duration
	AggregateMaxWait   time.Duration
	DisableAggregation bool
}

type ServiceOption func(*Service)

type TeamMembershipProvider interface {
	GetTeamMemberUserIDs(ctx context.Context, teamID string) ([]string, error)
}

type UserPreferencesProvider interface {
	GetNotificationPreferences(ctx context.Context, userID string) (map[string]bool, error)
	GetNotificationPreferencesBatch(ctx context.Context, userIDs []string) (map[string]map[string]bool, error)
}