69 lines
1.1 KiB
Go
69 lines
1.1 KiB
Go
package main
|
|
|
|
import (
|
|
"automation/integration/hue"
|
|
"automation/integration/mqtt"
|
|
"automation/integration/ntfy"
|
|
"automation/device"
|
|
"automation/presence"
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
"os"
|
|
|
|
"github.com/gorilla/mux"
|
|
"github.com/joho/godotenv"
|
|
)
|
|
|
|
func main() {
|
|
_ = godotenv.Load()
|
|
|
|
// MQTT
|
|
m := mqtt.Connect()
|
|
defer m.Disconnect()
|
|
|
|
// Hue
|
|
h := hue.Connect()
|
|
|
|
// Kasa
|
|
// k := kasa.New("10.0.0.32")
|
|
|
|
// ntfy.sh
|
|
n := ntfy.Connect()
|
|
|
|
// Presence
|
|
p := presence.New()
|
|
m.AddHandler("automation/presence/+", p.PresenceHandler)
|
|
|
|
// Smart home
|
|
service := smarthome.NewService(&m)
|
|
|
|
r := mux.NewRouter()
|
|
r.HandleFunc("/assistant", service.FullfillmentHandler)
|
|
|
|
// Event loop
|
|
go func() {
|
|
fmt.Println("Starting event loop")
|
|
for {
|
|
select {
|
|
case present := <-p.Presence:
|
|
fmt.Printf("Presence: %t\n", present)
|
|
h.SetFlag(41, present)
|
|
n.Presence(present)
|
|
|
|
case <-h.Events:
|
|
break
|
|
}
|
|
}
|
|
}()
|
|
|
|
addr := ":8090"
|
|
srv := http.Server{
|
|
Addr: addr,
|
|
Handler: r,
|
|
}
|
|
|
|
log.Printf("Starting server on %s (PID: %d)\n", addr, os.Getpid())
|
|
srv.ListenAndServe()
|
|
}
|