package services

import (
	"log"

	"github.com/dustinpianalto/weather"
	"github.com/dustinpianalto/weather/internal/mqtt"
	"github.com/dustinpianalto/weather/internal/postgres"
)

var EventService weather.AmbientService

func InitServices() {
	EventService = eventService{
		postgesService: postgres.EventService,
		mqttService:    mqtt.AmbientService,
	}
	log.Println("Services Initialized")
}

type eventService struct {
	postgesService weather.AmbientService
	mqttService    weather.AmbientService
}

func (e eventService) Event(i uint64) (*weather.AmbientEntry, error) {
	return e.postgesService.Event(i)
}

func (e eventService) AddEvent(event *weather.AmbientEntry) (*weather.AmbientEntry, error) {
	event, err := e.postgesService.AddEvent(event)
	if err != nil {
		log.Println(err)
	}
	event, err = e.mqttService.AddEvent(event)
	if err != nil {
		log.Println(err)
	}
	return event, nil
}

func (e eventService) UpdateEvent(event *weather.AmbientEntry) error {
	return e.postgesService.UpdateEvent(event)
}

func (e eventService) DeleteEvent(event *weather.AmbientEntry) error {
	return e.postgesService.UpdateEvent(event)
}