From d342efadbc8d31e526e49a58f8948de2a18f46d1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Pedro=20P=C3=A9rez?= <hola@pedroperez.dev>
Date: Thu, 9 Oct 2025 14:41:08 +0200
Subject: [PATCH] add models and validation

---
 internal/domains/sensors/domain.go | 74 ++++++++++++++++++++++++++++++
 internal/domains/sensors/models.go | 13 +++++-
 2 files changed, 86 insertions(+), 1 deletion(-)

diff --git a/internal/domains/sensors/domain.go b/internal/domains/sensors/domain.go
index 3b3fa2b..29e885c 100644
--- a/internal/domains/sensors/domain.go
+++ b/internal/domains/sensors/domain.go
@@ -1 +1,75 @@
 package sensors
+
+import (
+	"errors"
+	"time"
+)
+
+func (s *Sensor) Validate() error {
+	if s.SensorID == "" {
+		return ErrInvalidSensorIdentifier
+	}
+	if s.SensorType == "" {
+		return ErrInvalidSensorType
+	}
+	return nil
+}
+
+func (d *SensorData) Validate() error {
+	if d.SensorID == "" {
+		return ErrInvalidSensorIdentifier
+	}
+	if d.Value == nil {
+		return ErrMissingValue
+	}
+	if d.Timestamp.IsZero() {
+		d.Timestamp = time.Now()
+	}
+	return nil
+}
+
+func (d *SensorData) IsOutOfRangeAbove(sensor Sensor) bool {
+	return *d.Value > sensor.ThresholdAbove
+}
+
+func (d *SensorData) IsOutOfRangeBelow(sensor Sensor) bool {
+	return *d.Value < sensor.ThresholdBelow
+}
+
+func (r *SensorRequest) Validate() error {
+	if r.SensorID == "" {
+		return ErrInvalidSensorIdentifier
+	}
+	return nil
+}
+
+func (r *SensorDataRequest) Validate() error {
+	if r.SensorID == "" {
+		return ErrInvalidSensorIdentifier
+	}
+
+	if r.To == "" {
+		r.To = time.Now().Format(time.RFC3339)
+	} else {
+		if _, err := time.Parse(time.RFC3339, r.To); err != nil {
+			r.To = time.Now().Format(time.RFC3339)
+		}
+	}
+
+	if r.From == "" {
+		r.From = time.Now().AddDate(0, 0, -7).Format(time.RFC3339)
+	} else {
+		if _, err := time.Parse(time.RFC3339, r.From); err != nil {
+			r.From = time.Now().AddDate(0, 0, -7).Format(time.RFC3339)
+		}
+	}
+
+	return nil
+}
+
+var (
+	ErrInvalidSensorIdentifier = errors.New("sensor identifier is required")
+	ErrInvalidSensorType       = errors.New("sensor type is required")
+	ErrSensorNotFound          = errors.New("sensor not found")
+	ErrMissingValue            = errors.New("sensor value no provided")
+)
diff --git a/internal/domains/sensors/models.go b/internal/domains/sensors/models.go
index daabde3..f36d908 100644
--- a/internal/domains/sensors/models.go
+++ b/internal/domains/sensors/models.go
@@ -24,6 +24,17 @@ type Sensor struct {
 }
 
 type SensorData struct {
-	Value     float64   `json:"value"`
+	SensorID  string    `json:"sensor_id"`
+	Value     *float64  `json:"value"`
 	Timestamp time.Time `json:"timestamp"`
 }
+
+type SensorRequest struct {
+	SensorID string `json:"sensor_id"`
+}
+
+type SensorDataRequest struct {
+	SensorID string `json:"sensor_id"`
+	From     string `json:"from"`
+	To       string `json:"to"`
+}