Compare commits
5 Commits
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),
|
||||
},
|
||||
}
|
||||
|
||||
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,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -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