graphicek/server/routes/sensor_values.go

package routes

import (
	"basic-sensor-receiver/app"
	"database/sql"
	"net/http"

	"github.com/gin-gonic/gin"
)

type postSensorValueBody struct {
	Value float64 `json:"value" binding:"required"`
}

type getSensorValuesQuery struct {
	From int64 `form:"from" binding:"required"`
	To   int64 `form:"to" binding:"required"`
}

type getLatestSensorValueQuery struct {
	To int64 `form:"to" binding:"required"`
}

func PostSensorValues(s *app.Server) gin.HandlerFunc {
	return func(c *gin.Context) {
		var newValue postSensorValueBody

		bindJSONBodyOrAbort(c, &newValue)

		sensorId := getIntParamOrAbort(c, "sensor")

		if _, err := s.Services.SensorValues.Push(sensorId, newValue.Value); err != nil {
			c.AbortWithError(400, err)
			return
		}

		c.JSON(http.StatusCreated, newValue)
	}
}

func GetSensorValues(s *app.Server) gin.HandlerFunc {
	return func(c *gin.Context) {
		var query getSensorValuesQuery

		sensorId := getIntParamOrAbort(c, "sensor")

		if err := c.ShouldBindQuery(&query); err != nil {
			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
			return
		}

		values, err := s.Services.SensorValues.GetList(sensorId, query.From, query.To)

		if err != nil {
			c.AbortWithError(500, err)
			return
		}
		c.JSON(http.StatusOK, values)
	}
}

func GetSensorLatestValue(s *app.Server) gin.HandlerFunc {
	return func(c *gin.Context) {
		var query getLatestSensorValueQuery

		sensorId := getIntParamOrAbort(c, "sensor")

		if err := c.ShouldBindQuery(&query); err != nil {
			c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()})
			return
		}

		value, err := s.Services.SensorValues.GetLatest(sensorId, query.To)

		if err != nil {
			if err == sql.ErrNoRows {
				c.AbortWithError(404, err)
				return
			}

			c.AbortWithError(500, err)
			return
		}

		c.JSON(http.StatusOK, value)
	}
}