Compare commits
	
		
			5 Commits
		
	
	
		
			v0.15.4
			...
			f0bda0a3bd
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| f0bda0a3bd | |||
| 1ee231fe30 | |||
| 3279c6fd38 | |||
| 268bc7d8a2 | |||
| 2f83edc426 | 
							
								
								
									
										1
									
								
								TODO.md
									
									
									
									
									
								
							
							
						
						
									
										1
									
								
								TODO.md
									
									
									
									
									
								
							@@ -2,6 +2,7 @@
 | 
			
		||||
- [x] Redis recorder panic
 | 
			
		||||
 | 
			
		||||
# TODO
 | 
			
		||||
- [ ] Make lightning distance unit configurable (kph|mph)
 | 
			
		||||
- [ ] Set TTL on redis key
 | 
			
		||||
- [ ] Add json schema to CI and README
 | 
			
		||||
- [ ] Update README
 | 
			
		||||
 
 | 
			
		||||
@@ -15,13 +15,13 @@ type: application
 | 
			
		||||
# This is the chart version. This version number should be incremented each time you make changes
 | 
			
		||||
# to the chart and its templates, including the app version.
 | 
			
		||||
# Versions are expected to follow Semantic Versioning (https://semver.org/)
 | 
			
		||||
version: 0.1.8
 | 
			
		||||
version: 0.1.10
 | 
			
		||||
 | 
			
		||||
# This is the version number of the application being deployed. This version number should be
 | 
			
		||||
# incremented each time you make changes to the application. Versions are not expected to
 | 
			
		||||
# follow Semantic Versioning. They should reflect the version the application is using.
 | 
			
		||||
# It is recommended to use it with quotes.
 | 
			
		||||
appVersion: "v0.14.0"
 | 
			
		||||
appVersion: "v0.15.6"
 | 
			
		||||
 | 
			
		||||
dependencies:
 | 
			
		||||
  - name: hull
 | 
			
		||||
 
 | 
			
		||||
@@ -52,10 +52,8 @@ var mockUpdate = &weather.WeatherUpdate{
 | 
			
		||||
	TempHumiditySensors: []*weather.TempHumiditySensor{
 | 
			
		||||
		{Name: "sensor1", TempF: ptr.To(99.999), Humidity: nil},
 | 
			
		||||
	},
 | 
			
		||||
	LightningData: &weather.LightningData{
 | 
			
		||||
		LightningDay:      ptr.To(1),
 | 
			
		||||
		LightningDistance: ptr.To(20),
 | 
			
		||||
	},
 | 
			
		||||
	LightningDay:      ptr.To(1),
 | 
			
		||||
	LightningDistance: ptr.To(20),
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func TestUpdateToPbUpdate(t *testing.T) {
 | 
			
		||||
 
 | 
			
		||||
@@ -143,11 +143,9 @@ func MapAwnUpdate(awnUpdate *AmbientWeatherUpdate) *weather.WeatherUpdate {
 | 
			
		||||
			{Name: THSensor + "7", TempF: awnUpdate.Temp7F, Humidity: awnUpdate.Humidity7},
 | 
			
		||||
			{Name: THSensor + "8", TempF: awnUpdate.Temp8F, Humidity: awnUpdate.Humidity8},
 | 
			
		||||
		},
 | 
			
		||||
		LightningData: &weather.LightningData{
 | 
			
		||||
			LightningDay:      awnUpdate.LightningDay,
 | 
			
		||||
			LightningDistance: awnUpdate.LightningDistance,
 | 
			
		||||
			LightningTime:     awnUpdate.LightningTime,
 | 
			
		||||
		},
 | 
			
		||||
		LightningDay:      awnUpdate.LightningDay,
 | 
			
		||||
		LightningDistance: awnUpdate.LightningDistance,
 | 
			
		||||
		LightningTime:     awnUpdate.LightningTime,
 | 
			
		||||
	}
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -3,6 +3,7 @@ package weather
 | 
			
		||||
import (
 | 
			
		||||
	"context"
 | 
			
		||||
	"errors"
 | 
			
		||||
	"slices"
 | 
			
		||||
 | 
			
		||||
	"github.com/rs/zerolog"
 | 
			
		||||
	"go.opentelemetry.io/otel/attribute"
 | 
			
		||||
@@ -64,20 +65,10 @@ func (r *MetricRecorder) Record(opts *RecordOpts) {
 | 
			
		||||
func (o *RecordOpts) keep() bool {
 | 
			
		||||
	// If keep fields are given, only check keep fields
 | 
			
		||||
	if len(o.Station.KeepMetrics) > 0 {
 | 
			
		||||
		for _, f := range o.Station.KeepMetrics {
 | 
			
		||||
			if f == o.Field {
 | 
			
		||||
				return true
 | 
			
		||||
			}
 | 
			
		||||
		}
 | 
			
		||||
		return false
 | 
			
		||||
		return slices.Contains(o.Station.KeepMetrics, o.Field)
 | 
			
		||||
	}
 | 
			
		||||
 | 
			
		||||
	for _, f := range o.Station.DropMetrics {
 | 
			
		||||
		if f == o.Field {
 | 
			
		||||
			return false
 | 
			
		||||
		}
 | 
			
		||||
	}
 | 
			
		||||
	return true
 | 
			
		||||
	return !slices.Contains(o.Station.DropMetrics, o.Field)
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
func (r *MetricRecorder) recordInt(
 | 
			
		||||
 
 | 
			
		||||
@@ -9,56 +9,52 @@ import (
 | 
			
		||||
// Stable intermediate struct containing superset of fields
 | 
			
		||||
// between AWN and Wunderground style updates from Ambient devices
 | 
			
		||||
type WeatherUpdate struct {
 | 
			
		||||
	DateUTC         *time.Time
 | 
			
		||||
	StationConfig   *config.WeatherStation
 | 
			
		||||
	StationID       *string
 | 
			
		||||
	StationType     *string
 | 
			
		||||
	TempOutdoorF    *float64
 | 
			
		||||
	TempIndoorF     *float64
 | 
			
		||||
	HumidityOudoor  *int
 | 
			
		||||
	HumidityIndoor  *int
 | 
			
		||||
	WindSpeedMPH    *float64
 | 
			
		||||
	WindGustMPH     *float64
 | 
			
		||||
	MaxDailyGust    *float64
 | 
			
		||||
	WindDir         *int
 | 
			
		||||
	WindDirAvg10m   *int
 | 
			
		||||
	UV              *int
 | 
			
		||||
	SolarRadiation  *float64
 | 
			
		||||
	HourlyRainIn    *float64
 | 
			
		||||
	EventRainIn     *float64
 | 
			
		||||
	DailyRainIn     *float64
 | 
			
		||||
	WeeklyRainIn    *float64
 | 
			
		||||
	MonthlyRainIn   *float64
 | 
			
		||||
	YearlyRainIn    *float64
 | 
			
		||||
	TotalRainIn     *float64
 | 
			
		||||
	Batteries       []BatteryStatus
 | 
			
		||||
	BaromRelativeIn *float64
 | 
			
		||||
	BaromAbsoluteIn *float64
 | 
			
		||||
	DateUTC         *time.Time             `json:"dateUTC,omitempty"`
 | 
			
		||||
	StationConfig   *config.WeatherStation `json:"stationConfig,omitempty"`
 | 
			
		||||
	StationID       *string                `json:"stationID,omitempty"`
 | 
			
		||||
	StationType     *string                `json:"stationType,omitempty"`
 | 
			
		||||
	TempOutdoorF    *float64               `json:"tempOutdoorF,omitempty"`
 | 
			
		||||
	TempIndoorF     *float64               `json:"tempIndoorF,omitempty"`
 | 
			
		||||
	HumidityOudoor  *int                   `json:"humidityOudoor,omitempty"`
 | 
			
		||||
	HumidityIndoor  *int                   `json:"humidityIndoor,omitempty"`
 | 
			
		||||
	WindSpeedMPH    *float64               `json:"windSpeedMPH,omitempty"`
 | 
			
		||||
	WindGustMPH     *float64               `json:"windGustMPH,omitempty"`
 | 
			
		||||
	MaxDailyGust    *float64               `json:"maxDailyGust,omitempty"`
 | 
			
		||||
	WindDir         *int                   `json:"windDir,omitempty"`
 | 
			
		||||
	WindDirAvg10m   *int                   `json:"windDirAvg10M,omitempty"`
 | 
			
		||||
	UV              *int                   `json:"uv,omitempty"`
 | 
			
		||||
	SolarRadiation  *float64               `json:"solarRadiation,omitempty"`
 | 
			
		||||
	HourlyRainIn    *float64               `json:"hourlyRainIn,omitempty"`
 | 
			
		||||
	EventRainIn     *float64               `json:"eventRainIn,omitempty"`
 | 
			
		||||
	DailyRainIn     *float64               `json:"dailyRainIn,omitempty"`
 | 
			
		||||
	WeeklyRainIn    *float64               `json:"weeklyRainIn,omitempty"`
 | 
			
		||||
	MonthlyRainIn   *float64               `json:"monthlyRainIn,omitempty"`
 | 
			
		||||
	YearlyRainIn    *float64               `json:"yearlyRainIn,omitempty"`
 | 
			
		||||
	TotalRainIn     *float64               `json:"totalRainIn,omitempty"`
 | 
			
		||||
	Batteries       []BatteryStatus        `json:"batteries,omitempty"`
 | 
			
		||||
	BaromRelativeIn *float64               `json:"baromRelativeIn,omitempty"`
 | 
			
		||||
	BaromAbsoluteIn *float64               `json:"baromAbsoluteIn,omitempty"`
 | 
			
		||||
	// These fields may be calculated
 | 
			
		||||
	// if not otherwise set
 | 
			
		||||
	DewPointF  *float64
 | 
			
		||||
	WindChillF *float64
 | 
			
		||||
	DewPointF  *float64 `json:"dewPointF,omitempty"`
 | 
			
		||||
	WindChillF *float64 `json:"windChillF,omitempty"`
 | 
			
		||||
	// Extra Temp+Humidity Sensors
 | 
			
		||||
	TempHumiditySensors []*TempHumiditySensor
 | 
			
		||||
	TempHumiditySensors []*TempHumiditySensor `json:"tempHumiditySensors,omitempty"`
 | 
			
		||||
	// Lightning Data
 | 
			
		||||
	*LightningData
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
type LightningData struct {
 | 
			
		||||
	LightningDay      *int // Count of detections
 | 
			
		||||
	LightningDistance *int // Last detection distance [kilometers]
 | 
			
		||||
	LightningTime     *int // Last detection time
 | 
			
		||||
	LightningDay      *int `json:"lightningDay,omitempty"`      // Count of detections
 | 
			
		||||
	LightningDistance *int `json:"lightningDistance,omitempty"` // Last detection distance [kilometers]
 | 
			
		||||
	LightningTime     *int `json:"lightningTime,omitempty"`     // Last detection time
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
type TempHumiditySensor struct {
 | 
			
		||||
	Name     string
 | 
			
		||||
	TempF    *float64
 | 
			
		||||
	Humidity *int
 | 
			
		||||
	Name     string   `json:"name,omitempty"`
 | 
			
		||||
	TempF    *float64 `json:"tempF,omitempty"`
 | 
			
		||||
	Humidity *int     `json:"humidity,omitempty"`
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
type BatteryStatus struct {
 | 
			
		||||
	Component string
 | 
			
		||||
	Status    *int
 | 
			
		||||
	Component string `json:"component,omitempty"`
 | 
			
		||||
	Status    *int   `json:"status,omitempty"`
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
// CHORE: Maintain this, used to check against
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user