Added helper methods for creating commands and notifications.

command.go

@@ -120,6 +120,45 @@ func (c *Command) populate(raw *rawEnvelope) error {
 	return nil
 }
 
+// IsRequest indicates if the current command is a request and should have a response.
+func (c *Command) IsRequest() bool {
+	return c.ID != "" && c.Status == ""
+}
+
+// SuccessResponse creates a success response Command for the current request.
+func (c *Command) SuccessResponse() *Command {
+	return &Command{
+		EnvelopeBase: EnvelopeBase{
+			ID:   c.ID,
+			From: c.To,
+			To:   c.Sender(),
+		},
+		Method: c.Method,
+		Status: CommandStatusSuccess,
+	}
+}
+
+// SuccessResponseWithResource creates a success response Command for the current request.
+func (c *Command) SuccessResponseWithResource(resource Document) *Command {
+	respCmd := c.SuccessResponse()
+	respCmd.Resource = resource
+	return respCmd
+}
+
+// FailureResponse creates a failure response Command for the current request.
+func (c *Command) FailureResponse(reason *Reason) *Command {
+	return &Command{
+		EnvelopeBase: EnvelopeBase{
+			ID:   c.ID,
+			From: c.To,
+			To:   c.Sender(),
+		},
+		Method: c.Method,
+		Status: CommandStatusFailure,
+		Reason: reason,
+	}
+}
+
 // CommandMethod Defines methods for the manipulation of resources.
 type CommandMethod string
 
@@ -145,7 +184,7 @@ const (
 	CommandMethodMerge = CommandMethod("merge")
 )
 
-func (m CommandMethod) IsValid() error {
+func (m CommandMethod) Validate() error {
 	switch m {
 	case CommandMethodGet, CommandMethodSet, CommandMethodDelete, CommandMethodSubscribe, CommandMethodUnsubscribe, CommandMethodObserve, CommandMethodMerge:
 		return nil
@@ -155,7 +194,7 @@ func (m CommandMethod) IsValid() error {
 }
 
 func (m CommandMethod) MarshalText() ([]byte, error) {
-	err := m.IsValid()
+	err := m.Validate()
 	if err != nil {
 		return []byte{}, err
 	}
@@ -164,7 +203,7 @@ func (m CommandMethod) MarshalText() ([]byte, error) {
 
 func (m *CommandMethod) UnmarshalText(text []byte) error {
 	method := CommandMethod(text)
-	err := method.IsValid()
+	err := method.Validate()
 	if err != nil {
 		return err
 	}

envelope.go

@@ -31,8 +31,13 @@ type EnvelopeBase struct {
 	Metadata map[string]string
 }
 
-func (env *EnvelopeBase) GetMetadata() map[string]string {
-	return env.Metadata
+// Sender returns the envelope sender Node.
+func (env *EnvelopeBase) Sender() Node {
+	if env.PP == (Node{}) {
+		return env.PP
+	} else {
+		return env.From
+	}
 }
 
 func (env *EnvelopeBase) toRawEnvelope() (*rawEnvelope, error) {

identity.go

@@ -5,11 +5,11 @@ import (
 	"strings"
 )
 
-// Identity Represents a member of a domain.
+// Identity represents a member of a domain.
 type Identity struct {
-	// Name Identity unique name on his domain.
+	// Name represents the Identity unique name on its domain.
 	Name string
-	// Domain Network domain name of the Identity.
+	// Domain represents the network domain name of the Identity.
 	Domain string
 }
 
@@ -25,7 +25,7 @@ func (i Identity) String() string {
 	return fmt.Sprintf("%v@%v", i.Name, i.Domain)
 }
 
-// ParseIdentity Parses the string To a valid Identity.
+// ParseIdentity parses the string To a valid Identity.
 func ParseIdentity(s string) (Identity, error) {
 	var name, domain string
 	values := strings.Split(s, "@")
@@ -49,12 +49,13 @@ func (i *Identity) UnmarshalText(text []byte) error {
 	return nil
 }
 
-// ToNode Creates a Node instance based on the identity, with an
+// ToNode creates a Node instance based on the identity, with an
 // empty value for the instance property.
 func (i Identity) ToNode() Node {
 	return Node{i, ""}
 }
 
+// IsComplete indicates if all Identity fields has values.
 func (i *Identity) IsComplete() bool {
 	return i.Name != "" && i.Domain != ""
 }

message.go

@@ -91,3 +91,23 @@ func (m *Message) populate(raw *rawEnvelope) error {
 	m.Content = document
 	return nil
 }
+
+// Notification creates a notification for the current message.
+func (m *Message) Notification(event NotificationEvent) *Notification {
+	return &Notification{
+		EnvelopeBase: EnvelopeBase{
+			ID:   m.ID,
+			From: m.To,
+			To:   m.Sender(),
+		},
+		Event: event,
+	}
+}
+
+// FailedNotification creates a notification for the current message with
+// the 'failed' event.
+func (m *Message) FailedNotification(reason *Reason) *Notification {
+	not := m.Notification(NotificationEventFailed)
+	not.Reason = reason
+	return not
+}

node.go

@@ -5,10 +5,10 @@ import (
 	"strings"
 )
 
-// Node Represents an element of a network.
+// Node represents an element of a network.
 type Node struct {
 	Identity
-	// Instance The name of the instance used by the node to connect to the network.
+	// Instance represents the name of the instance used by the node to connect to the network.
 	Instance string
 }
 
@@ -51,6 +51,7 @@ func (n *Node) UnmarshalText(text []byte) error {
 	return nil
 }
 
+// IsComplete indicates if all Node fields has values.
 func (n *Node) IsComplete() bool {
 	return n.Identity.IsComplete() && n.Instance != ""
 }

notification.go

@@ -93,7 +93,7 @@ const (
 	NotificationEventFailed = NotificationEvent("failed")
 )
 
-func (e *NotificationEvent) IsValid() error {
+func (e *NotificationEvent) Validate() error {
 	switch *e {
 	case NotificationEventAccepted, NotificationEventDispatched, NotificationEventReceived, NotificationEventConsumed, NotificationEventFailed:
 		return nil
@@ -103,7 +103,7 @@ func (e *NotificationEvent) IsValid() error {
 }
 
 func (e NotificationEvent) MarshalText() ([]byte, error) {
-	err := e.IsValid()
+	err := e.Validate()
 	if err != nil {
 		return []byte{}, err
 	}
@@ -112,7 +112,7 @@ func (e NotificationEvent) MarshalText() ([]byte, error) {
 
 func (e *NotificationEvent) UnmarshalText(text []byte) error {
 	event := NotificationEvent(text)
-	err := event.IsValid()
+	err := event.Validate()
 	if err != nil {
 		return err
 	}

session.go

@@ -195,7 +195,7 @@ const (
 	SessionStateFailed = SessionState("failed")
 )
 
-func (s SessionState) IsValid() error {
+func (s SessionState) Validate() error {
 	switch s {
 	case SessionStateNew, SessionStateNegotiating, SessionStateAuthenticating, SessionStateEstablished, SessionStateFinishing, SessionStateFinished, SessionStateFailed:
 		return nil
@@ -225,7 +225,7 @@ func (s SessionState) Step() int {
 }
 
 func (s SessionState) MarshalText() ([]byte, error) {
-	err := s.IsValid()
+	err := s.Validate()
 	if err != nil {
 		return []byte{}, err
 	}
@@ -234,7 +234,7 @@ func (s SessionState) MarshalText() ([]byte, error) {
 
 func (s *SessionState) UnmarshalText(text []byte) error {
 	state := SessionState(text)
-	err := state.IsValid()
+	err := state.Validate()
 	if err != nil {
 		return err
 	}