repository

type IncidentRepository interface {
	List(ctx context.Context, filter bson.M, page, limit int) ([]models.Incident, int64, error)
	FindByID(ctx context.Context, id primitive.ObjectID) (models.Incident, error)
	InsertIncident(ctx context.Context, incident models.Incident) error
	UpdateIncidentByID(ctx context.Context, id primitive.ObjectID, setFields bson.M) (models.Incident, error)
	DeleteIncidentByID(ctx context.Context, id primitive.ObjectID) error
	InsertUpdate(ctx context.Context, update models.IncidentUpdate) error
	ApplyIncidentStatus(ctx context.Context, incidentID primitive.ObjectID, status models.IncidentStatus) error
	ListUpdates(ctx context.Context, incidentID primitive.ObjectID) ([]models.IncidentUpdate, error)
	InsertAuditLog(ctx context.Context, audit models.AuditLog) error
	ListHistory(ctx context.Context, incidentID primitive.ObjectID) ([]models.AuditLog, error)
	CountComponents(ctx context.Context, ids []primitive.ObjectID) (int64, error)
	CountSubComponentsByComponent(ctx context.Context, componentID primitive.ObjectID, ids []primitive.ObjectID) (int64, error)
}

type MaintenanceRepository interface {
	List(ctx context.Context, page, limit int) ([]models.Maintenance, int64, error)
	ListPublic(ctx context.Context, page, limit int) ([]models.Maintenance, int64, error)
	FindByID(ctx context.Context, id primitive.ObjectID) (models.Maintenance, error)
	Insert(ctx context.Context, maintenance models.Maintenance) error
	UpdateByID(ctx context.Context, id primitive.ObjectID, setFields bson.M) (models.Maintenance, error)
	DeleteByID(ctx context.Context, id primitive.ObjectID) error
	InsertAuditLog(ctx context.Context, audit models.AuditLog) error
	ListHistory(ctx context.Context, maintenanceID primitive.ObjectID) ([]models.AuditLog, error)
}

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

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

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

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

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

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

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

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

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

type MonitorRepository interface {
	Insert(ctx context.Context, monitor models.Monitor) error
	Update(ctx context.Context, id primitive.ObjectID, monitor models.Monitor) (bool, error)
	Delete(ctx context.Context, id primitive.ObjectID) (bool, error)
	List(ctx context.Context, page, limit int) ([]models.Monitor, int64, error)
	ListLogs(ctx context.Context, monitorID primitive.ObjectID, limit int64) ([]models.MonitorLog, error)
	FindLogsByMonitorIDPaginated(ctx context.Context, monitorID primitive.ObjectID, page, limit int) ([]models.MonitorLog, int64, error)
	ListUptime(ctx context.Context, monitorID primitive.ObjectID, since time.Time) ([]models.DailyUptime, error)
	ListOutages(ctx context.Context) ([]models.Outage, error)
	ListHistory(ctx context.Context, monitorID primitive.ObjectID, limit int64) ([]models.EnhancedMonitorLog, error)
}

type SettingsRepository interface {
	GetSSOSettings(ctx context.Context) (*models.StatusPageSSOSettings, error)
	UpdateSSOSettings(ctx context.Context, updates bson.M) (*models.StatusPageSSOSettings, error)
}

type StatusRepository interface {
	ListComponents(ctx context.Context) ([]models.Component, error)
	ListComponentsByIDs(ctx context.Context, ids []primitive.ObjectID) ([]models.Component, error)
	ListSubComponentsByComponentIDs(ctx context.Context, componentIDs []primitive.ObjectID) ([]models.SubComponent, error)
	ListAllSubComponents(ctx context.Context) ([]models.SubComponent, error)
	ListSubComponentsByIDs(ctx context.Context, ids []primitive.ObjectID) ([]models.SubComponent, error)
	FindMonitorByID(ctx context.Context, id primitive.ObjectID) (*models.Monitor, error)
	FindMonitorBySubComponentID(ctx context.Context, subComponentID primitive.ObjectID) (*models.Monitor, error)
	ListMonitorsByTargets(ctx context.Context, componentIDs []primitive.ObjectID, subComponentIDs []primitive.ObjectID) ([]models.Monitor, error)
	ListMonitorsByServiceID(ctx context.Context, serviceID primitive.ObjectID) ([]models.Monitor, error)
	ListMonitorLogsByMonitorIDsSince(ctx context.Context, monitorIDs []primitive.ObjectID, since time.Time) ([]models.MonitorLog, error)
	ListDailyUptimeSinceByMonitorIDs(ctx context.Context, monitorIDs []primitive.ObjectID, since time.Time) ([]models.DailyUptime, error)
	ListActiveIncidents(ctx context.Context) ([]models.Incident, error)
	ListActiveMaintenanceAt(ctx context.Context, at time.Time) ([]models.Maintenance, error)
	CountActiveIncidents(ctx context.Context) (int64, error)
	CountActiveMaintenanceAt(ctx context.Context, at time.Time) (int64, error)
	FindLatestIncidentByComponent(ctx context.Context, componentID primitive.ObjectID) (*models.Incident, error)
	ListIncidentsByCreatedAtRange(ctx context.Context, start, end time.Time) ([]models.Incident, error)
	ListResolvedIncidentsSince(ctx context.Context, since time.Time) ([]models.Incident, error)
	ListIncidentsByAffectedComponents(ctx context.Context, affectedIDs []primitive.ObjectID, limit int64) ([]models.Incident, error)
	ListIncidentUpdatesByIncidentIDs(ctx context.Context, incidentIDs []primitive.ObjectID) (map[primitive.ObjectID][]models.IncidentUpdate, error)
}

type SubComponentRepository interface {
	List(ctx context.Context, filter bson.M, page, limit int) ([]models.SubComponent, int64, error)
	Insert(ctx context.Context, sub models.SubComponent) error
	UpdateByID(ctx context.Context, id primitive.ObjectID, setFields bson.M) (models.SubComponent, error)
	FindByID(ctx context.Context, id primitive.ObjectID) (models.SubComponent, error)
	DeleteByID(ctx context.Context, id primitive.ObjectID) (int64, error)
	CountByComponentID(ctx context.Context, componentID primitive.ObjectID) (int64, error)
	ComponentExists(ctx context.Context, id primitive.ObjectID) (bool, error)
	CleanupReferencesForDeletedSubComponent(ctx context.Context, subComponentID primitive.ObjectID, componentID primitive.ObjectID) error
}

type SubscriberRepository interface {
	FindByEmail(ctx context.Context, email string) (*models.Subscriber, error)
	Insert(ctx context.Context, sub models.Subscriber) error
	List(ctx context.Context, page, limit int) ([]models.Subscriber, int64, error)
	DeleteByID(ctx context.Context, id primitive.ObjectID) (bool, error)
}

type UserRepository interface {
	FindByEmailHash(ctx context.Context, emailHash string) (*models.User, error)
	EmailExistsByHash(ctx context.Context, emailHash string) (bool, error)
	Create(ctx context.Context, user models.User) error
	FindByID(ctx context.Context, id string) (*models.User, error)
	UpdateProfile(ctx context.Context, id string, username string, passwordHash *string) error
	BeginMFAEnrollment(ctx context.Context, id string, secretEnc string, recoveryHashes []string) error
	EnableMFA(ctx context.Context, id string) error
	DisableMFA(ctx context.Context, id string) error
	ReplaceRecoveryCodes(ctx context.Context, id string, hashes []string) error
}

type WebhookChannelRepository interface {
	List(ctx context.Context, page, limit int) ([]models.WebhookChannel, int64, error)
	Insert(ctx context.Context, channel models.WebhookChannel) error
	DeleteByID(ctx context.Context, id primitive.ObjectID) (bool, error)
}