df6dfdf8a9
- drop the execution index; we don't need it - it is inclusion tipset - use MessagesForTipset - hoist db sql stuffs on top for clarity - add index for tipset on messages
44 lines
974 B
Go
44 lines
974 B
Go
package index
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/ipfs/go-cid"
|
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
)
|
|
|
|
var ErrNotFound = errors.New("message not found")
|
|
var ErrClosed = errors.New("index closed")
|
|
|
|
// MsgInfo is the Message metadata the index tracks.
|
|
type MsgInfo struct {
|
|
// the message this record refers to
|
|
Message cid.Cid
|
|
// the tipset where this messages was included
|
|
TipSet cid.Cid
|
|
// the epoch whre this message was included
|
|
Epoch abi.ChainEpoch
|
|
}
|
|
|
|
// MsgIndex is the interface to the message index
|
|
type MsgIndex interface {
|
|
// GetMsgInfo retrieves the message metadata through the index.
|
|
GetMsgInfo(ctx context.Context, m cid.Cid) (MsgInfo, error)
|
|
// Close closes the index
|
|
Close() error
|
|
}
|
|
|
|
type dummyMsgIndex struct{}
|
|
|
|
func (dummyMsgIndex) GetMsgInfo(ctx context.Context, m cid.Cid) (MsgInfo, error) {
|
|
return MsgInfo{}, ErrNotFound
|
|
}
|
|
|
|
func (dummyMsgIndex) Close() error {
|
|
return nil
|
|
}
|
|
|
|
var DummyMsgIndex MsgIndex = dummyMsgIndex{}
|