// Package cmd provides the command line interface for the RFQ API service.
package cmd

import (
	"fmt"

	"github.com/synapsecns/sanguine/core/commandline"
	"github.com/synapsecns/sanguine/core/dbcommon"

	"github.com/synapsecns/sanguine/core"
	"github.com/synapsecns/sanguine/core/metrics"
	omniClient "github.com/synapsecns/sanguine/services/omnirpc/client"
	"github.com/synapsecns/sanguine/services/rfq/api/config"
	"github.com/synapsecns/sanguine/services/rfq/api/db/sql"
	"github.com/synapsecns/sanguine/services/rfq/api/rest"
	"github.com/urfave/cli/v2"
)

var configFlag = &cli.StringFlag{
	Name:      "config",
	Usage:     "path to the config file",
	TakesFile: true,
}

// runCommand runs the rfq api.
var runCommand = &cli.Command{
	Name:        "run",
	Description: "run the API Server",
	Flags:       []cli.Flag{configFlag, &commandline.LogLevel},
	Action: func(c *cli.Context) (err error) {
		commandline.SetLogLevel(c)
		cfg, err := config.LoadConfig(core.ExpandOrReturnPath(c.String(configFlag.Name)))
		if err != nil {
			return fmt.Errorf("could not read config file: %w", err)
		}

		metricsProvider := metrics.Get()

		dbType, err := dbcommon.DBTypeFromString(cfg.Database.Type)
		if err != nil {
			return fmt.Errorf("could not get db type: %w", err)
		}
		store, err := sql.Connect(c.Context, dbType, cfg.Database.DSN, metricsProvider)
		if err != nil {
			return fmt.Errorf("could not connect to database: %w", err)
		}

		omnirpcClient := omniClient.NewOmnirpcClient(cfg.OmniRPCURL, metricsProvider, omniClient.WithCaptureReqRes())
		apiServer, err := rest.NewAPI(c.Context, cfg, metricsProvider, omnirpcClient, store)
		if err != nil {
			return fmt.Errorf("could not create api server: %w", err)
		}

		err = apiServer.Run(c.Context)
		if err != nil {
			return fmt.Errorf("could not run rfq relayer: %w", err)
		}
		return nil
	},
}