package main

import (
	"log/slog"
	"os"

	"edge-infra.dev/pkg/edge/logging/logreplay"
)

func main() {
	jh := slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{
		ReplaceAttr: func(_ []string, a slog.Attr) slog.Attr {
			// use "message" instead of "msg" for the output since "message" has a special meaning in GCP
			if a.Key == slog.MessageKey {
				a.Key = "message"
			}
			return a
		},
	})

	log := slog.New(jh)

	// setup logger and read environment variables
	cfg, err := logreplay.NewConfig()
	if err != nil {
		log.Error("config err", "could not create config", err)
		os.Exit(1)
	}

	// setup the log replay client
	lrc, err := logreplay.New(cfg)
	if err != nil {
		log.Error("k8s client error", "could not create log replay client", err)
		os.Exit(1)
	}

	// run the log replay
	if err = lrc.Run(); err != nil {
		log.Error("log replay err", "error", err)
		os.Exit(1)
	}
}