model

type ContractFilterers interface {
	ContractName() string
	ContractAddress() common.Address
	EventTypes() []string
	UpdateStartBlock(eventType string, startBlock uint64)
	LastEvents() []*Event
	StartFilterers(client bind.ContractBackend, pastEvents []*Event, nonSubOnly bool) ([]*Event, error)
}

type ContractWatchers interface {
	ContractName() string
	ContractAddress() common.Address
	StartWatchers(client bind.ContractBackend, eventRecvChan chan *Event,
		errs chan error) ([]utils.WatcherSubscription, error)
	StopWatchers(unsub bool) error
}

type Event struct {
	// contains filtered or unexported fields
}

type EventDataPersister interface {
	// SaveEvents stores a list of Event(s)
	SaveEvents(events []*Event) []error

	// RetrieveEvents retrieves the Events from the persistence layer based
	// on date in which it was received
	RetrieveEvents(criteria *RetrieveEventsCriteria) ([]*Event, error)
}

type EventPayload struct {
	// contains filtered or unexported fields
}

type EventPayloadValue struct {
	// contains filtered or unexported fields
}

type ListenerMetaDataPersister interface {
	// LastBlockNumber returns the last block number seen by the listener for
	// an event type and contract address
	LastBlockNumber(eventType string, contractAddress common.Address) uint64

	// LastBlockHash returns the last block hash seen by the listener for an
	// event type and contract address
	LastBlockHash(eventType string, contractAddress common.Address) common.Hash

	// UpdateLastBlockData should update the last block data from the Event(s)
	UpdateLastBlockData(events []*Event) error
}

type RetrievalMethod int

type RetrieveEventsCriteria struct {
	Hash            string   `db:"hash"`
	ContractAddress string   `db:"contract_address"`
	Offset          int      `db:"offset"`
	Count           int      `db:"count"`
	ExcludeHashes   []string `db:"exclude_hashes"`
	// Reverse reverses by id in DB
	Reverse   bool   `db:"reverse"`
	FromTs    int64  `db:"fromts"`
	BeforeTs  int64  `db:"beforets"`
	EventType string `db:"eventtype"`
}

type RetrieverMetaDataPersister interface {
	// LastBlockNumber returns the last block number seen by the retriever for
	// an event type and contract address
	LastBlockNumber(eventType string, contractAddress common.Address) uint64

	// LastBlockHash returns the last block hash seen by the retriever for an event
	// type and contract address
	LastBlockHash(eventType string, contractAddress common.Address) common.Hash

	// UpdateLastBlockData should update the last block Number from the Event(s)
	UpdateLastBlockData(events []*Event) error
}

type VersionDataPersister interface {
	// PersisterVersion retrieves the latest version for the table type
	PersisterVersion(tableType string) (string, error)

	// SaveVersion saves the version number for this table type with the current timestamp
	SaveVersion(tableType string, versionNumber string) error

	// OldVersions retrieves all the versions except for most recent for this service name
	OldVersions(serviceName string) ([]string, error)
}