mirror of
https://github.com/anyproto/any-sync.git
synced 2025-06-08 05:57:03 +09:00
51 lines
1.2 KiB
Go
51 lines
1.2 KiB
Go
package fileservice
|
|
|
|
import (
|
|
"context"
|
|
"github.com/anyproto/any-sync/commonfile/fileblockstore"
|
|
"github.com/ipfs/boxo/blockservice"
|
|
blockstore "github.com/ipfs/boxo/blockstore"
|
|
exchange "github.com/ipfs/boxo/exchange"
|
|
blocks "github.com/ipfs/go-block-format"
|
|
"github.com/ipfs/go-cid"
|
|
)
|
|
|
|
func newBlockService(store fileblockstore.BlockStore) blockservice.BlockService {
|
|
return &blockService{store: store}
|
|
}
|
|
|
|
type blockService struct {
|
|
store fileblockstore.BlockStore
|
|
}
|
|
|
|
func (bs *blockService) GetBlock(ctx context.Context, c cid.Cid) (blocks.Block, error) {
|
|
return bs.store.Get(ctx, c)
|
|
}
|
|
|
|
func (bs *blockService) GetBlocks(ctx context.Context, ks []cid.Cid) <-chan blocks.Block {
|
|
return bs.store.GetMany(ctx, ks)
|
|
}
|
|
|
|
func (bs *blockService) Blockstore() blockstore.Blockstore {
|
|
return nil
|
|
}
|
|
|
|
func (bs *blockService) Exchange() exchange.Interface {
|
|
return nil
|
|
}
|
|
|
|
func (bs *blockService) AddBlock(ctx context.Context, b blocks.Block) error {
|
|
return bs.store.Add(ctx, []blocks.Block{b})
|
|
}
|
|
|
|
func (bs *blockService) AddBlocks(ctx context.Context, b []blocks.Block) error {
|
|
return bs.store.Add(ctx, b)
|
|
}
|
|
|
|
func (bs *blockService) DeleteBlock(ctx context.Context, c cid.Cid) error {
|
|
return bs.store.Delete(ctx, c)
|
|
}
|
|
|
|
func (bs *blockService) Close() error {
|
|
return nil
|
|
}
|