hats/main.go

package main

import (
	"context"
	_ "embed"
	"log/slog"
	"os"
	"os/signal"

	"code.jhot.me/jhot/hats/internal/api"
	"code.jhot.me/jhot/hats/internal/homeassistant"
	"code.jhot.me/jhot/hats/internal/nats"
	"code.jhot.me/jhot/hats/internal/ntfy"
	"code.jhot.me/jhot/hats/pkg/config"
)

//go:embed README.md
var readme []byte

var (
	interrupt chan os.Signal
	cfg       *config.HatsConfig
	logger    *slog.Logger
	ctx       context.Context
	cancel    context.CancelFunc
)

func main() {
	cfg = config.FromEnvironment()
	ctx, cancel = context.WithCancel(context.Background())
	logger = slog.New(slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{
		Level: cfg.GetLogLevel(),
	}))
	interrupt = make(chan os.Signal, 1)
	signal.Notify(interrupt, os.Interrupt)

	err := nats.JetstreamConnect(ctx, logger)
	if err != nil {
		panic(err)
	}
	defer nats.Close()

	err = nats.KvConnect()
	if err != nil {
		panic(err)
	}

	err = nats.ScheduleStoreConnect()
	if err != nil {
		panic(err)
	}
	nats.GetExistingSchedules()
	defer nats.StopSchedules()

	err = homeassistant.Subscribe(logger)
	if err != nil {
		panic(err)
	}
	defer homeassistant.CloseSubscription()

	ntfy.InitClient(cfg)

	api.Listen(logger, readme)
	defer api.Close()

	for sig := range interrupt {
		logger.Debug("Interrupt:", "signal", sig.String())
		cancel()
		break
	}
}