opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-01 19:24:14 +08:00
Code Issues Projects Releases Wiki Activity

daemon listener to http serve code

Browse Source
This commit is contained in:
verokarhu
2014-09-16 20:05:48 +03:00
parent 8eb95faf50
commit d894d6382f
1 changed files with 14 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
cmd/ipfs/serve.go
View File

@ -3,8 +3,10 @@ package main
import ( import (
"errors" "errors"
"fmt" "fmt"
"github.com/gonuts/flag"
"github.com/jbenet/commander" "github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/gonuts/flag"
"github.com/jbenet/go-ipfs/Godeps/_workspace/src/github.com/jbenet/commander"
"github.com/jbenet/go-ipfs/daemon"
h "github.com/jbenet/go-ipfs/server/http" h "github.com/jbenet/go-ipfs/server/http"
) )
@ -36,13 +38,20 @@ func serveHttpCmd(c *commander.Command, _ []string) error {
return errors.New("invalid port number") return errors.New("invalid port number")
} }
hostname := c.Flag.Lookup("hostname").Value.Get().(string) n, err := localNode(true)
n, err := localNode()
if err != nil { if err != nil {
return err return err
} }
fmt.Println("starting new daemon listener...")
dl, err := daemon.NewDaemonListener(n, "localhost:12345")
if err != nil {
return err
}
go dl.Listen()
defer dl.Close()
hostname := c.Flag.Lookup("hostname").Value.Get().(string)
address := fmt.Sprintf("%s:%d", hostname, port) address := fmt.Sprintf("%s:%d", hostname, port)
fmt.Printf("Serving on %s\n", address) fmt.Printf("Serving on %s\n", address)