@cryptotaxi247 / kubo / commits / df59b29fd

Extract exchange/offline to go-ipfs-exchange offline

License: MIT Signed-off-by: Hector Sanjuan <hector@protocol.ai>

Hector Sanjuan committed Apr 3, 2018 at 16:30 UTC df59b29fdc2c2094a92aaf1c3b2cbd32de35d373
20 files changed +23 -170
blockservice/blockservice_test.go
+1 -2
@@ -3,8 +3,7 @@ package blockservice
3 import (
4 "testing"
5
6 - offline "github.com/ipfs/go-ipfs/exchange/offline"
7 -
6 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
7 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
8 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
9 blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
blockservice/test/blocks_test.go
+1 -1
@@ -8,9 +8,9 @@ import (
8 "time"
9
10 . "github.com/ipfs/go-ipfs/blockservice"
11 - offline "github.com/ipfs/go-ipfs/exchange/offline"
11
12 u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
13 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
14 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
15 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
16 blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
core/builder.go
+1 -1
@@ -10,7 +10,6 @@ import (
10 "time"
11
12 bserv "github.com/ipfs/go-ipfs/blockservice"
13 - offline "github.com/ipfs/go-ipfs/exchange/offline"
13 filestore "github.com/ipfs/go-ipfs/filestore"
14 dag "github.com/ipfs/go-ipfs/merkledag"
15 resolver "github.com/ipfs/go-ipfs/path/resolver"
@@ -22,6 +21,7 @@ import (
21
22 metrics "gx/ipfs/QmRg1gKTHzc3CZXSKzem8aR4E3TubFhbgXwfVuWnSK5CC5/go-metrics-interface"
23 goprocessctx "gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess/context"
24 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
25 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
26 retry "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/retrystore"
27 dsync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
core/commands/add.go
+1 -1
@@ -10,12 +10,12 @@ import (
10 blockservice "github.com/ipfs/go-ipfs/blockservice"
11 core "github.com/ipfs/go-ipfs/core"
12 "github.com/ipfs/go-ipfs/core/coreunix"
13 - offline "github.com/ipfs/go-ipfs/exchange/offline"
13 dag "github.com/ipfs/go-ipfs/merkledag"
14 dagtest "github.com/ipfs/go-ipfs/merkledag/test"
15 mfs "github.com/ipfs/go-ipfs/mfs"
16 ft "github.com/ipfs/go-ipfs/unixfs"
17
18 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
19 mh "gx/ipfs/QmZyZDi491cCNTLfAhwcaDii2Kg4pwKRkhqQzURGDvY6ua/go-multihash"
20 bstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
21 cmdkit "gx/ipfs/QmceUdzxkimdYsgtX733uNgzf1DLHyBKN6ehGSp85ayppM/go-ipfs-cmdkit"
core/commands/files.go
+1 -1
@@ -15,7 +15,6 @@ import (
15 lgc "github.com/ipfs/go-ipfs/commands/legacy"
16 core "github.com/ipfs/go-ipfs/core"
17 e "github.com/ipfs/go-ipfs/core/commands/e"
18 - "github.com/ipfs/go-ipfs/exchange/offline"
18 dag "github.com/ipfs/go-ipfs/merkledag"
19 mfs "github.com/ipfs/go-ipfs/mfs"
20 path "github.com/ipfs/go-ipfs/path"
@@ -25,6 +24,7 @@ import (
24
25 humanize "gx/ipfs/QmPSBJL4momYnE7DcUyk2DVhD6rH488ZmHBGLbxNdhU44K/go-humanize"
26 logging "gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
27 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
28 mh "gx/ipfs/QmZyZDi491cCNTLfAhwcaDii2Kg4pwKRkhqQzURGDvY6ua/go-multihash"
29 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
30 cmdkit "gx/ipfs/QmceUdzxkimdYsgtX733uNgzf1DLHyBKN6ehGSp85ayppM/go-ipfs-cmdkit"
core/commands/ls.go
+1 -1
@@ -10,7 +10,6 @@ import (
10 cmds "github.com/ipfs/go-ipfs/commands"
11 core "github.com/ipfs/go-ipfs/core"
12 e "github.com/ipfs/go-ipfs/core/commands/e"
13 - offline "github.com/ipfs/go-ipfs/exchange/offline"
13 merkledag "github.com/ipfs/go-ipfs/merkledag"
14 path "github.com/ipfs/go-ipfs/path"
15 resolver "github.com/ipfs/go-ipfs/path/resolver"
@@ -18,6 +17,7 @@ import (
17 uio "github.com/ipfs/go-ipfs/unixfs/io"
18 unixfspb "github.com/ipfs/go-ipfs/unixfs/pb"
19
20 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
21 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
22 "gx/ipfs/QmceUdzxkimdYsgtX733uNgzf1DLHyBKN6ehGSp85ayppM/go-ipfs-cmdkit"
23 ipld "gx/ipfs/Qme5bWv7wtjUNGsK2BNGVUFPKiuxWrsqrtvYwCLRw8YFES/go-ipld-format"
core/commands/pin.go
+1 -1
@@ -12,7 +12,6 @@ import (
12 core "github.com/ipfs/go-ipfs/core"
13 e "github.com/ipfs/go-ipfs/core/commands/e"
14 corerepo "github.com/ipfs/go-ipfs/core/corerepo"
15 - offline "github.com/ipfs/go-ipfs/exchange/offline"
15 dag "github.com/ipfs/go-ipfs/merkledag"
16 path "github.com/ipfs/go-ipfs/path"
17 resolver "github.com/ipfs/go-ipfs/path/resolver"
@@ -21,6 +20,7 @@ import (
20 uio "github.com/ipfs/go-ipfs/unixfs/io"
21
22 u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
23 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
24 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
25 "gx/ipfs/QmceUdzxkimdYsgtX733uNgzf1DLHyBKN6ehGSp85ayppM/go-ipfs-cmdkit"
26 )
core/coreapi/pin.go
+1 -1
@@ -8,10 +8,10 @@ import (
8 coreiface "github.com/ipfs/go-ipfs/core/coreapi/interface"
9 caopts "github.com/ipfs/go-ipfs/core/coreapi/interface/options"
10 corerepo "github.com/ipfs/go-ipfs/core/corerepo"
11 - offline "github.com/ipfs/go-ipfs/exchange/offline"
11 merkledag "github.com/ipfs/go-ipfs/merkledag"
12 pin "github.com/ipfs/go-ipfs/pin"
13
14 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
15 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
16 ipld "gx/ipfs/Qme5bWv7wtjUNGsK2BNGVUFPKiuxWrsqrtvYwCLRw8YFES/go-ipld-format"
17 )
core/coreunix/add.go
+1 -1
@@ -11,7 +11,6 @@ import (
11
12 bserv "github.com/ipfs/go-ipfs/blockservice"
13 core "github.com/ipfs/go-ipfs/core"
14 - "github.com/ipfs/go-ipfs/exchange/offline"
14 balanced "github.com/ipfs/go-ipfs/importer/balanced"
15 ihelper "github.com/ipfs/go-ipfs/importer/helpers"
16 trickle "github.com/ipfs/go-ipfs/importer/trickle"
@@ -21,6 +20,7 @@ import (
20 unixfs "github.com/ipfs/go-ipfs/unixfs"
21
22 logging "gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
23 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
24 chunker "gx/ipfs/QmWo8jYc19ppG7YoTsrr2kEtLRbARTJho5oNXFTR6B7Peq/go-ipfs-chunker"
25 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
26 syncds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
core/coreunix/metadata_test.go
+1 -1
@@ -8,13 +8,13 @@ import (
8
9 bserv "github.com/ipfs/go-ipfs/blockservice"
10 core "github.com/ipfs/go-ipfs/core"
11 - offline "github.com/ipfs/go-ipfs/exchange/offline"
11 importer "github.com/ipfs/go-ipfs/importer"
12 merkledag "github.com/ipfs/go-ipfs/merkledag"
13 ft "github.com/ipfs/go-ipfs/unixfs"
14 uio "github.com/ipfs/go-ipfs/unixfs/io"
15
16 u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
17 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
18 chunker "gx/ipfs/QmWo8jYc19ppG7YoTsrr2kEtLRbARTJho5oNXFTR6B7Peq/go-ipfs-chunker"
19 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
20 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
exchange/offline/offline.go deleted
-73
@@ -1,73 +0,0 @@
1 -// package offline implements an object that implements the exchange
2 -// interface but returns nil values to every request.
3 -package offline
4 -
5 -import (
6 - "context"
7 -
8 - blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
9 - cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
10 - exchange "gx/ipfs/QmdcAXgEHUueP4A7b5hjabKn2EooeHgMreMvFC249dGCgc/go-ipfs-exchange-interface"
11 - blocks "gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
12 -)
13 -
14 -func Exchange(bs blockstore.Blockstore) exchange.Interface {
15 - return &offlineExchange{bs: bs}
16 -}
17 -
18 -// offlineExchange implements the Exchange interface but doesn't return blocks.
19 -// For use in offline mode.
20 -type offlineExchange struct {
21 - bs blockstore.Blockstore
22 -}
23 -
24 -// GetBlock returns nil to signal that a block could not be retrieved for the
25 -// given key.
26 -// NB: This function may return before the timeout expires.
27 -func (e *offlineExchange) GetBlock(_ context.Context, k *cid.Cid) (blocks.Block, error) {
28 - return e.bs.Get(k)
29 -}
30 -
31 -// HasBlock always returns nil.
32 -func (e *offlineExchange) HasBlock(b blocks.Block) error {
33 - return e.bs.Put(b)
34 -}
35 -
36 -// Close always returns nil.
37 -func (_ *offlineExchange) Close() error {
38 - // NB: exchange doesn't own the blockstore's underlying datastore, so it is
39 - // not responsible for closing it.
40 - return nil
41 -}
42 -
43 -func (e *offlineExchange) GetBlocks(ctx context.Context, ks []*cid.Cid) (<-chan blocks.Block, error) {
44 - out := make(chan blocks.Block)
45 - go func() {
46 - defer close(out)
47 - var misses []*cid.Cid
48 - for _, k := range ks {
49 - hit, err := e.bs.Get(k)
50 - if err != nil {
51 - misses = append(misses, k)
52 - // a long line of misses should abort when context is cancelled.
53 - select {
54 - // TODO case send misses down channel
55 - case <-ctx.Done():
56 - return
57 - default:
58 - continue
59 - }
60 - }
61 - select {
62 - case out <- hit:
63 - case <-ctx.Done():
64 - return
65 - }
66 - }
67 - }()
68 - return out, nil
69 -}
70 -
71 -func (e *offlineExchange) IsOnline() bool {
72 - return false
73 -}
exchange/offline/offline_test.go deleted
-79
@@ -1,79 +0,0 @@
1 -package offline
2 -
3 -import (
4 - "context"
5 - "testing"
6 -
7 - u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
8 - ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
9 - ds_sync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
10 - blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
11 - cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
12 - blocks "gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
13 - blocksutil "gx/ipfs/Qmf951DP11mCoctpyF3ZppPZdo2oAxuNi2vnkVDgHJ8Fqk/go-ipfs-blocksutil"
14 -)
15 -
16 -func TestBlockReturnsErr(t *testing.T) {
17 - off := Exchange(bstore())
18 - c := cid.NewCidV0(u.Hash([]byte("foo")))
19 - _, err := off.GetBlock(context.Background(), c)
20 - if err != nil {
21 - return // as desired
22 - }
23 - t.Fail()
24 -}
25 -
26 -func TestHasBlockReturnsNil(t *testing.T) {
27 - store := bstore()
28 - ex := Exchange(store)
29 - block := blocks.NewBlock([]byte("data"))
30 -
31 - err := ex.HasBlock(block)
32 - if err != nil {
33 - t.Fail()
34 - }
35 -
36 - if _, err := store.Get(block.Cid()); err != nil {
37 - t.Fatal(err)
38 - }
39 -}
40 -
41 -func TestGetBlocks(t *testing.T) {
42 - store := bstore()
43 - ex := Exchange(store)
44 - g := blocksutil.NewBlockGenerator()
45 -
46 - expected := g.Blocks(2)
47 -
48 - for _, b := range expected {
49 - if err := ex.HasBlock(b); err != nil {
50 - t.Fail()
51 - }
52 - }
53 -
54 - request := func() []*cid.Cid {
55 - var ks []*cid.Cid
56 -
57 - for _, b := range expected {
58 - ks = append(ks, b.Cid())
59 - }
60 - return ks
61 - }()
62 -
63 - received, err := ex.GetBlocks(context.Background(), request)
64 - if err != nil {
65 - t.Fatal(err)
66 - }
67 -
68 - var count int
69 - for range received {
70 - count++
71 - }
72 - if len(expected) != count {
73 - t.Fail()
74 - }
75 -}
76 -
77 -func bstore() blockstore.Blockstore {
78 - return blockstore.NewBlockstore(ds_sync.MutexWrap(ds.NewMapDatastore()))
79 -}
merkledag/merkledag_test.go
+1 -1
@@ -15,12 +15,12 @@ import (
15
16 bserv "github.com/ipfs/go-ipfs/blockservice"
17 bstest "github.com/ipfs/go-ipfs/blockservice/test"
18 - offline "github.com/ipfs/go-ipfs/exchange/offline"
18 . "github.com/ipfs/go-ipfs/merkledag"
19 mdpb "github.com/ipfs/go-ipfs/merkledag/pb"
20 dstest "github.com/ipfs/go-ipfs/merkledag/test"
21
22 u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
23 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
24 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
25 ipld "gx/ipfs/Qme5bWv7wtjUNGsK2BNGVUFPKiuxWrsqrtvYwCLRw8YFES/go-ipld-format"
26 blocks "gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
merkledag/test/utils.go
+1 -1
@@ -2,9 +2,9 @@ package mdutils
2
3 import (
4 bsrv "github.com/ipfs/go-ipfs/blockservice"
5 - "github.com/ipfs/go-ipfs/exchange/offline"
5 dag "github.com/ipfs/go-ipfs/merkledag"
6
7 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
8 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
9 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
10 blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
merkledag/utils/utils.go
+1 -1
@@ -5,10 +5,10 @@ import (
5 "errors"
6
7 bserv "github.com/ipfs/go-ipfs/blockservice"
8 - offline "github.com/ipfs/go-ipfs/exchange/offline"
8 dag "github.com/ipfs/go-ipfs/merkledag"
9 path "github.com/ipfs/go-ipfs/path"
10
11 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
12 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
13 syncds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
14 bstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
mfs/mfs_test.go
+1 -1
@@ -15,7 +15,6 @@ import (
15 "time"
16
17 bserv "github.com/ipfs/go-ipfs/blockservice"
18 - offline "github.com/ipfs/go-ipfs/exchange/offline"
18 importer "github.com/ipfs/go-ipfs/importer"
19 dag "github.com/ipfs/go-ipfs/merkledag"
20 "github.com/ipfs/go-ipfs/path"
@@ -23,6 +22,7 @@ import (
22 uio "github.com/ipfs/go-ipfs/unixfs/io"
23
24 u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
25 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
26 chunker "gx/ipfs/QmWo8jYc19ppG7YoTsrr2kEtLRbARTJho5oNXFTR6B7Peq/go-ipfs-chunker"
27 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
28 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
package.json
+6
@@ -599,6 +599,12 @@
599 "hash": "Qmf951DP11mCoctpyF3ZppPZdo2oAxuNi2vnkVDgHJ8Fqk",
600 "name": "go-ipfs-blocksutil",
601 "version": "0.0.1"
602 + },
603 + {
604 + "author": "hsanjuan",
605 + "hash": "QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc",
606 + "name": "go-ipfs-exchange-offline",
607 + "version": "0.0.1"
608 }
609 ],
610 "gxVersion": "0.10.0",
pin/gc/gc.go
+1 -1
@@ -8,12 +8,12 @@ import (
8 "strings"
9
10 bserv "github.com/ipfs/go-ipfs/blockservice"
11 - offline "github.com/ipfs/go-ipfs/exchange/offline"
11 dag "github.com/ipfs/go-ipfs/merkledag"
12 pin "github.com/ipfs/go-ipfs/pin"
13 "github.com/ipfs/go-ipfs/thirdparty/verifcid"
14
15 logging "gx/ipfs/QmRb5jh8z2E8hMGN2tkvs1yHynUanqnZ3UeKwgN1i9P1F8/go-log"
16 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
17 dstore "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
18 bstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
19 cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
pin/pin_test.go
+1 -1
@@ -6,10 +6,10 @@ import (
6 "time"
7
8 bs "github.com/ipfs/go-ipfs/blockservice"
9 - "github.com/ipfs/go-ipfs/exchange/offline"
9 mdag "github.com/ipfs/go-ipfs/merkledag"
10
11 util "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
12 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
13 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
14 dssync "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/sync"
15 blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"
pin/set_test.go
+1 -1
@@ -6,9 +6,9 @@ import (
6 "testing"
7
8 bserv "github.com/ipfs/go-ipfs/blockservice"
9 - offline "github.com/ipfs/go-ipfs/exchange/offline"
9 dag "github.com/ipfs/go-ipfs/merkledag"
10
11 + offline "gx/ipfs/QmWM5HhdG5ZQNyHQ5XhMdGmV9CvLpFynQfGpTxN2MEM7Lc/go-ipfs-exchange-offline"
12 ds "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore"
13 dsq "gx/ipfs/QmXRKBQA4wXP7xWbFiZsR1GP4HV6wMDQ1aWFxZZ4uBcPX9/go-datastore/query"
14 blockstore "gx/ipfs/QmaG4DZ4JaqEfvPWt5nPPgoTzhc1tr1T3f4Nu9Jpdm8ymY/go-ipfs-blockstore"