Removed using github.com/pkg/errors

Author: Evgeniy Ivakha

.travis.yml

@@ -9,7 +9,6 @@ before_install:
 
 install:
   - go get golang.org/x/net/websocket
-  - go get github.com/pkg/errors
   - go get github.com/getblank/uuid
 
 script:

client.go

@@ -1,21 +1,21 @@
 package wango
 
 import (
+	"errors"
 	"strconv"
 
-	"github.com/pkg/errors"
 	"golang.org/x/net/websocket"
 )
 
 func (c *Conn) receiveWelcome() error {
 	var data []byte
 	err := websocket.Message.Receive(c.connection, &data)
 	if err != nil {
-		return errors.Wrap(err, "Can't receive welcome message")
+		return err
 	}
 	msgType, msg, err := parseMessage(data)
 	if err != nil {
-		return errors.Wrap(err, "Parsing welcome message")
+		return err
 	}
 	if msgType != msgWelcome {
 		if typeString, ok := msgIntTypes[msgType]; ok {

parser.go

@@ -2,15 +2,15 @@ package wango
 
 import (
 	"encoding/json"
-
-	"github.com/pkg/errors"
+	"errors"
+	"fmt"
 )
 
 func parseMessage(_msg []byte) (int, []interface{}, error) {
 	var msg []interface{}
 	err := json.Unmarshal(_msg, &msg)
 	if err != nil {
-		return 0, nil, errors.Wrap(err, "when unmarshaling wamp message")
+		return 0, nil, err
 	}
 	if len(msg) < 1 {
 		return 0, nil, errors.New("invalid wamp message")
@@ -21,20 +21,20 @@ func parseMessage(_msg []byte) (int, []interface{}, error) {
 	if strCallType, ok := msg[0].(string); ok {
 		callType, ok := msgTxtTypes[strCallType]
 		if !ok {
-			return 0, nil, errors.Errorf("unknown call type: %s", strCallType)
+			return 0, nil, fmt.Errorf("unknown call type: %s", strCallType)
 		}
 		return callType, msg, nil
 	}
 	return 0, nil, errors.New("unknown call type")
 }
 
-func parseWampMessage(typ int, msg []interface{}) (*wampMsg, error) {
+func parseWampMessage(typ int, msg []interface{}) (*wampUnmarshaledMsg, error) {
 	if typ == msgCall && len(msg) < 3 {
 		return nil, errors.New("invalid wamp message")
 	} else if len(msg) < 2 {
 		return nil, errors.New("invalid wamp message")
 	}
-	message := new(wampMsg)
+	message := new(wampUnmarshaledMsg)
 	switch typ {
 	case msgCall:
 		if msg[1] == nil {

wamp.go

@@ -1,13 +1,13 @@
 package wango
 
 import (
+	"errors"
 	"io"
 	"regexp"
 	"strings"
 	"sync"
 	"time"
 
-	"github.com/pkg/errors"
 	"golang.org/x/net/websocket"
 )
 
@@ -60,7 +60,7 @@ func Connect(url, origin string, timeout ...time.Duration) (*Wango, error) {
 	}
 	ws, err := websocket.Dial(url, "wamp", origin)
 	if err != nil {
-		return nil, errors.Wrap(err, "Can't connect to "+url)
+		return nil, err
 	}
 	w := New()
 	c := w.addConnection(ws, nil)
@@ -224,14 +224,14 @@ func (w *Wango) RegisterRPCHandler(_uri interface{}, fn func(c *Conn, uri string
 	case string:
 		uri := _uri.(string)
 		if _, ok := w.rpcHandlers[uri]; ok {
-			return errors.Wrap(errHandlerAlreadyRegistered, "when registering string rpcHandler")
+			return errHandlerAlreadyRegistered
 		}
 		w.rpcHandlers[uri] = fn
 	case *regexp.Regexp:
 		rgx := _uri.(*regexp.Regexp)
 		for k := range w.rpcRgxHandlers {
 			if k.String() == rgx.String() {
-				return errors.Wrap(errHandlerAlreadyRegistered, "when registering rgx rpcHandler")
+				return errHandlerAlreadyRegistered
 			}
 		}
 		w.rpcRgxHandlers[rgx] = fn
@@ -248,7 +248,7 @@ func (w *Wango) RegisterRPCHandler(_uri interface{}, fn func(c *Conn, uri string
 // then to connection will send data from second argument.
 func (w *Wango) RegisterSubHandler(uri string, fnSub func(c *Conn, uri string, args ...interface{}) (interface{}, error), fnUnsub func(c *Conn, uri string, args ...interface{}) (interface{}, error), fnPub func(uri string, event interface{}, extra interface{}) (bool, interface{})) error {
 	if _, ok := w.subHandlers[uri]; ok {
-		return errors.Wrap(errHandlerAlreadyRegistered, "when registering subHandler")
+		return errHandlerAlreadyRegistered
 	}
 
 	w.subHandlers[uri] = subHandler{