package main

import (
	"context"
	"flag"
	"fmt"
	"os"
	"os/signal"
	"runtime/pprof"
	"sync"

	"badc0de.net/pkg/flagutil"
	"github.com/getsentry/sentry-go"

	"go.alanpearce.eu/searchix/internal/config"
	"go.alanpearce.eu/searchix/internal/importer"
	"go.alanpearce.eu/searchix/internal/index"
	"go.alanpearce.eu/searchix/web"
	"go.alanpearce.eu/x/log"
)

var (
	configFile         = flag.String("config", "config.toml", "config `file` to use")
	printDefaultConfig = flag.Bool(
		"print-default-config",
		false,
		"print default configuration and exit",
	)
	dev        = flag.Bool("dev", false, "enable live reloading and nicer logging")
	replace    = flag.Bool("replace", false, "replace existing index and exit")
	version    = flag.Bool("version", false, "print version information")
	cpuprofile = flag.String("cpuprofile", "", "enable CPU profiling and save to `file`")
)

func main() {
	flagutil.Parse()
	if *version {
		_, err := fmt.Fprintf(os.Stderr, "searchix %s\n", config.Version)
		if err != nil {
			panic("can't write to standard error?!")
		}
		os.Exit(0)
	}
	if *printDefaultConfig {
		_, err := fmt.Print(config.GetDefaultConfig())
		if err != nil {
			panic("can't write to standard output?!")
		}
		os.Exit(0)
	}
	if *cpuprofile != "" {
		f, err := os.Create(*cpuprofile)
		if err != nil {
			panic("can't create CPU profile: " + err.Error())
		}
		err = pprof.StartCPUProfile(f)
		if err != nil {
			panic("can't start CPU profile: " + err.Error())
		}
		defer pprof.StopCPUProfile()
	}

	logger := log.Configure(!*dev)

	cfg, err := config.GetConfig(*configFile, logger)
	if err != nil {
		logger.Fatal("Failed to parse config file", "error", err)
	}

	log.SetLevel(cfg.LogLevel)

	ctx, cancel := signal.NotifyContext(context.Background(), os.Interrupt)
	defer cancel()

	read, write, exists, err := index.OpenOrCreate(
		cfg.DataPath,
		*replace,
		&index.Options{
			LowMemory: cfg.Importer.LowMemory,
			Logger:    logger.Named("index"),
		},
	)
	if err != nil {
		logger.Fatal("Failed to open or create index", "error", err)
	}

	s, err := web.New(cfg, logger, read)
	if err != nil {
		logger.Fatal("Failed to initialise searchix-web", "error", err)
	}

	imp, err := importer.New(cfg, &importer.Options{
		LowMemory: cfg.Importer.LowMemory,
		Logger:    logger.Named("importer"),
	})
	if err != nil {
		logger.Fatal("Failed to create importer", "error", err)
	}

	if !exists || *replace {
		err := imp.Start(ctx, true, nil)
		if err != nil {
			logger.Fatal("Failed to start importer", "error", err)
		}

		return
	}

	err = imp.EnsureSourcesIndexed(ctx, read, write)
	if err != nil {
		logger.Fatal("Failed to setup index", "error", err)
	}

	wg := &sync.WaitGroup{}
	wg.Add(1)
	go func() {
		defer wg.Done()
		err := s.Start(*dev)
		if err != nil {
			// Error starting or closing listener:
			logger.Fatal("error", "error", err)
		}
	}()

	wg.Add(1)
	go func() {
		defer wg.Done()
		imp.StartUpdateTimer(ctx, sentry.CurrentHub().Clone())
	}()

	<-ctx.Done()
	logger.Debug("calling stop")
	s.Stop()
	wg.Wait()
	logger.Debug("done")
}