package main

import (
	"automation/automation"
	"automation/config"
	"automation/home"
	"automation/integration/hue"
	"automation/integration/kasa"
	"automation/integration/ntfy"
	"automation/integration/wol"
	"automation/integration/zigbee"
	"automation/presence"
	"fmt"
	"log"
	"net/http"
	"os"

	"github.com/gorilla/mux"
	"github.com/joho/godotenv"

	paho "github.com/eclipse/paho.mqtt.golang"
)

func main() {
	_ = godotenv.Load()

	cfg := config.Get()

	notify := ntfy.New(cfg.Ntfy.Topic)
	hue := hue.New(cfg.Hue.IP, cfg.Hue.Token)

	home := home.New(cfg.Google.Username, cfg.Google.Credentials, cfg.Google.OAuthUrl)
	r := mux.NewRouter()
	r.HandleFunc("/assistant", home.Service.FullfillmentHandler)

	for name, info := range cfg.Computer {
		home.AddDevice(wol.NewComputer(info.MACAddress, name, info.Url))
	}

	for name, ip := range cfg.Kasa.Outlets {
		home.AddDevice(kasa.NewOutlet(name, ip))
	}

	opts := paho.NewClientOptions().AddBroker(fmt.Sprintf("%s:%d", cfg.MQTT.Host, cfg.MQTT.Port))
	opts.SetClientID(cfg.MQTT.ClientID)
	opts.SetUsername(cfg.MQTT.Username)
	opts.SetPassword(cfg.MQTT.Password)
	opts.SetOrderMatters(false)

	client := paho.NewClient(opts)
	if token := client.Connect(); token.Wait() && token.Error() != nil {
		panic(token.Error())
	}
	defer client.Disconnect(250)

	zigbee.DevicesHandler(client, cfg.Zigbee.MQTTPrefix, home)

	p := presence.New(client, hue, notify, home)
	defer p.Delete(client)

	opts.SetClientID(fmt.Sprintf("%s-2", cfg.MQTT.ClientID))
	automationClient := paho.NewClient(opts)
	if token := automationClient.Connect(); token.Wait() && token.Error() != nil {
		panic(token.Error())
	}
	defer automationClient.Disconnect(250)

	automation.RegisterAutomations(automationClient, cfg.Zigbee.MQTTPrefix, hue, notify, home)

	addr := ":8090"
	srv := http.Server{
		Addr:    addr,
		Handler: r,
	}

	log.Printf("Starting server on %s (PID: %d)\n", addr, os.Getpid())
	srv.ListenAndServe()
}