Commit 5cfe7b83 authored by hannahhoward's avatar hannahhoward

style(imports): fix imports

parent 09368acf
...@@ -3,11 +3,11 @@ package testnet ...@@ -3,11 +3,11 @@ package testnet
import ( import (
"context" "context"
gsnet "github.com/ipfs/go-graphsync/network"
"github.com/libp2p/go-libp2p-core/peer" "github.com/libp2p/go-libp2p-core/peer"
tnet "github.com/libp2p/go-libp2p-testing/net" tnet "github.com/libp2p/go-libp2p-testing/net"
mockpeernet "github.com/libp2p/go-libp2p/p2p/net/mock" mockpeernet "github.com/libp2p/go-libp2p/p2p/net/mock"
gsnet "github.com/ipfs/go-graphsync/network"
) )
type peernet struct { type peernet struct {
......
...@@ -36,8 +36,8 @@ func Traverse(ctx context.Context, loader ipld.Loader, chooser traversal.LinkTar ...@@ -36,8 +36,8 @@ func Traverse(ctx context.Context, loader ipld.Loader, chooser traversal.LinkTar
node := nb.Build() node := nb.Build()
return traversal.Progress{ return traversal.Progress{
Cfg: &traversal.Config{ Cfg: &traversal.Config{
Ctx: ctx, Ctx: ctx,
LinkLoader: loader, LinkLoader: loader,
LinkTargetNodePrototypeChooser: chooser, LinkTargetNodePrototypeChooser: chooser,
}, },
}.WalkAdv(node, s, fn) }.WalkAdv(node, s, fn)
......
...@@ -167,8 +167,8 @@ func (t *traverser) start() { ...@@ -167,8 +167,8 @@ func (t *traverser) start() {
} }
err = traversal.Progress{ err = traversal.Progress{
Cfg: &traversal.Config{ Cfg: &traversal.Config{
Ctx: t.ctx, Ctx: t.ctx,
LinkLoader: loader, LinkLoader: loader,
LinkTargetNodePrototypeChooser: t.chooser, LinkTargetNodePrototypeChooser: t.chooser,
}, },
}.WalkAdv(nd, sel, t.visitor) }.WalkAdv(nd, sel, t.visitor)
......
...@@ -7,11 +7,11 @@ import ( ...@@ -7,11 +7,11 @@ import (
"github.com/ipld/go-ipld-prime/codec/dagcbor" "github.com/ipld/go-ipld-prime/codec/dagcbor"
"github.com/ipld/go-ipld-prime/fluent" "github.com/ipld/go-ipld-prime/fluent"
cidlink "github.com/ipld/go-ipld-prime/linking/cid"
basicnode "github.com/ipld/go-ipld-prime/node/basic"
"github.com/stretchr/testify/require" "github.com/stretchr/testify/require"
"github.com/ipfs/go-graphsync/testutil" "github.com/ipfs/go-graphsync/testutil"
cidlink "github.com/ipld/go-ipld-prime/linking/cid"
basicnode "github.com/ipld/go-ipld-prime/node/basic"
) )
func TestDecodeEncodeMetadata(t *testing.T) { func TestDecodeEncodeMetadata(t *testing.T) {
......
...@@ -36,15 +36,15 @@ type ExecutionEnv struct { ...@@ -36,15 +36,15 @@ type ExecutionEnv struct {
// RequestExecution are parameters for a single request execution // RequestExecution are parameters for a single request execution
type RequestExecution struct { type RequestExecution struct {
Ctx context.Context Ctx context.Context
P peer.ID P peer.ID
NetworkError chan error NetworkError chan error
Request gsmsg.GraphSyncRequest Request gsmsg.GraphSyncRequest
LastResponse *atomic.Value LastResponse *atomic.Value
DoNotSendCids *cid.Set DoNotSendCids *cid.Set
NodePrototypeChooser traversal.LinkTargetNodePrototypeChooser NodePrototypeChooser traversal.LinkTargetNodePrototypeChooser
ResumeMessages chan []graphsync.ExtensionData ResumeMessages chan []graphsync.ExtensionData
PauseMessages chan struct{} PauseMessages chan struct{}
} }
// Start begins execution of a request in a go routine // Start begins execution of a request in a go routine
......
...@@ -430,13 +430,13 @@ func (ree *requestExecutionEnv) requestExecution() (chan graphsync.ResponseProgr ...@@ -430,13 +430,13 @@ func (ree *requestExecutionEnv) requestExecution() (chan graphsync.ResponseProgr
TerminateRequest: ree.terminateRequest, TerminateRequest: ree.terminateRequest,
Loader: ree.fal.AsyncLoad, Loader: ree.fal.AsyncLoad,
}.Start(executor.RequestExecution{ }.Start(executor.RequestExecution{
Ctx: ree.ctx, Ctx: ree.ctx,
P: ree.p, P: ree.p,
LastResponse: &lastResponse, LastResponse: &lastResponse,
Request: ree.request, Request: ree.request,
DoNotSendCids: ree.doNotSendCids, DoNotSendCids: ree.doNotSendCids,
NodePrototypeChooser: ree.nodeStyleChooser, NodePrototypeChooser: ree.nodeStyleChooser,
ResumeMessages: ree.resumeMessages, ResumeMessages: ree.resumeMessages,
PauseMessages: ree.pauseMessages, PauseMessages: ree.pauseMessages,
}) })
} }
...@@ -338,15 +338,15 @@ func (nrm *newRequestMessage) setupRequest(requestID graphsync.RequestID, rm *Re ...@@ -338,15 +338,15 @@ func (nrm *newRequestMessage) setupRequest(requestID graphsync.RequestID, rm *Re
Loader: rm.asyncLoader.AsyncLoad, Loader: rm.asyncLoader.AsyncLoad,
}.Start( }.Start(
executor.RequestExecution{ executor.RequestExecution{
Ctx: ctx, Ctx: ctx,
P: p, P: p,
Request: request, Request: request,
NetworkError: networkError, NetworkError: networkError,
LastResponse: lastResponse, LastResponse: lastResponse,
DoNotSendCids: doNotSendCids, DoNotSendCids: doNotSendCids,
NodePrototypeChooser: hooksResult.CustomChooser, NodePrototypeChooser: hooksResult.CustomChooser,
ResumeMessages: resumeMessages, ResumeMessages: resumeMessages,
PauseMessages: pauseMessages, PauseMessages: pauseMessages,
}) })
return incoming, incomingError return incoming, incomingError
} }
......
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