eth

var TrackSyncCmd = &cobra.Command{
	Use:   "trackSync",
	Short: "Track sync progress of Ethereum nodes",
	Long:  `Track sync progress of Ethereum's execution and Ethereum2 consensus nodes. You need to provide a list of execution and consensus nodes endpoints or put them in a configuration file or environment variables. Check the project's README for more information.`,
	Args:  cobra.NoArgs,
	Run: func(cmd *cobra.Command, args []string) {
		monitor, err := eth2.NewEth2Monitor(
			db.EmptyRepository{},
			&net.BeaconClient{RetryDuration: time.Second},
			&net.ExecutionClient{RetryDuration: time.Second},
			net.SubscribeOpts{},
			eth2.ConfigOpts{
				HandleCfg: false,
				Checkers: []eth2.CfgChecker{
					{Key: eth2.Execution, ErrMsg: eth2.NoExecutionFoundError, Data: executionEndp},
					{Key: eth2.Consensus, ErrMsg: eth2.NoConsensusFoundError, Data: consensusEndp},
				},
			},
		)
		if err != nil {
			log.Fatal(err)
		}

		done := make(chan struct{})

		sigChan := make(chan os.Signal, 1)
		signal.Notify(sigChan, os.Interrupt)

		results := monitor.TrackSync(done, consensusEndp, executionEndp, time.Duration(cron)*time.Second)

		go func() {
			for r := range results {
				if r.Error != nil {
					log.Errorf("Endpoint %s returned an error. Error: %v", r.Endpoint, r.Error)
				}
			}
		}()

		for range sigChan {
			log.Info("Received SIGINT, exiting...")
			close(done)
			time.Sleep(time.Second)
			os.Exit(0)
		}
	},
}