From 8af80169c0fe2786446f766b2ae8cc94db8c8749 Mon Sep 17 00:00:00 2001 From: Jakub Sztandera Date: Mon, 17 Feb 2020 18:15:30 +0100 Subject: [PATCH] Add graphsync Signed-off-by: Jakub Sztandera --- node/builder.go | 2 ++ node/modules/chain.go | 13 +++++++++++++ node/modules/dtypes/storage.go | 1 + 3 files changed, 16 insertions(+) diff --git a/node/builder.go b/node/builder.go index b42b93774..fa258f797 100644 --- a/node/builder.go +++ b/node/builder.go @@ -91,6 +91,7 @@ const ( RunHelloKey RunBlockSyncKey + RunChainGraphsync RunPeerMgrKey HandleIncomingBlocksKey @@ -227,6 +228,7 @@ func Online() Option { Override(RunHelloKey, modules.RunHello), Override(RunBlockSyncKey, modules.RunBlockSync), + Override(RunChainGraphsync, modules.ChainGraphsync), Override(RunPeerMgrKey, modules.RunPeerMgr), Override(HandleIncomingBlocksKey, modules.HandleIncomingBlocks), diff --git a/node/modules/chain.go b/node/modules/chain.go index b70cb6892..24104425e 100644 --- a/node/modules/chain.go +++ b/node/modules/chain.go @@ -9,6 +9,10 @@ import ( "github.com/ipfs/go-blockservice" "github.com/ipfs/go-car" "github.com/ipfs/go-datastore" + graphsync "github.com/ipfs/go-graphsync/impl" + "github.com/ipfs/go-graphsync/ipldbridge" + gsnet "github.com/ipfs/go-graphsync/network" + "github.com/ipfs/go-graphsync/storeutil" blockstore "github.com/ipfs/go-ipfs-blockstore" "github.com/libp2p/go-libp2p-core/host" "github.com/libp2p/go-libp2p-core/routing" @@ -73,6 +77,15 @@ func ChainBlockservice(bs dtypes.ChainBlockstore, rem dtypes.ChainExchange) dtyp return blockservice.New(bs, rem) } +func ChainGraphsync(mctx helpers.MetricsCtx, lc fx.Lifecycle, ibs dtypes.ChainGCBlockstore, h host.Host) dtypes.ClientGraphsync { + graphsyncNetwork := gsnet.NewFromLibp2pHost(h) + ipldBridge := ipldbridge.NewIPLDBridge() + loader := storeutil.LoaderForBlockstore(ibs) + gs := graphsync.New(helpers.LifecycleCtx(mctx, lc), graphsyncNetwork, ipldBridge, loader, nil) + + return gs +} + func ChainStore(lc fx.Lifecycle, bs dtypes.ChainBlockstore, ds dtypes.MetadataDS, syscalls *types.VMSyscalls) *store.ChainStore { chain := store.NewChainStore(bs, ds, syscalls) diff --git a/node/modules/dtypes/storage.go b/node/modules/dtypes/storage.go index 24d658ebf..1e6f74f23 100644 --- a/node/modules/dtypes/storage.go +++ b/node/modules/dtypes/storage.go @@ -24,6 +24,7 @@ type ChainGCLocker blockstore.GCLocker type ChainGCBlockstore blockstore.GCBlockstore type ChainExchange exchange.Interface type ChainBlockService bserv.BlockService +type ChainGraphsync graphsync.GraphExchange type ClientFilestore *filestore.Filestore type ClientBlockstore blockstore.Blockstore