monitor

var MonitorCmd = &cobra.Command{
	Use:   "monitor [rpc-url]",
	Short: "A simple terminal monitor for a blockchain",
	Long:  ``,
	RunE: func(cmd *cobra.Command, args []string) error {
		ctx := cmd.Context()

		rpc, err := ethrpc.DialContext(ctx, args[0])
		if err != nil {
			log.Error().Err(err).Msg("Unable to dial rpc")
			return err
		}
		ec := ethclient.NewClient(rpc)

		ms := new(monitorStatus)

		ms.MaxBlockRetrieved = big.NewInt(0)
		ms.BlocksLock.Lock()
		ms.Blocks = make(map[string]rpctypes.PolyBlock, 0)
		ms.BlocksLock.Unlock()
		ms.ChainID = big.NewInt(0)
		zero := big.NewInt(0)

		isUiRendered := false
		errChan := make(chan error)
		go func() {
			for {
				var cs *chainState
				cs, err = getChainState(ctx, ec)
				if err != nil {
					log.Error().Err(err).Msg("Encountered issue fetching network information")
					time.Sleep(5 * time.Second)
					continue
				}

				ms.HeadBlock = new(big.Int).SetUint64(cs.HeadBlock)
				ms.ChainID = cs.ChainID
				ms.PeerCount = cs.PeerCount
				ms.GasPrice = cs.GasPrice

				from := big.NewInt(0)

				if ms.MaxBlockRetrieved.Cmp(from) == 0 {
					headBlockMinusBatchSize := new(big.Int).SetUint64(*inputBatchSize + 100 - 1)
					from.Sub(ms.HeadBlock, headBlockMinusBatchSize)
				} else {
					from = ms.MaxBlockRetrieved
				}

				if from.Cmp(zero) < 0 {
					from.SetInt64(0)
				}
				err = ms.getBlockRange(ctx, from, ms.HeadBlock, rpc, args[0])
				if err != nil {
					log.Error().Err(err).Msg("There was an issue fetching the block range")
				}
				if !isUiRendered {
					go func() {
						errChan <- renderMonitorUI(ms)
					}()
					isUiRendered = true

				}
				time.Sleep(5 * time.Second)
			}

		}()

		err = <-errChan
		return err
	},
	Args: func(cmd *cobra.Command, args []string) error {
		if len(args) != 1 {
			return fmt.Errorf("too many arguments")
		}

		_, err := url.Parse(args[0])
		if err != nil {
			log.Error().Err(err).Msg("Unable to parse url input error")
			return err
		}

		if *inputBatchSize == 0 {
			return fmt.Errorf("batch-size can't be equal to zero")
		}

		setMonitorLogLevel(*verbosity)

		return nil
	},
}