monitor

type Cache interface {
	GetMonitor(ctx context.Context, id uuid.UUID) (Monitor, bool)
	SetMonitor(ctx context.Context, m Monitor) error
	Schedule(ctx context.Context, monitorID string, runAt time.Time) error
	ClearIncident(ctx context.Context, monitorID uuid.UUID) error
	DelMonitor(ctx context.Context, id uuid.UUID) error
	DelStatus(ctx context.Context, monitorID uuid.UUID) error
	DelSchedule(ctx context.Context, monitorID string) error
}

type CreateMonitor struct {
	TeamID               uuid.UUID
	UserID               uuid.UUID
	Url                  string
	IntervalSec          int32
	TimeoutSec           int32
	LatencyThresholdMs   *int32
	ExpectedStatus       *int32
	NotificationChannels []string
}

type CreateMonitorRequest struct {
	Url                  string   `json:"url" validate:"required,url"`
	IntervalSec          int32    `json:"interval_sec" validate:"required,gte=60"`
	TimeoutSec           int32    `json:"timeout_sec" validate:"required,gte=120"`
	LatencyThresholdMs   *int32   `json:"latency_threshold_ms"`
	ExpectedStatus       *int32   `json:"expected_status"`
	NotificationChannels []string `json:"notification_channels"`
}

type CreateMonitorResponse struct {
	MonitorID string `json:"monitor_id"`
}

type Cursor struct {
	CreatedAt time.Time
	MonitorID string
}

type GetMonitorResponse struct {
	ID                   string   `json:"id"`
	Url                  string   `json:"url"`
	IntervalSec          int32    `json:"interval_sec"`
	TimeoutSec           int32    `json:"timeout_sec"`
	LatencyThresholdMs   *int32   `json:"latency_threshold_ms"`
	ExpectedStatus       *int32   `json:"expected_status"`
	Enabled              bool     `json:"enabled"`
	IsDown               bool     `json:"is_down"`
	NotificationChannels []string `json:"notification_channels"`
}

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

type ListMonitorsOptions struct {
	Limit  int32
	Cursor *Cursor
}

type ListMonitorsPage struct {
	Monitors   []Monitor
	HasMore    bool
	NextCursor *string
	Limit      int32
}

type ListMonitorsResponse struct {
	Limit      int32                `json:"limit"`
	HasMore    bool                 `json:"has_more"`
	NextCursor *string              `json:"next_cursor,omitempty"`
	Monitors   []GetMonitorResponse `json:"monitors"`
}

type Monitor struct {
	ID                   uuid.UUID
	TeamID               uuid.UUID
	UserID               uuid.UUID
	Url                  string
	IntervalSec          int32
	TimeoutSec           int32
	LatencyThresholdMs   *int32
	ExpectedStatus       *int32
	Enabled              bool
	CreatedAt            time.Time
	IsDown               bool
	NotificationChannels []string
}

type MonitorRecord struct {
	ID                 uuid.UUID
	UserID             uuid.UUID
	Url                string
	IntervalSec        time.Duration
	TimeoutSec         time.Duration
	LatencyThresholdMS time.Duration
	ExpectedStatus     int
	Enabled            bool
	Disabled           bool
}

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

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

type UpdateMonitorStatusRequest struct {
	Enable *bool `json:"enable" validate:"required"`
}

type UserService interface {
	IncrementMonitorCount(ctx context.Context, userID uuid.UUID) error
	DecrementMonitorCount(ctx context.Context, userID uuid.UUID) error
}