Initial structure

.circleci/config.yml

@@ -3,10 +3,19 @@ orbs:
   go: gotest/tools@0.0.9
 
 
+jobs:
+  mod-tidy-check:
+    executor: go/circleci-golang
+    steps:
+      - go/install-ssh
+      - checkout
+      - go/mod-tidy-check
+
 workflows:
   version: 2
   ci:
     jobs:
       - go/lint
       - go/test:
           executor: go/circleci-golang
+      - mod-tidy-check

.golangci.yml

@@ -0,0 +1,21 @@
+linters:
+  disable-all: true
+  enable:
+    - vet
+    - gofmt
+    - misspell
+    - goconst
+    - golint
+    - errcheck
+    - unconvert
+    - staticcheck
+    - varcheck
+    - structcheck
+    - deadcode
+
+issues:
+  exclude-use-default: false
+
+linters-settings:
+  goconst:
+    min-occurrences: 6

api/api.go

@@ -0,0 +1,76 @@
+package api
+
+import (
+	"context"
+
+	"github.com/libp2p/go-libp2p-core/peer"
+)
+
+type Version struct {
+	Version string
+
+	// TODO: git commit / os / genesis cid?
+}
+
+type API interface {
+	// chain
+
+	// // head
+
+	// messages
+
+	// // wait
+	// // send
+	// // status
+	// // mpool
+	// // // ls / show / rm
+
+	// dag
+
+	// // get block
+	// // (cli: show / info)
+
+	// network
+
+	// // peers
+	// // ping
+	// // connect
+
+	// Struct
+
+	// miner
+
+	// // create
+	// // owner
+	// // power
+	// // set-price
+	// // set-perrid
+
+	// // UX ?
+
+	// wallet
+
+	// // import
+	// // export
+	// // list
+	// // (on cli - cmd to list associations)
+
+	// dht
+
+	// // need ?
+
+	// paych
+
+	// // todo
+
+	// retrieval
+
+	// // retrieve piece
+
+	// Other
+
+	// // ID (on cli - print with other info)
+
+	ID(context.Context) (peer.ID, error)
+	Version(context.Context) (Version, error)
+}

api/client/client.go

@@ -0,0 +1,12 @@
+package client
+
+import (
+	"github.com/filecoin-project/go-lotus/api"
+	"github.com/filecoin-project/go-lotus/rpclib"
+)
+
+func NewRPC(addr string) api.API {
+	var res api.Struct
+	rpclib.NewClient(addr, "Filecoin", &res.Internal)
+	return &res
+}

api/struct.go

@@ -0,0 +1,24 @@
+package api
+
+import (
+	"context"
+
+	"github.com/libp2p/go-libp2p-core/peer"
+)
+
+type Struct struct {
+	Internal struct {
+		ID      func(context.Context) (peer.ID, error)
+		Version func(context.Context) (Version, error)
+	}
+}
+
+func (c *Struct) ID(ctx context.Context) (peer.ID, error) {
+	return c.Internal.ID(ctx)
+}
+
+func (c *Struct) Version(ctx context.Context) (Version, error) {
+	return c.Internal.Version(ctx)
+}
+
+var _ API = &Struct{}

api/test/test.go

@@ -0,0 +1,35 @@
+package test
+
+import (
+	"context"
+	"testing"
+
+	"github.com/filecoin-project/go-lotus/api"
+	"github.com/filecoin-project/go-lotus/build"
+)
+
+type NodeBuilder func() api.API
+type testSuite struct {
+	makeNode NodeBuilder
+}
+
+func TestApis(t *testing.T, nb NodeBuilder) {
+	ts := testSuite{
+		makeNode: nb,
+	}
+
+	t.Run("version", ts.testVersion)
+}
+
+func (ts *testSuite) testVersion(t *testing.T) {
+	ctx := context.Background()
+	fc := ts.makeNode()
+
+	v, err := fc.Version(ctx)
+	if err != nil {
+		t.Fatal(err)
+	}
+	if v.Version != build.Version {
+		t.Error("Version didn't work properly")
+	}
+}

build/version.go

@@ -0,0 +1,3 @@
+package build
+
+const Version = "0.0.0"

cli/cmd.go

@@ -0,0 +1,9 @@
+package cli
+
+import (
+	"gopkg.in/urfave/cli.v2"
+)
+
+var Commands = []*cli.Command{
+	versionCmd,
+}

cli/version.go

@@ -0,0 +1,16 @@
+package cli
+
+import (
+	"gopkg.in/urfave/cli.v2"
+)
+
+var versionCmd = &cli.Command{
+	Name:  "version",
+	Usage: "Print version",
+	Action: func(context *cli.Context) error {
+		// TODO: print more useful things
+
+		cli.VersionPrinter(context)
+		return nil
+	},
+}

cmd/lotus/main.go

@@ -0,0 +1,31 @@
+package main
+
+import (
+	"log"
+	"os"
+
+	"gopkg.in/urfave/cli.v2"
+
+	"github.com/filecoin-project/go-lotus/build"
+	lcli "github.com/filecoin-project/go-lotus/cli"
+	"github.com/filecoin-project/go-lotus/daemon"
+)
+
+func main() {
+	local := []*cli.Command{
+		daemon.Cmd,
+	}
+
+	app := &cli.App{
+		Name:    "lotus",
+		Usage:   "Filecoin decentralized storage network client",
+		Version: build.Version,
+
+		Commands: append(local, lcli.Commands...),
+	}
+
+	if err := app.Run(os.Args); err != nil {
+		log.Println(err)
+		return
+	}
+}

daemon/cmd.go

@@ -0,0 +1,24 @@
+package daemon
+
+import (
+	goctx "context"
+
+	"gopkg.in/urfave/cli.v2"
+
+	"github.com/filecoin-project/go-lotus/node"
+)
+
+var Cmd = &cli.Command{
+	Name:  "daemon",
+	Usage: "Start a lotus daemon process",
+	Action: func(context *cli.Context) error {
+		ctx := goctx.Background()
+
+		api, err := node.New(ctx)
+		if err != nil {
+			return err
+		}
+
+		return serveRPC(api)
+	},
+}

daemon/rpc.go

@@ -0,0 +1,15 @@
+package daemon
+
+import (
+	"net/http"
+
+	"github.com/filecoin-project/go-lotus/api"
+	"github.com/filecoin-project/go-lotus/rpclib"
+)
+
+func serveRPC(api api.API) error {
+	rpcServer := rpclib.NewServer()
+	rpcServer.Register("Filecoin", api)
+	http.Handle("/rpc/v0", rpcServer)
+	return http.ListenAndServe(":1234", http.DefaultServeMux)
+}

go.mod

@@ -0,0 +1,35 @@
+module github.com/filecoin-project/go-lotus
+
+go 1.12
+
+require (
+	github.com/ipfs/go-datastore v0.0.5
+	github.com/ipfs/go-ipfs-routing v0.1.0
+	github.com/ipfs/go-log v0.0.1
+	github.com/libp2p/go-libp2p v0.2.0
+	github.com/libp2p/go-libp2p-circuit v0.1.0
+	github.com/libp2p/go-libp2p-connmgr v0.1.0
+	github.com/libp2p/go-libp2p-core v0.0.6
+	github.com/libp2p/go-libp2p-discovery v0.1.0
+	github.com/libp2p/go-libp2p-kad-dht v0.1.1
+	github.com/libp2p/go-libp2p-mplex v0.2.1
+	github.com/libp2p/go-libp2p-peerstore v0.1.1
+	github.com/libp2p/go-libp2p-pnet v0.1.0
+	github.com/libp2p/go-libp2p-pubsub v0.1.0
+	github.com/libp2p/go-libp2p-quic-transport v0.1.1
+	github.com/libp2p/go-libp2p-record v0.1.0
+	github.com/libp2p/go-libp2p-routing-helpers v0.1.0
+	github.com/libp2p/go-libp2p-secio v0.1.0
+	github.com/libp2p/go-libp2p-tls v0.1.0
+	github.com/libp2p/go-libp2p-yamux v0.2.1
+	github.com/libp2p/go-maddr-filter v0.0.4
+	github.com/multiformats/go-multiaddr v0.0.4
+	github.com/multiformats/go-multihash v0.0.5
+	github.com/whyrusleeping/multiaddr-filter v0.0.0-20160516205228-e903e4adabd7
+	go.uber.org/atomic v1.4.0 // indirect
+	go.uber.org/dig v1.7.0 // indirect
+	go.uber.org/fx v1.9.0
+	go.uber.org/goleak v0.10.0 // indirect
+	go.uber.org/multierr v1.1.0 // indirect
+	gopkg.in/urfave/cli.v2 v2.0.0-20180128182452-d3ae77c26ac8
+)