main.go

package main

import (
	"flag"
	"github.com/mwuertinger/hal/pkg/mqtt"
	"log"
	"os"
	"os/signal"
	"syscall"

	"github.com/mwuertinger/hal/pkg/config"
	"github.com/mwuertinger/hal/pkg/device"
	"github.com/mwuertinger/hal/pkg/frontend"
	"github.com/mwuertinger/hal/pkg/persistence"
)

func main() {
	sigc := make(chan os.Signal, 1)
	signal.Notify(sigc, os.Interrupt, os.Kill, syscall.SIGTERM)

	configPath := flag.String("config", "", "Path to config file.")
	flag.Parse()

	if len(*configPath) < 1 {
		log.Fatalf("Missing -config argument.")
	}

	c, err := config.Load(*configPath)
	if err != nil {
		log.Fatalf("Failed to read config file: %v", err)
	}

	persistence := persistence.GetInMemoryService()
	if err := persistence.Start(); err != nil {
		log.Fatalf("persistence.Start: %v", err)
	}

	mqttBroker := mqtt.New()
	if err := mqttBroker.Connect(c.Mqtt); err != nil {
		log.Fatalf("mqttBroker.Connect: %v", err)
	}

	device.SetMqttBroker(mqttBroker)
	if err := device.RegisterDevices(c.Devices); err != nil {
		log.Fatalf("device.RegisterDevices: %v", err)
	}

	if err := frontend.Start(c.Http); err != nil {
		log.Fatalf("frontend.Start: %v", err)
	}

	log.Println("Server ready")

	// Wait for receiving a signal.
	sig := <-sigc
	log.Printf("Received %v signal, shutting down...", sig)

	frontend.Shutdown()
	mqttBroker.Shutdown()
	device.Shutdown()
}