cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

abstract ChainStore interface

Browse Source
This commit is contained in:
vyzo 2023-03-11 17:55:48 +02:00
parent eab728c4e7
commit 9144f9cea7
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
chain/index/msgindex.go
View File

@ -18,8 +18,16 @@ import (
"github.com/filecoin-project/lotus/chain/types"
)
// chain store interface; we could use store.ChainStore directly,
// but this simplifies unit testing.
type ChainStore interface {
SubscribeHeadChanges(f store.ReorgNotifee)
}
var _ ChainStore = (*store.ChainStore)(nil)
type msgIndex struct {
cs *store.ChainStore
cs ChainStore
db *sql.DB
}
@ -36,7 +44,7 @@ var (
coalesceMergeInterval = 100 * time.Millisecond
)
func NewMsgIndex(basePath string, cs *store.ChainStore) (MsgIndex, error) {
func NewMsgIndex(basePath string, cs ChainStore) (MsgIndex, error) {
var (
mkdb bool
dbPath string
@ -113,7 +121,7 @@ func createTables(db *sql.DB) error {
return errors.New("TODO: index.createTables")
}
func reconcileIndex(db *sql.DB, cs *store.ChainStore) error {
func reconcileIndex(db *sql.DB, cs ChainStore) error {
// TODO
return errors.New("TODO: index.reconcileIndex")
}