watchdaemon

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

type Client struct {
	Endpoint, Token string
	HTTP            *http.Client
}

type Config struct {
	Namespace      string            `json:"namespace"`
	Listen         string            `json:"listen,omitempty"`
	TLSCertFile    string            `json:"tlsCertFile,omitempty"`
	TLSKeyFile     string            `json:"tlsKeyFile,omitempty"`
	Credentials    []Credential      `json:"credentials"`
	AllowedOrigins []string          `json:"allowedOrigins,omitempty"`
	PublicUIURL    string            `json:"publicUIURL,omitempty"`
	ProjectUIURLs  map[string]string `json:"projectUIURLs,omitempty"`
	Limits         Limits            `json:"limits,omitempty"`
	Storage        struct {
		DALGOConnectionEnv string `json:"dalgoConnectionEnv"`
	} `json:"storage"`
	Runner struct {
		TokenEnv            string             `json:"tokenEnv"`
		CoordinatorEndpoint string             `json:"coordinatorEndpoint"`
		ProjectDir          string             `json:"projectDir"`
		Environment         string             `json:"environment"`
		Principal           string             `json:"principal"`
		EvidenceDir         string             `json:"evidenceDir"`
		AllowOpaqueSQL      bool               `json:"allowOpaqueSQL,omitempty"`
		Telegram            *TelegramBotConfig `json:"telegram,omitempty"`
	} `json:"runner"`
	Notifications struct {
		EmailSink string      `json:"emailSink,omitempty"`
		SMTP      *SMTPConfig `json:"smtp,omitempty"`
		SMSSink   string      `json:"smsSink,omitempty"`
		Twilio    bool        `json:"twilio,omitempty"`
	} `json:"notifications"`
}

type CoordinatorStore interface {
	Health(context.Context) error
	ListDefinitions(context.Context, watch.Actor) ([]watch.Definition, error)
	GetDefinition(context.Context, watch.Actor, string) (watch.Definition, error)
	PutDefinition(context.Context, watch.Actor, watch.Definition, string, int64) (watch.Definition, error)
	DeleteDefinition(context.Context, watch.Actor, string, string, int64) error
	SetLifecycle(context.Context, watch.Actor, string, string, string, int64) (watch.Definition, error)
	ResetBaseline(context.Context, watch.Actor, string, string, int64) (watch.Definition, error)
	Subscribe(context.Context, watch.Actor, watch.Subscription) error
	GetSubscription(context.Context, watch.Actor, string) (watch.Subscription, error)
	ListRuns(context.Context, watch.Actor, string) ([]watch.Run, error)
	ListDeliveries(context.Context, watch.Actor, string) ([]watch.Delivery, error)
	RetryNotification(context.Context, watch.Actor, string) error
	RegisterRunner(context.Context, watch.RunnerIdentity) error
	ClaimDue(context.Context, watch.RunnerIdentity) (*watch.Claim, error)
	Heartbeat(context.Context, watch.RunnerIdentity, string, int64) error
	FinishRun(context.Context, watch.RunnerIdentity, watch.Completion) (watch.Run, error)
	Inbox(context.Context, watch.Actor) ([]watch.Notification, error)
	MarkRead(context.Context, watch.Actor, string) error
	Status(context.Context, watch.Actor) (watch.Status, error)
	Reconcile(context.Context) error
	ClaimNotifications(context.Context) (*watch.Delivery, error)
	FinishNotification(context.Context, string, int64, string) error
}

type Credential struct {
	TelegramBotID string   `json:"telegramBotId,omitempty"`
	TokenEnv      string   `json:"tokenEnv"`
	Kind          string   `json:"kind"` // user or runner
	ID            string   `json:"id"`
	AccountID     string   `json:"accountId,omitempty"`
	Namespace     string   `json:"namespace"`
	Project       string   `json:"project"`
	Environment   string   `json:"environment"`
	SharedEditor  bool     `json:"sharedEditor,omitempty"`
	Capabilities  []string `json:"capabilities,omitempty"`
	Email         string   `json:"email,omitempty"`
	Tier          string   `json:"tier,omitempty"`
	Phone         string   `json:"phone,omitempty"`
}

type EmailMessage struct {
	ID      string `json:"id"`
	To      string `json:"to"`
	Subject string `json:"subject"`
	Body    string `json:"body"`
}

type EmailSender interface {
	Send(context.Context, EmailMessage) error
}

type Executor interface {
	Execute(context.Context, watch.Claim) (watch.Completion, error)
}

type ExecutorFunc func(context.Context, watch.Claim) (watch.Completion, error)

type FileEmailSink struct {
	Path string
	// contains filtered or unexported fields
}

type FileSMSSink struct{ Sink *FileEmailSink }

type Limits struct {
	EmailPerDay        int `json:"emailPerDay,omitempty"`
	EmailPerMinute     int `json:"emailPerMinute,omitempty"`
	SMSPerDay          int `json:"smsPerDay,omitempty"`
	SMSPerMinute       int `json:"smsPerMinute,omitempty"`
	TelegramPerDay     int `json:"telegramPerDay,omitempty"`
	TelegramPerMinute  int `json:"telegramPerMinute,omitempty"`
	WatchesPerUser     int `json:"watchesPerUser,omitempty"`
	MinIntervalSeconds int `json:"minIntervalSeconds,omitempty"`
}

type Runner struct {
	Telegram *TelegramBotConfig

	Client                      Client
	Executor                    Executor
	PollInterval, RenewInterval time.Duration
	RegistrationInterval        time.Duration
	// contains filtered or unexported fields
}

type SMSMessage struct{ ID, To, Body string }

type SMSSender interface {
	Send(context.Context, SMSMessage) error
}

type SMTPConfig struct {
	Address     string `json:"address"`
	From        string `json:"from"`
	UsernameEnv string `json:"usernameEnv,omitempty"`
	PasswordEnv string `json:"passwordEnv,omitempty"`
	// AllowLoopbackPlaintext is only for a local development SMTP receiver.
	AllowLoopbackPlaintext bool `json:"allowLoopbackPlaintext,omitempty"`
}

type SMTPSender struct{ Config SMTPConfig }

type Server struct {
	Store          CoordinatorStore
	Auth           *Authenticator
	AllowedOrigins []string
	Email          EmailSender
	SMS            SMSSender
	PublicUIURL    string
	ProjectUIURLs  map[string]string
	Limits         Limits
}

type TelegramBotConfig struct {
	BotID     string `json:"botID"`
	SecretEnv string `json:"secretEnv,omitempty"`
	TokenEnv  string `json:"tokenEnv,omitempty"`
}

type TwilioSMSSender struct {
	Credentials twiliosms.Credentials
	Transport   http.RoundTripper
}