scan

type BNSH BlockNumberScannerHandler

type BlockNumber2LogData struct {
	sync.RWMutex
	M         map[string]*LogData
	BlocksDLL *DoublyLinkedList // for efficient cleanup
}

type BlockNumberScannerHandler struct{}

type ChannelID2Info struct {
	sync.RWMutex
	M    map[string]*ChannelInfo
	SHub *EHub // parent
	// contains filtered or unexported fields
}

type ChannelID2Soln struct {
	sync.RWMutex
	M    map[string]*Soln
	SHub *EHub // parent
	// contains filtered or unexported fields
}

type ChannelInfo struct {
	sync.RWMutex
	Address    string
	IsOpenTick NYUP
	IsOpenStop NYUP
	Value      uint64
	Gas        uint64
	GasPrice   uint64
	Ticks      uint64
}

type DataType int

type EHub struct {
	BlockNumber *state.BlockNumber // ptr to the global block number
	TxMgr       *state.TxMgr
	ProfileMgr  *state.ProfileMgr

	Scanners *Topic2Scanner
	Solns    *ChannelID2Soln
	Channels *ChannelID2Info
	// contains filtered or unexported fields
}

type EScanner struct {
	SHub Hub // parent

	BlkN2LogData *BlockNumber2LogData
	// contains filtered or unexported fields
}

type Hub interface {
	Init(topics []string, lookback uint64) error
	// TODO CONSOLIDATE INITIALIZERS
	InitializeBlockNumberScanner(w *sync.WaitGroup)
	InitializeTxMgr(w *sync.WaitGroup)
	InitializeProfileMgr(lookback uint64, w *sync.WaitGroup)
	InitGlobalParameters(w *sync.WaitGroup) <-chan error
	InitChannels(lookback uint64, w *sync.WaitGroup)
	InitSolns(lookback uint64, w *sync.WaitGroup)
	InitTestTriggers(w *sync.WaitGroup)
	Topics() []string
	TopicHashes() []string
	CatchUp() error
	Listen() error
	UpdateCache() error // this is to prune irrelevant entries
	AddData(method, blockNumber string, up *encodings.UnpackedTx)
	SolnIsSubmitted(channelID, soln string) (tf bool)
}

type LH ListenerHandler

type LSParams struct {
	Result LSResult `json:"result"`
}

type LSResult struct {
	BlockNumber     string `json:"blockNumber"`
	Data            string `json:"data"`
	TransactionHash string `json:"transactionHash"`
}

type ListenerHandler struct{}

type LogData struct {
	Data map[string]bool
}

type LogsSubscription struct {
	Params LSParams `json:"params"`
}

type NPTP struct {
	Result string `json:"result"`
}

type NewHeadsParams struct {
	Result NewHeadsResult `json:"result"`
}

type NewHeadsResponse struct {
	Params NewHeadsParams `json:"params"`
}

type NewHeadsResult struct {
	Number   string `json:"number"`
	GasLimit string `json:"gasLimit"`
}

type NewPendingTransactionsResponse struct {
	Params NPTP `json:"params"`
}

type PTH PendingTransactionsHandler

type PendingTransactionsHandler struct{}

type Scanner interface {
	Topic() string
	TopicHash() string
	Init(topic string, lookback uint64) error
	DumpData() [][]byte
	CatchUp() error
	Listen() error
	Process(data interface{}, t DataType) error
	UpdateCache() error // this is to prune irrelevant entries
}

type Soln struct {
	sync.RWMutex // mutex not immediately useful, but may be later
	M            map[string]bool
}

type Topic2Scanner struct {
	sync.RWMutex
	M map[string]*EScanner
}