Commit 3df9fe4b authored by Jeromy's avatar Jeromy

integrate bitswap and blockservice into the core package

parent 1c51a522
...@@ -48,24 +48,29 @@ func (s *BlockService) AddBlock(b *blocks.Block) (u.Key, error) { ...@@ -48,24 +48,29 @@ func (s *BlockService) AddBlock(b *blocks.Block) (u.Key, error) {
// GetBlock retrieves a particular block from the service, // GetBlock retrieves a particular block from the service,
// Getting it from the datastore using the key (hash). // Getting it from the datastore using the key (hash).
func (s *BlockService) GetBlock(k u.Key) (*blocks.Block, error) { func (s *BlockService) GetBlock(k u.Key) (*blocks.Block, error) {
u.DOut("BlockService GetBlock: '%s'\n", k.Pretty())
dsk := ds.NewKey(string(k)) dsk := ds.NewKey(string(k))
datai, err := s.Datastore.Get(dsk) datai, err := s.Datastore.Get(dsk)
if err == nil { if err == nil {
u.DOut("Blockservice: Got data in datastore.\n")
bdata, ok := datai.([]byte) bdata, ok := datai.([]byte)
if !ok { if !ok {
return nil, fmt.Errorf("data associated with %s is not a []byte", k) return nil, fmt.Errorf("data associated with %s is not a []byte", k)
} }
u.DOut("Got data: %v\n", bdata)
return &blocks.Block{ return &blocks.Block{
Multihash: mh.Multihash(k), Multihash: mh.Multihash(k),
Data: bdata, Data: bdata,
}, nil }, nil
} else if err == ds.ErrNotFound && s.Remote != nil { } else if err == ds.ErrNotFound && s.Remote != nil {
u.DOut("Blockservice: Searching bitswap.\n")
blk, err := s.Remote.GetBlock(k, time.Second*5) blk, err := s.Remote.GetBlock(k, time.Second*5)
if err != nil { if err != nil {
return nil, err return nil, err
} }
return blk, nil return blk, nil
} else { } else {
u.DOut("Blockservice GetBlock: Not found.\n")
return nil, u.ErrNotFound return nil, u.ErrNotFound
} }
} }
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment