Fixed tests

Author: artem-v

services-examples/src/main/java/io/scalecube/services/examples/GreetingServiceCancelCallback.java

@@ -1,6 +1,7 @@
 package io.scalecube.services.examples;
 
 import io.scalecube.services.api.ServiceMessage;
+import io.scalecube.services.exceptions.BadRequestException;
 import java.util.List;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -16,6 +17,9 @@ public GreetingServiceCancelCallback(Runnable onCancel) {
 
   @Override
   public Mono<String> one(String name) {
+    if (name == null) {
+      throw new BadRequestException("Wrong request");
+    }
     return greetingService.one(name).doOnCancel(onCancel);
   }
 

services-examples/src/main/java/io/scalecube/services/examples/GreetingServiceImpl.java

@@ -2,6 +2,7 @@
 
 import io.scalecube.services.RequestContext;
 import io.scalecube.services.api.ServiceMessage;
+import io.scalecube.services.exceptions.BadRequestException;
 import java.time.Duration;
 import java.util.Collections;
 import java.util.List;
@@ -14,6 +15,9 @@ public class GreetingServiceImpl implements GreetingService {
 
   @Override
   public Mono<String> one(String name) {
+    if (name == null) {
+      throw new BadRequestException("Wrong request");
+    }
     return Mono.defer(() -> Mono.just("Echo:" + name));
   }
 

services-gateway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketGatewayTest.java

@@ -181,7 +181,7 @@ void shouldReturnErrorDataWhenRequestDataIsEmpty() {
         .verifyErrorSatisfies(
             ex -> {
               assertInstanceOf(BadRequestException.class, ex);
-              assertThat(ex.getMessage(), startsWith("Wrong request data type"));
+              assertThat(ex.getMessage(), startsWith("Wrong request"));
             });
   }
 

services-gateway/src/test/java/io/scalecube/services/gateway/websocket/WebsocketLocalGatewayTest.java

@@ -161,7 +161,7 @@ void shouldReturnErrorDataWhenRequestDataIsEmpty() {
         .verifyErrorSatisfies(
             ex -> {
               assertInstanceOf(BadRequestException.class, ex);
-              assertThat(ex.getMessage(), startsWith("Wrong request data type"));
+              assertThat(ex.getMessage(), startsWith("Wrong request"));
             });
   }