Add client disconnected error type

Add client disconnected error type and add integration test cases
to test client.Request, client.Signal and client.RestoreSession
on disconnected client.

client/client.go

@@ -211,7 +211,7 @@ func (clt *Client) Signal(name string, payload webwire.Payload) error {
 	defer clt.apiLock.RUnlock()
 
 	if atomic.LoadInt32(&clt.isConnected) < 1 {
-		return fmt.Errorf("Trying to send a signal on a disconnected client")
+		return DisconnectedErr{}
 	}
 
 	msgBytes := webwire.NewSignalMessage(name, payload)

client/errors.go

@@ -0,0 +1,8 @@
+package client
+
+// DisconnectedErr is an error type indicating that the client isn't connected to the server
+type DisconnectedErr struct{}
+
+func (err DisconnectedErr) Error() string {
+	return "Client is disconnected"
+}

client/sendNamelessRequest.go

@@ -14,10 +14,7 @@ func (clt *Client) sendNamelessRequest(
 	timeout time.Duration,
 ) (webwire.Payload, error) {
 	if atomic.LoadInt32(&clt.isConnected) < 1 {
-		return webwire.Payload{}, webwire.ReqErr{
-			Code:    "DISCONNECTED",
-			Message: "Trying to send a request on a disconnected socket",
-		}
+		return webwire.Payload{}, DisconnectedErr{}
 	}
 
 	request := clt.requestManager.Create(timeout)

client/sendRequest.go

@@ -15,10 +15,7 @@ func (clt *Client) sendRequest(
 	timeout time.Duration,
 ) (webwire.Payload, error) {
 	if atomic.LoadInt32(&clt.isConnected) < 1 {
-		return webwire.Payload{}, webwire.ReqErr{
-			Code:    "DISCONNECTED",
-			Message: "Trying to send a request on a disconnected socket",
-		}
+		return webwire.Payload{}, DisconnectedErr{}
 	}
 
 	request := clt.requestManager.Create(timeout)

test/clientRestoreSessionDisconnected_test.go

@@ -0,0 +1,36 @@
+package test
+
+import (
+	"reflect"
+	"testing"
+	"time"
+
+	wwr "github.com/qbeon/webwire-go"
+	wwrclt "github.com/qbeon/webwire-go/client"
+)
+
+// TestClientRestoreSessionDisconnected tests manual session restoration on disconnected client
+func TestClientRestoreSessionDisconnected(t *testing.T) {
+	// Initialize webwire server
+	_, addr := setupServer(
+		t,
+		wwr.ServerOptions{},
+	)
+
+	// Initialize client
+	client := wwrclt.NewClient(
+		addr,
+		wwrclt.Options{
+			DefaultRequestTimeout: 2 * time.Second,
+		},
+	)
+
+	err := client.RestoreSession([]byte("somekey"))
+	if _, isDisconnErr := err.(wwrclt.DisconnectedErr); !isDisconnErr {
+		t.Fatalf(
+			"Expected disconnected error, got: %s | %s",
+			reflect.TypeOf(err),
+			err,
+		)
+	}
+}

test/clientSignalDisconnected_test.go

@@ -0,0 +1,37 @@
+package test
+
+import (
+	"reflect"
+	"testing"
+	"time"
+
+	wwr "github.com/qbeon/webwire-go"
+	wwrclt "github.com/qbeon/webwire-go/client"
+)
+
+// TestClientSignalDisconnected tests sending signals on disconnected clients
+func TestClientSignalDisconnected(t *testing.T) {
+	// Initialize webwire server given only the request
+	_, addr := setupServer(
+		t,
+		wwr.ServerOptions{},
+	)
+
+	// Initialize client
+	client := wwrclt.NewClient(
+		addr,
+		wwrclt.Options{
+			DefaultRequestTimeout: 2 * time.Second,
+		},
+	)
+
+	// Send request and await reply
+	err := client.Signal("", wwr.Payload{Data: []byte("testdata")})
+	if _, isDisconnErr := err.(wwrclt.DisconnectedErr); !isDisconnErr {
+		t.Fatalf(
+			"Expected disconnected error, got: %s | %s",
+			reflect.TypeOf(err),
+			err,
+		)
+	}
+}

test/cllientRequestDisconnected_test.go

@@ -0,0 +1,37 @@
+package test
+
+import (
+	"reflect"
+	"testing"
+	"time"
+
+	wwr "github.com/qbeon/webwire-go"
+	wwrclt "github.com/qbeon/webwire-go/client"
+)
+
+// TestClientRequestDisconnected tests sending requests on disconnected clients
+func TestClientRequestDisconnected(t *testing.T) {
+	// Initialize webwire server given only the request
+	_, addr := setupServer(
+		t,
+		wwr.ServerOptions{},
+	)
+
+	// Initialize client
+	client := wwrclt.NewClient(
+		addr,
+		wwrclt.Options{
+			DefaultRequestTimeout: 2 * time.Second,
+		},
+	)
+
+	// Send request and await reply
+	_, err := client.Request("", wwr.Payload{Data: []byte("testdata")})
+	if _, isDisconnErr := err.(wwrclt.DisconnectedErr); !isDisconnErr {
+		t.Fatalf(
+			"Expected disconnected error, got: %s | %s",
+			reflect.TypeOf(err),
+			err,
+		)
+	}
+}