watch

type Actor struct {
	ID           string
	Email        string
	Scope        Scope
	SharedEditor bool
	AccountID    string
	Tier         string
	Phone        string
}

type AuditEvent struct {
	ID         string    `json:"id"`
	Scope      Scope     `json:"scope"`
	Actor      string    `json:"actor"`
	Action     string    `json:"action"`
	ResourceID string    `json:"resourceId"`
	At         time.Time `json:"at"`
}

type Claim struct {
	ClaimID    string     `json:"claimId"`
	RunID      string     `json:"runId"`
	Fence      int64      `json:"fence"`
	LeaseUntil time.Time  `json:"leaseUntil"`
	Definition Definition `json:"definition"`
}

type CloudRetainedDocument struct {
	Collection  string
	ID          string
	Environment string
	WatchID     string
	Owner       string
	Payload     json.RawMessage
}

type CloudRetainedInventory struct {
	Namespace   string
	Project     string
	Collections []string
	Documents   []CloudRetainedDocument
}

type CloudRetainedInventoryLimits struct{ MaxDocuments, MaxBytes int }

type CloudRetainedSource struct {
	Collection, RecordID    string
	Owner                   string
	Scope                   Scope
	WatchID, RunID, EventID string
	DeliveryID              string
	Active                  bool
	Definition              *Definition
	Run                     *Run
	Event                   *Event
	Observation             *Observation
}

type CloudRetainedWrite struct {
	Before *CloudRetainedDocument
	After  *CloudRetainedDocument
}

type CloudRetainedWriteAdmission func(context.Context, dal.ReadwriteTransaction, string, string, []CloudRetainedWrite) (CloudRetainedWritePlan, error)

type CloudRetainedWritePlan struct {
	Persist    func() error
	WriteRows  int
	WriteBytes int
}

type Completion struct {
	SourceRevision    string `json:"sourceRevision,omitempty"`
	SourceFingerprint string `json:"sourceFingerprint,omitempty"`
	ClaimID           string `json:"claimId"`
	RunID             string `json:"runId"`
	Fence             int64  `json:"fence"`
	ExecutionStatus   string `json:"executionStatus"`
	Outcome           string `json:"outcome"`
	Severity          string `json:"severity,omitempty"`
	DurationMS        int64  `json:"durationMs"`
	CheckRunRef       string `json:"checkRunRef,omitempty"`
	FailureCode       string `json:"failureCode,omitempty"`
}

type Config struct {
	MaxWatchesPerUser   int
	MinIntervalSeconds  int
	TelegramDailyLimit  int
	TelegramMinuteLimit int
	IsPaidAccount       func(string) bool
	EmailDailyLimit     int
	SMSDailyLimit       int
	EmailMinuteLimit    int
	SMSMinuteLimit      int
	Namespace           string
	Now                 func() time.Time
	LeaseDuration       time.Duration
	RunnerTTL           time.Duration
	ExecutionTimeout    time.Duration
	MaxAttempts         int
	HistoryLimit        int
}

type Definition struct {
	// SourceRevision is a canonical cloud admission pin, not a client grant.
	SourceRevision    string `json:"sourceRevision,omitempty"`
	SourceFingerprint string `json:"sourceFingerprint,omitempty"`
	Scope
	ID                 string                          `json:"id"`
	Version            int64                           `json:"version"`
	Title              string                          `json:"title"`
	Owner              string                          `json:"owner"`
	Visibility         string                          `json:"visibility"`
	CheckID            string                          `json:"checkId"`
	CheckVersion       string                          `json:"checkVersion,omitempty"`
	Inputs             map[string]detective.InputValue `json:"inputs,omitempty"`
	Schedule           Schedule                        `json:"schedule"`
	Trigger            string                          `json:"trigger"`            // becomes_true, becomes_false, changes
	InitialObservation string                          `json:"initialObservation"` // notify, baseline
	Mode               string                          `json:"mode"`               // one_shot, continuous
	Lifecycle          string                          `json:"lifecycle"`          // enabled, paused, completed, deleted
	Enabled            bool                            `json:"enabled"`
	Requirements       []string                        `json:"requirements,omitempty"`
	NotificationPolicy NotificationPolicy              `json:"notificationPolicy"`
	CreatedAt          time.Time                       `json:"createdAt"`
	UpdatedAt          time.Time                       `json:"updatedAt"`
}

type DefinitionRepository interface {
	ListDefinitions(context.Context, Actor) ([]Definition, error)
	GetDefinition(context.Context, Actor, string) (Definition, error)
	PutDefinition(context.Context, Actor, Definition, string, int64) (Definition, error)
}

type Delivery struct {
	TelegramLinkGeneration int64  `json:"telegramLinkGeneration,omitempty"`
	TelegramBotID          string `json:"telegramBotId,omitempty"`
	TelegramChatID         string `json:"telegramChatId,omitempty"`
	AccountID              string `json:"accountId,omitempty"`
	Phone                  string `json:"phone,omitempty"`
	QuotaReserved          bool   `json:"quotaReserved"`
	Notification
	Channel     string    `json:"channel"`
	Email       string    `json:"email,omitempty"`
	State       string    `json:"state"`
	Attempts    int       `json:"attempts"`
	Fence       int64     `json:"fence"`
	LeaseUntil  time.Time `json:"leaseUntil,omitempty"`
	RetryAt     time.Time `json:"retryAt,omitempty"`
	FailureCode string    `json:"failureCode,omitempty"`
}

type Event struct {
	Scope
	ID                string                          `json:"id"`
	WatchID           string                          `json:"watchId"`
	RunID             string                          `json:"runId"`
	DefinitionVersion int64                           `json:"definitionVersion"`
	Title             string                          `json:"title"`
	Kind              string                          `json:"kind"`     // trigger or recovery
	Previous          string                          `json:"previous"` // true, false, never
	Outcome           string                          `json:"outcome"`  // pass or fail
	OccurredAt        time.Time                       `json:"occurredAt"`
	CheckID           string                          `json:"checkId"`
	CheckVersion      string                          `json:"checkVersion"`
	SourceFingerprint string                          `json:"sourceFingerprint"`
	CheckRunRef       string                          `json:"checkRunRef,omitempty"`
	Inputs            map[string]detective.InputValue `json:"inputs,omitempty"`
	Owner             string                          `json:"owner"`
	Visibility        string                          `json:"visibility"`
}

type FirestoreOptions struct {
	ProjectKey *record.Key
	// StorageRoot is a separately protected server-only project container. It
	// must not be a descendant of a project subtree readable by Space members.
	StorageRoot *record.Key
	AccountRoot *record.Key
	// AccountNamespace is a server-fixed deployment quota namespace. Empty uses Config.Namespace.
	AccountNamespace string
	ProjectID        string
	Config           Config
	Authorize        func(context.Context, dal.ReadTransaction) error
	AdmitDefinition  func(context.Context, dal.ReadTransaction, Definition, string) (string, error)
	AdmitRunner      func(context.Context, dal.ReadTransaction, Definition, RunnerIdentity) (bool, error)
	AdmitRecipient   func(context.Context, dal.ReadTransaction, Definition, string) (RecipientAuthority, error)
	// AdmitRetainedWrite prepares reference admission after the complete buffered
	// command, before any physical write. Its returned closure may only write and
	// must commit the shared project fence in this same transaction. Installing
	// this hook does not establish that other project writers participate.
	AdmitRetainedWrite CloudRetainedWriteAdmission
	// DefinitionChanged stages exactly one <=1KiB deterministic metadata event.
	// It runs after every read, must not read/publish/network, and shares commit.
	DefinitionChanged func(context.Context, dal.ReadwriteTransaction, Definition) error
	// WorkReady stages one deterministic metadata wakeup for new pending work.
	// It shares DefinitionChanged's no-read/no-network/<=1KiB contract.
	WorkReady func(context.Context, dal.ReadwriteTransaction, WorkEvent) error
}

type Notification struct {
	EventID string `json:"eventId,omitempty"`
	Scope
	ID        string    `json:"id"`
	WatchID   string    `json:"watchId"`
	RunID     string    `json:"runId"`
	UserID    string    `json:"userId"`
	Title     string    `json:"title"`
	Event     string    `json:"event"`
	Link      string    `json:"link"`
	CreatedAt time.Time `json:"createdAt"`
	ReadAt    time.Time `json:"readAt,omitempty"`
}

type NotificationPolicy struct {
	CooldownSeconds int  `json:"cooldownSeconds,omitempty"`
	Recovery        bool `json:"recovery"`
}

type Observation struct {
	LastEventID       string    `json:"lastEventId,omitempty"`
	SourceFingerprint string    `json:"sourceFingerprint,omitempty"`
	WatchID           string    `json:"watchId"`
	Value             string    `json:"value"` // true, false, unknown, never
	LastKnown         string    `json:"lastKnown"`
	LastRunID         string    `json:"lastRunId,omitempty"`
	LastObservedAt    time.Time `json:"lastObservedAt,omitempty"`
	LastNotifiedAt    time.Time `json:"lastNotifiedAt,omitempty"`
	NextEvaluation    time.Time `json:"nextEvaluation"`
	Availability      string    `json:"availability"`
}

type RecipientAuthority struct {
	AccountID string
	Email     string
	Phone     string
	Paid      bool
}

type Run struct {
	EventID string `json:"eventId,omitempty"`
	Scope
	ID                string    `json:"id"`
	WatchID           string    `json:"watchId"`
	DefinitionVersion int64     `json:"definitionVersion"`
	DueAt             time.Time `json:"dueAt"`
	State             string    `json:"state"` // due, running, completed, retry, failed, cancelled
	RunnerID          string    `json:"runnerId,omitempty"`
	Fence             int64     `json:"fence"`
	Attempts          int       `json:"attempts"`
	Deadline          time.Time `json:"deadline,omitempty"`
	CompletionHash    string    `json:"completionHash,omitempty"`
	LeaseUntil        time.Time `json:"leaseUntil,omitempty"`
	RetryAt           time.Time `json:"retryAt,omitempty"`
	ExecutionStatus   string    `json:"executionStatus,omitempty"`
	Outcome           string    `json:"outcome,omitempty"`
	Severity          string    `json:"severity,omitempty"`
	DurationMS        int64     `json:"durationMs,omitempty"`
	CheckRunRef       string    `json:"checkRunRef,omitempty"`
	FailureCode       string    `json:"failureCode,omitempty"`
	FinishedAt        time.Time `json:"finishedAt,omitempty"`
}

type Runner struct {
	TelegramBotID       string `json:"telegramBotId,omitempty"`
	TelegramBotUsername string `json:"telegramBotUsername,omitempty"`
	Scope
	ID           string    `json:"id"`
	Capabilities []string  `json:"capabilities"`
	LastSeen     time.Time `json:"lastSeen"`
}

type RunnerIdentity struct {
	TelegramBotID       string
	TelegramBotUsername string
	ID                  string
	Scope               Scope
	Capabilities        []string
}

type Schedule struct {
	IntervalSeconds int `json:"intervalSeconds"`
}

type Scope struct {
	Namespace   string `json:"namespace"`
	Project     string `json:"project"`
	Environment string `json:"environment"`
}

type Status struct {
	Coordinator  string        `json:"coordinator"`
	Runners      []Runner      `json:"runners"`
	Observations []Observation `json:"observations"`
}

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

type Subscription struct {
	TelegramBotID string   `json:"telegramBotId,omitempty"`
	AccountID     string   `json:"accountId,omitempty"`
	Tier          string   `json:"tier,omitempty"`
	Phone         string   `json:"phone,omitempty"`
	WatchID       string   `json:"watchId"`
	UserID        string   `json:"userId"`
	Channels      []string `json:"channels"`
	NotifyOn      []string `json:"notifyOn,omitempty"`
	Email         string   `json:"email,omitempty"`
	Unsubscribed  bool     `json:"unsubscribed,omitempty"`
}

type TelegramPollLease struct {
	NextAttemptAt time.Time `json:"nextAttemptAt,omitempty"`
	BotID         string    `json:"botId"`
	Fence         int64     `json:"fence"`
	Offset        int64     `json:"offset"`
	LeaseUntil    time.Time `json:"leaseUntil"`
}

type TelegramProviderStatus struct {
	ReconnectRequired bool   `json:"reconnectRequired,omitempty"`
	ConnectionError   string `json:"connectionError,omitempty"`
	Connected         bool   `json:"connected"`
	BotID             string `json:"botId,omitempty"`
	BotUsername       string `json:"botUsername,omitempty"`
}

type WorkEvent struct {
	Scope
	ID      string
	Kind    string
	WatchID string
	RunID   string
}