diff --git a/core/commands/pubsub.go b/core/commands/pubsub.go index 172bac07737a..eea6b7e6f470 100644 --- a/core/commands/pubsub.go +++ b/core/commands/pubsub.go @@ -4,12 +4,11 @@ import ( "bytes" "fmt" "io" - "reflect" - - u "gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util" cmds "github.com/ipfs/go-ipfs/commands" - floodsub "github.com/whyrusleeping/go-floodsub" + + floodsub "gx/ipfs/QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH/floodsub" + u "gx/ipfs/QmZNVWh8LLjAavuQ2JXuFmuYH3C11xo988vSgp7UQrTRj1/go-ipfs-util" ) var PubsubCmd = &cmds.Command{ @@ -71,7 +70,6 @@ var PubsubSubCmd = &cmds.Command{ cmds.Text: func(res cmds.Response) (io.Reader, error) { outChan, ok := res.Output().(<-chan interface{}) if !ok { - fmt.Println(reflect.TypeOf(res.Output())) return nil, u.ErrCast() } diff --git a/core/core.go b/core/core.go index f0776402dce7..18a93f5f1851 100644 --- a/core/core.go +++ b/core/core.go @@ -17,12 +17,12 @@ import ( "time" diag "github.com/ipfs/go-ipfs/diagnostics" - floodsub "github.com/whyrusleeping/go-floodsub" goprocess "gx/ipfs/QmSF8fPo3jgVBAy8fpdjjYqgG87dkJgUprRBHRd2tmfgpP/goprocess" mamask "gx/ipfs/QmSMZwvs3n4GBikZ7hKzT17c3bk65FmyZo2JqtJ16swqCv/multiaddr-filter" pstore "gx/ipfs/QmSZi9ygLohBUGyHMqE5N6eToPwqcg7bZQTULeVLFu7Q6d/go-libp2p-peerstore" logging "gx/ipfs/QmSpJByNKFX1sCsHBEp3R73FL4NF6FnQTEGyNAXHm2GS52/go-log" b58 "gx/ipfs/QmT8rehPR3F6bmwL6zjUN8XpiDBFFpMP2myPdC6ApsWfJf/go-base58" + floodsub "gx/ipfs/QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH/floodsub" ic "gx/ipfs/QmVoi5es8D5fNHZDqoW6DgDAEPEV5hQp8GBz161vZXiwpQ/go-libp2p-crypto" peer "gx/ipfs/QmWtbQU15LaB5B1JC2F7TV9P4K88vD3PpA4AJrwfCjhML8/go-libp2p-peer" ma "gx/ipfs/QmYzDkkgAEmrcNzFCiYo6L1dTX4EAG1gZkbtdbd9trL4vd/go-multiaddr" diff --git a/package.json b/package.json index 0f2339c6cc79..b1b5b28c1810 100644 --- a/package.json +++ b/package.json @@ -233,6 +233,12 @@ "hash": "QmUHmMGmcwCrjHQHcYhBnqGCSWs5pBSMbGZmfwavETR1gg", "name": "go-ds-leveldb", "version": "1.0.0" + }, + { + "author": "whyrusleeping", + "hash": "QmTP5RSsmZacEFanuBhnDE3RC3aqGAoozF9ZmKqcHa8EKH", + "name": "floodsub", + "version": "0.2.0" } ], "gxVersion": "0.4.0",