monitor

type Config struct {
	EthereumJsonRpcURIs []string `mapstructure:"ethereum-jsonrpc-uris"`
	PostgresDSN         string   `mapstructure:"postgres-dsn"`
	ListenAddress       string   `mapstructure:"listen-address"`
	SimulateBlocks      bool     `mapstructure:"simulate-blocks"`
	MevGethURI          string   `mapstructure:"mev-geth-uri"`
	MaxBlocks           int      `mapstructure:"max-blocks"`
	EnableDebug         bool     `mapstructure:"debug"`
}

type ConnectionInfo struct {
	NodeUri         string
	IsConnected     bool
	IsSubscribed    bool
	NumBlocks       uint64
	NumReconnects   int64
	NumResubscribes int64
	NextTimeout     int64
}

type GethConnection struct {
	NodeUri      string
	Client       *ethclient.Client
	NewBlockChan chan<- *analysis.Block

	IsConnected         bool
	IsSubscribed        bool
	NextRetryTimeoutSec int64 // Wait time before retry. Starts at 5 seconds and doubles after each unsuccessful retry (max: 3 min).

	NumResubscribes int64
	NumReconnects   int64
	NumBlocks       uint64
}

type MonitorInfo struct {
	Id                  string
	NumBlocks           int
	EarliestBlockNumber uint64
	LatestBlockNumber   uint64
	TimeStarted         string
}

type MonitorWebserver struct {
	Monitor     *ReorgMonitor
	Addr        string
	TimeStarted time.Time
}

type ReorgMonitor struct {
	NewBlockChan chan *analysis.Block
	NewReorgChan chan<- *analysis.Reorg

	BlockByHash    map[common.Hash]*analysis.Block
	BlocksByHeight map[uint64]map[common.Hash]*analysis.Block

	EarliestBlockNumber uint64
	LatestBlockNumber   uint64

	KnownReorgs map[string]uint64 // key: reorgId, value: endBlockNumber
	// contains filtered or unexported fields
}

type StatusResponse struct {
	Monitor     MonitorInfo
	Connections []ConnectionInfo
}