monitor

type MonitorContext struct {
	sync.Mutex

	OzoneCh chan OzoneTask // OzoneCh is a channel that receives an OzoneTask to start or stop the ozone generator.

	OzoneRunning bool

	NotifyCh chan NotificationTask // Channel to track notification tasks

	TempMonitorCh     chan TemperatureTask // Channel to track temperature monitoring requests
	TargetTemperature float64
	WaterTemperature  float64
	RoomTemperature   float64
	// contains filtered or unexported fields
}

type MonitorStore interface {
	SaveTemperature(ctx context.Context, arg database.SaveTemperatureParams) (database.Temperature, error)
	GetLatestOzoneEntry(ctx context.Context) (database.Ozone, error)
	StartOzoneGenerator(ctx context.Context, arg database.StartOzoneGeneratorParams) (database.Ozone, error)
	StopOzoneGenerator(ctx context.Context, id uuid.UUID) (database.Ozone, error)
	UpdateOzoneEntryStatus(ctx context.Context, args database.UpdateOzoneEntryStatusParams) (database.Ozone, error)
	GetLatestLeakDetected(ctx context.Context) (database.Leak, error)
	CreateLeakDetected(ctx context.Context, detectedAt time.Time) (database.Leak, error)
	ClearDetectedLeak(ctx context.Context, id uuid.UUID) (database.Leak, error)
}

type NotificationTask struct {
	// Message to send to the consumer.
	Message string
}

type OzoneAction int

type OzoneTask struct {
	Action OzoneAction

	// Duration to run the ozone generator in minutes.
	Duration int
}

type TemperatureTask struct {
	TargetTemperature float64
}