b7a4dbb07f
And use the new CidBuilder from the spec actors. This patch does not switch over to inline CIDs by default, but paves the way.
69 lines
1.4 KiB
Go
69 lines
1.4 KiB
Go
package apibstore
|
|
|
|
import (
|
|
"context"
|
|
|
|
blocks "github.com/ipfs/go-block-format"
|
|
"github.com/ipfs/go-cid"
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/lotus/lib/blockstore"
|
|
)
|
|
|
|
type ChainIO interface {
|
|
ChainReadObj(context.Context, cid.Cid) ([]byte, error)
|
|
ChainHasObj(context.Context, cid.Cid) (bool, error)
|
|
}
|
|
|
|
type apiBStore struct {
|
|
api ChainIO
|
|
}
|
|
|
|
func NewAPIBlockstore(cio ChainIO) blockstore.Blockstore {
|
|
return &apiBStore{
|
|
api: cio,
|
|
}
|
|
}
|
|
|
|
func (a *apiBStore) DeleteBlock(cid.Cid) error {
|
|
return xerrors.New("not supported")
|
|
}
|
|
|
|
func (a *apiBStore) Has(c cid.Cid) (bool, error) {
|
|
return a.api.ChainHasObj(context.TODO(), c)
|
|
}
|
|
|
|
func (a *apiBStore) Get(c cid.Cid) (blocks.Block, error) {
|
|
bb, err := a.api.ChainReadObj(context.TODO(), c)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return blocks.NewBlockWithCid(bb, c)
|
|
}
|
|
|
|
func (a *apiBStore) GetSize(c cid.Cid) (int, error) {
|
|
bb, err := a.api.ChainReadObj(context.TODO(), c)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return len(bb), nil
|
|
}
|
|
|
|
func (a *apiBStore) Put(blocks.Block) error {
|
|
return xerrors.New("not supported")
|
|
}
|
|
|
|
func (a *apiBStore) PutMany([]blocks.Block) error {
|
|
return xerrors.New("not supported")
|
|
}
|
|
|
|
func (a *apiBStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error) {
|
|
return nil, xerrors.New("not supported")
|
|
}
|
|
|
|
func (a *apiBStore) HashOnRead(enabled bool) {
|
|
return
|
|
}
|
|
|
|
var _ blockstore.Blockstore = &apiBStore{}
|