feat(core): initial contact flow implementation (#40)

core/api/p2p/event.go

@@ -0,0 +1,19 @@
+package p2p
+
+import "time"
+
+func NewOutgoingEvent(sender, receiver string, kind Kind) *Event {
+	return &Event{
+		SenderAPIVersion: Version,
+		CreatedAt:        time.Now(),
+		Kind:             kind,
+		SenderID:         sender,
+		ReceiverID:       receiver,
+		Direction:        Event_Outgoing,
+	}
+}
+
+func (e *Event) Validate() error {
+	// FIXME: generate validation
+	return nil
+}

core/api/p2p/event.proto

@@ -56,10 +56,8 @@ message Event {
   // Attributes is a nested protobuf message containing per-event-type additional attributes.
   bytes attributes = 14;
 
-  oneof context {
-    // ConversationID needs to be set if the event belongs to a conversation.
-    string conversation_id = 15 [(gogoproto.customname) = "ConversationID"];
-  }
+  // ConversationID needs to be set if the event belongs to a conversation.
+  string conversation_id = 15 [(gogoproto.customname) = "ConversationID"];
 
   //
   // enums

core/api/p2p/kind.go

@@ -0,0 +1,12 @@
+package p2p
+
+import "github.com/gogo/protobuf/proto"
+
+func (e *Event) SetAttrs(attrs proto.Message) error {
+	raw, err := proto.Marshal(attrs)
+	if err != nil {
+		return err
+	}
+	e.Attributes = raw
+	return nil
+}

core/cmd/berty/client.go

@@ -46,7 +46,6 @@ func newClientCommand() *cobra.Command {
 }
 
 func clientUnary(opts *clientOptions) error {
-	fmt.Println(opts.endpoint)
 	ctx := context.Background()
 
 	zap.L().Debug("dialing node", zap.String("addr", opts.nodeAddress), zap.String("protocol", "gRPC"))

core/entity/contact.go

@@ -0,0 +1,16 @@
+package entity
+
+func (c *Contact) Validate() error {
+	if c == nil {
+		return ErrInvalidEntity
+	}
+	return nil
+}
+
+func (c *Contact) Filtered() *Contact {
+	return &Contact{
+		DisplayName:   c.DisplayName,
+		DisplayStatus: c.DisplayStatus,
+		// FIXME: share sigchain
+	}
+}

core/entity/errors.go

@@ -0,0 +1,7 @@
+package entity
+
+import "errors"
+
+var (
+	ErrInvalidEntity = errors.New("invalid entity")
+)

core/node/errors.go

@@ -0,0 +1,9 @@
+package node
+
+import "errors"
+
+var (
+	ErrInvalidInput        = errors.New("invalid input")
+	ErrNotImplemented      = errors.New("not implemented")
+	ErrEntityAlreadyExists = errors.New("entity already exists")
+)

core/node/node.go

@@ -1,15 +1,30 @@
 package node
 
-import "github.com/jinzhu/gorm"
+import (
+	"fmt"
+
+	"github.com/jinzhu/gorm"
+	"github.com/pkg/errors"
+	uuid "github.com/satori/go.uuid"
+
+	"github.com/berty/berty/core/api/p2p"
+	"github.com/berty/berty/core/entity"
+)
 
 // Node is the top-level object of a Berty peer
 type Node struct {
-	db *gorm.DB
+	sql            *gorm.DB
+	myself         *entity.Contact
+	outgoingEvents chan *p2p.Event
 }
 
 // New initializes a new Node object
 func New(opts ...NewNodeOption) *Node {
-	n := &Node{}
+	n := &Node{
+		// FIXME: fetch myself from db
+		myself:         &entity.Contact{ID: "init"},
+		outgoingEvents: make(chan *p2p.Event, 100),
+	}
 
 	for _, opt := range opts {
 		opt(n)
@@ -19,8 +34,24 @@ func New(opts ...NewNodeOption) *Node {
 
 // Start is the node's mainloop
 func (n *Node) Start() error {
+	if err := n.Validate(); err != nil {
+		return errors.Wrap(err, "node is misconfigured")
+	}
 	select {}
 }
 
+// Validate returns an error if object is invalid
+func (n *Node) Validate() error {
+	if n == nil || n.sql == nil {
+		return errors.New("missing required fields")
+	}
+	return nil
+}
+
 // NewNodeOption is a callback used to configure a Node during intiailization phase
 type NewNodeOption func(n *Node)
+
+// NewID returns a unique ID prefixed with our contact ID
+func (n *Node) NewID() string {
+	return fmt.Sprintf("%s:%s", n.myself.ID, uuid.Must(uuid.NewV4()).String())
+}