synapsecns/sanguine

package cmd

import (
    "fmt"

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

    "github.com/synapsecns/sanguine/core"
    "github.com/synapsecns/sanguine/core/dbcommon"
    "github.com/synapsecns/sanguine/core/metrics"
    "github.com/synapsecns/sanguine/services/cctp-relayer/attestation"
    "github.com/synapsecns/sanguine/services/cctp-relayer/config"
    "github.com/synapsecns/sanguine/services/cctp-relayer/db/sql"
    "github.com/synapsecns/sanguine/services/cctp-relayer/relayer"
    omniClient "github.com/synapsecns/sanguine/services/omnirpc/client"
    "github.com/urfave/cli/v2"
)

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

var dbFlag = &cli.StringFlag{
    Name:     "db",
    Usage:    "--db <sqlite> or <mysql>",
    Value:    "sqlite",
    Required: true,
}

var pathFlag = &cli.StringFlag{
    Name:     "path",
    Usage:    "--path <path/to/database> or <database url>",
    Required: true,
}

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

        _, err = cfg.IsValid(c.Context)
        if err != nil {
            return fmt.Errorf("could not decode config file: %w", err)
        }

        dbTypeFromString, err := dbcommon.DBTypeFromString(c.String(dbFlag.Name))
        if err != nil {
            return fmt.Errorf("could not get db type from string: %w", err)
        }

        path := core.ExpandOrReturnPath(c.String(pathFlag.Name))

        metricsProvider := metrics.Get()

        store, err := sql.Connect(c.Context, dbTypeFromString, path, metricsProvider)
        if err != nil {
            return fmt.Errorf("could not connect to database: %w", err)
        }

        omnirpcClient := omniClient.NewOmnirpcClient(cfg.BaseOmnirpcURL, metricsProvider, omniClient.WithCaptureReqRes())
        attAPI := attestation.NewCircleAPI(c.String(cfg.CircleAPIURl))

        cctpRelayer, err := relayer.NewCCTPRelayer(c.Context, cfg, store, omnirpcClient, metricsProvider, attAPI)
        if err != nil {
            return fmt.Errorf("could not create cctp relayer: %w", err)
        }

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