95 lines
2.0 KiB
Go
95 lines
2.0 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"log"
|
|
"time"
|
|
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/pkg/broker"
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/pkg/domain"
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/pkg/openweather"
|
|
)
|
|
|
|
type Handler struct {
|
|
broker broker.Broker
|
|
key string
|
|
lat float64
|
|
lon float64
|
|
}
|
|
|
|
func NewHandler(broker broker.Broker, key string, lat float64, lon float64) *Handler {
|
|
return &Handler{
|
|
broker: broker,
|
|
key: key,
|
|
lat: lat,
|
|
lon: lon,
|
|
}
|
|
}
|
|
|
|
func (h *Handler) Handle(ctx context.Context) error {
|
|
log.Println("get forecast")
|
|
|
|
now := time.Now()
|
|
|
|
forecast, err := openweather.Forecast(ctx, h.key, h.lat, h.lon)
|
|
if err != nil {
|
|
return fmt.Errorf("error in get forecast: %w", err)
|
|
}
|
|
|
|
log.Println("get forecast successfully", forecast)
|
|
|
|
for _, list := range forecast.List {
|
|
weatherEvent := domain.WeatherEvent{
|
|
Source: domain.WeatherSourceOpenWeather,
|
|
ForecastDate: now,
|
|
TargetDate: time.Unix(int64(list.Dt), 0),
|
|
Condition: decideCondition(list.Weather),
|
|
Temperature: domain.Temperature{
|
|
Value: domain.Celsius(list.Main.Temp),
|
|
},
|
|
}
|
|
|
|
message, err := json.Marshal(&weatherEvent)
|
|
if err != nil {
|
|
log.Println("error in marshal weather event", err)
|
|
|
|
continue
|
|
}
|
|
|
|
err = h.broker.Publish(ctx, "SEVEN_SKIES_SUBJECT.OPENWEATHER", message)
|
|
if err != nil {
|
|
log.Println("error in publish weather event", err)
|
|
|
|
continue
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func decideCondition(weather []openweather.Weather) domain.WeatherCondition {
|
|
if len(weather) == 0 {
|
|
return domain.WeatherConditionUnknown
|
|
}
|
|
|
|
main := weather[0].Main
|
|
switch main {
|
|
case "Thunderstorm", "Drizzle", "Rain":
|
|
return domain.WeatherConditionRain
|
|
|
|
case "Snow":
|
|
return domain.WeatherConditionSnow
|
|
|
|
case "Mist", "Smoke", "Haze", "Dust", "Fog", "Sand", "Ash", "Squall", "Tornado", "Clouds":
|
|
return domain.WeatherConditionCloudy
|
|
|
|
case "Clear":
|
|
return domain.WeatherConditionClear
|
|
|
|
default:
|
|
return domain.WeatherConditionUnknown
|
|
}
|
|
}
|