Skip to content

Commit f0387ae

Browse files
authored
Merge pull request ipfs/kubo#6162 from ipfs/feat/dig
DI-based core.NewNode This commit was moved from ipfs/kubo@c3a7bc2
2 parents 7b38742 + 6077854 commit f0387ae

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

gateway/core/corehttp/corehttp.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ func Serve(node *core.IpfsNode, lis net.Listener, options ...ServeOption) error
8585
}
8686

8787
select {
88-
case <-node.Process().Closing():
88+
case <-node.Process.Closing():
8989
return fmt.Errorf("failed to start server, process closing")
9090
default:
9191
}
@@ -95,15 +95,15 @@ func Serve(node *core.IpfsNode, lis net.Listener, options ...ServeOption) error
9595
}
9696

9797
var serverError error
98-
serverProc := node.Process().Go(func(p goprocess.Process) {
98+
serverProc := node.Process.Go(func(p goprocess.Process) {
9999
serverError = server.Serve(lis)
100100
})
101101

102102
// wait for server to exit.
103103
select {
104104
case <-serverProc.Closed():
105105
// if node being closed before server exits, close server
106-
case <-node.Process().Closing():
106+
case <-node.Process.Closing():
107107
log.Infof("server at %s terminating...", addr)
108108

109109
warnProc := periodicproc.Tick(5*time.Second, func(_ goprocess.Process) {

gateway/core/corehttp/gateway_handler.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,7 @@ import (
1414

1515
"github.com/ipfs/go-ipfs/core"
1616
"github.com/ipfs/go-ipfs/dagutils"
17+
"github.com/ipfs/go-ipfs/namesys/resolve"
1718

1819
"github.com/dustin/go-humanize"
1920
"github.com/ipfs/go-cid"
@@ -423,7 +424,7 @@ func (i *gatewayHandler) putHandler(w http.ResponseWriter, r *http.Request) {
423424
}
424425

425426
var newcid cid.Cid
426-
rnode, err := core.Resolve(ctx, i.node.Namesys, i.node.Resolver, rootPath)
427+
rnode, err := resolve.Resolve(ctx, i.node.Namesys, i.node.Resolver, rootPath)
427428
switch ev := err.(type) {
428429
case resolver.ErrNoLink:
429430
// ev.Node < node where resolve failed

0 commit comments

Comments
 (0)