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
	AlertEmail         string
}

type CreateMonitorRequest struct {
	Url                string `json:"url" validate:"required,url"`
	AlertEmail         string `json:"alert_email" validate:"omitempty,email"`
	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"`
}

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"`
	AlertEmail         string `json:"alert_mail"`
	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"`
}

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
	AlertEmail         string
	IntervalSec        int32
	TimeoutSec         int32
	LatencyThresholdMs *int32
	ExpectedStatus     *int32
	Enabled            bool
	CreatedAt          time.Time
	IsDown             bool
}

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
}