datastore

type AddressRepository interface {
	GetOrCreateAddress(address string) (int, error)
}

type CheckedHeadersRepository interface {
	MarkHeaderChecked(headerID int64) error
	MarkSingleHeaderUnchecked(blockNumber int64) error
	UncheckedHeaders(startingBlockNumber, endingBlockNumber, checkCount int64) ([]core.Header, error)
}

type CheckedLogsRepository interface {
	AlreadyWatchingLog(addresses []string, topic0 string) (bool, error)
	MarkLogWatched(addresses []string, topic0 string) error
}

type EventLogRepository interface {
	GetUntransformedEventLogs(minID, limit int) ([]core.EventLog, error)
	CreateEventLogs(headerID int64, logs []types.Log) error
}

type HeaderRepository interface {
	CreateOrUpdateHeader(header core.Header) (int64, error)
	CreateTransactions(headerID int64, transactions []core.TransactionModel) error
	CreateTransactionInTx(tx *sqlx.Tx, headerID int64, transaction core.TransactionModel) (int64, error)
	DeleteHeader(blockNumber int64) error
	GetHeaderByBlockNumber(blockNumber int64) (core.Header, error)
	GetHeaderByID(id int64) (core.Header, error)
	GetHeadersInRange(startingBlock, endingBlock int64) ([]core.Header, error)
	MissingBlockNumbers(startingBlockNumber, endingBlockNumber int64) ([]int64, error)
	GetMostRecentHeaderBlockNumber() (int64, error)
}