/* Copyright © 2022 NAME HERE */ package cmd import ( "context" "time" log "github.com/sirupsen/logrus" "github.com/spf13/cobra" "github.com/vulcanize/ipld-ethcl-indexer/internal/boot" "github.com/vulcanize/ipld-ethcl-indexer/internal/shutdown" "github.com/vulcanize/ipld-ethcl-indexer/pkg/loghelper" ) // headCmd represents the head command var headCmd = &cobra.Command{ Use: "head", Short: "Capture only the blocks and state at head.", Long: `Capture only the blocks and state at head.`, Run: func(cmd *cobra.Command, args []string) { startHeadTracking() }, } // Start the application to track at head. func startHeadTracking() { // Boot the application log.Info("Starting the application in head tracking mode.") ctx := context.Background() BC, DB, err := boot.BootApplicationWithRetry(ctx, dbAddress, dbPort, dbName, dbUsername, dbPassword, dbDriver, bcAddress, bcPort, bcConnectionProtocol) if err != nil { loghelper.LogError(err).Error("Unable to Start application") } // Capture head blocks go BC.CaptureHead() // Shutdown when the time is right. shutdown.ShutdownServices(ctx, time.Duration(maxWaitSecondsShutdown), DB, BC) } func init() { captureCmd.AddCommand(headCmd) // Here you will define your flags and configuration settings. // Cobra supports Persistent Flags which will work for this command // and all subcommands, e.g.: // headCmd.PersistentFlags().String("foo", "", "A help for foo") // Cobra supports local flags which will only run when this command // is called directly, e.g.: // headCmd.Flags().BoolP("toggle", "t", false, "Help message for toggle") }