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
	}
}