mirror of
https://github.com/ipfs/kubo.git
synced 2026-02-21 18:37:45 +08:00
28 lines
789 B
Go
28 lines
789 B
Go
package node
|
|
|
|
import (
|
|
"github.com/ipfs/go-graphsync"
|
|
gsimpl "github.com/ipfs/go-graphsync/impl"
|
|
"github.com/ipfs/go-graphsync/ipldbridge"
|
|
"github.com/ipfs/go-graphsync/network"
|
|
"github.com/ipfs/go-graphsync/storeutil"
|
|
"github.com/ipfs/go-ipfs-blockstore"
|
|
libp2p "github.com/libp2p/go-libp2p-core"
|
|
"go.uber.org/fx"
|
|
|
|
"github.com/ipfs/go-ipfs/core/node/helpers"
|
|
)
|
|
|
|
// Graphsync constructs a graphsync
|
|
func Graphsync(lc fx.Lifecycle, mctx helpers.MetricsCtx, host libp2p.Host, bs blockstore.GCBlockstore) graphsync.GraphExchange {
|
|
ctx := helpers.LifecycleCtx(mctx, lc)
|
|
|
|
network := network.NewFromLibp2pHost(host)
|
|
ipldBridge := ipldbridge.NewIPLDBridge()
|
|
return gsimpl.New(ctx,
|
|
network, ipldBridge,
|
|
storeutil.LoaderForBlockstore(bs),
|
|
storeutil.StorerForBlockstore(bs),
|
|
)
|
|
}
|