olympus

type AlarmLogger interface {
	ActiveAlarmsCount() (failures, emergencies, warnings int)
	GetReports() []api.AlarmReport
	// PushAlarms adds a list of AlarmEvents to this logger.
	PushAlarms([]*api.AlarmUpdate, string)
	ClearDomain(string, time.Time)
}

type AlreadyExistError string

type BatchingFilter func(outgoing chan<- []ZonedAlarmUpdate, incoming <-chan ZonedAlarmUpdate)

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

type ClimateDataDownsampler interface {
	// Adds a new list of value to the sampler for a given time.Time
	// t. If mx is non nil, an asynchronous update will be performed.
	Add(values TimedValues)

	// Returns the resulting time series
	TimeSeries() api.ClimateTimeSeries
}

type ClimateLogger interface {
	Host() string
	ZoneName() string
	ZoneIdentifier() string
	// PushTarget update current target for this logger.
	PushTarget(*api.ClimateTarget)
	// PushReports updates a list of reports to this logger.
	PushReports([]*api.ClimateReport)
	GetClimateTimeSeries(window string) api.ClimateTimeSeries
	GetClimateReport() *api.ZoneClimateReport
}

type ClosedOlympusServerError struct{}

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

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

type GracefulServer interface {
	Run() error
	Close() error
}

type GrpcSubscription[T any] struct {
	// contains filtered or unexported fields
}

type NoClimateRunningError string

type NoTrackingRunningError string

type NotificationFor struct {
	Subscription *webpush.Subscription
	Updates      []ZonedAlarmUpdate
}

type NotificationSender interface {
	Send(NotificationFor) error
}

type NotificationSubscription struct {
	Push     *webpush.Subscription
	Settings api.NotificationSettings
}

type Notifier interface {
	Incoming() chan<- ZonedAlarmUpdate
	Outgoing() <-chan NotificationFor

	RegisterPushSubscription(*webpush.Subscription) error
	UpdatePushSubscription(*api.NotificationSettingsUpdate) error

	Loop()
}

type Olympus struct {
	api.UnimplementedOlympusServer
	// contains filtered or unexported fields
}

type OlympusGRPCWrapper Olympus

type Options struct {
}

type PersistentMap[T any] struct {
	Map map[string]T
	// contains filtered or unexported fields
}

type RunCommand struct {
	Verbose []bool `long:"verbose" short:"v" description:"enables verbose logging, set multiple time to increase the level"`

	Address      string   `long:"http-listen" short:"l" description:"Address for the HTTP server" default:":3000"`
	RPC          int      `long:"rpc-listen" short:"r" description:"Port for the RPC Service" default:"3001"`
	AllowCORS    []string `long:"allow-cors" description:"allow cors from domain"`
	OtelEndpoint string   `long:"otel-exporter" description:"Open Telemetry exporter endpoint" env:"OLYMPUS_OTEL_ENDPOINT"`
}

type ServiceLogger interface {
	Log(ctx context.Context, identifier string, on, graceful bool)
	Logs() []api.ServiceLog
	OnServices() []string
	OffServices() []string
}

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

type TrackingLogger interface {
	TrackingInfo() *api.TrackingInfo
	PushDiskStatus(*api.DiskStatus)
}

type UnexpectedStreamServerError struct {
	Got, Expected string
}

type UpdateFilter func(outgoing chan<- ZonedAlarmUpdate, incoming <-chan ZonedAlarmUpdate)

type VersionCommand struct{}

type WebPushAction struct {
	Action string `json:"action,omitempty"`
	Title  string `json:"title,omitempty"`
}

type WebPushData struct {
	OnActionClick map[string]WebPushTargetAction `json:"onActionClick,omitempty"`
}

type WebPushNotification struct {
	Title   string          `json:"title,omitempty"` // Mandatory
	Body    string          `json:"body,omitempty"`  // Mandatory
	Actions []WebPushAction `json:"actions,omitempty"`
	Data    WebPushData     `json:"data,omitempty"`
	Icon    string          `json:"icon,omitempty"`    // Yes we would like something : https://web.dev/push-notifications-display-a-notification/#icon
	Image   string          `json:"image,omitempty"`   // Preferably not see https://web.dev/push-notifications-display-a-notification/#image
	Badge   string          `json:"badge,omitempty"`   // Yes we would like something : https://web.dev/push-notifications-display-a-notification/#badge
	Vibrate []int           `json:"vibrate,omitempty"` // Seems uneffective
	Sound   string          `json:"sound.omitempty"`   // Doesn't work
}

type WebPushTargetAction struct {
	Operation string `json:"operation,omitempty"`
	URL       string `json:"url,omitempty"`
}

type ZoneNotFoundError string

type ZonedAlarmUpdate struct {
	Zone   string
	Update *api.AlarmUpdate
}