Add tests

Author: segabriel

services-gateway-netty/src/main/java/io/scalecube/services/gateway/rsocket/RSocketGateway.java

@@ -37,6 +37,10 @@ public RSocketGateway(GatewayOptions options, GatewaySessionHandler sessionHandl
     this(options, sessionHandler, DefaultErrorMapper.INSTANCE);
   }
 
+  public RSocketGateway(GatewayOptions options, ServiceProviderErrorMapper errorMapper) {
+    this(options, GatewaySessionHandler.DEFAULT_INSTANCE, errorMapper);
+  }
+
   /**
    * Constructor.
    *

services-gateway-tests/src/test/java/io/scalecube/services/gateway/http/HttpClientErrorMapperTest.java

@@ -0,0 +1,38 @@
+package io.scalecube.services.gateway.http;
+
+import static io.scalecube.services.gateway.TestUtils.TIMEOUT;
+import static io.scalecube.services.gateway.exeptions.GatewayErrorMapperImpl.ERROR_MAPPER;
+
+import io.scalecube.services.ServiceInfo;
+import io.scalecube.services.gateway.BaseTest;
+import io.scalecube.services.gateway.exeptions.ErrorService;
+import io.scalecube.services.gateway.exeptions.ErrorServiceImpl;
+import io.scalecube.services.gateway.exeptions.SomeException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import reactor.test.StepVerifier;
+
+@Disabled("Cannot deserialize instance of `java.lang.String` out of START_OBJECT token")
+class HttpClientErrorMapperTest extends BaseTest {
+
+  @RegisterExtension
+  static HttpGatewayExtension extension =
+      new HttpGatewayExtension(
+          ServiceInfo.fromServiceInstance(new ErrorServiceImpl())
+              .errorMapper(ERROR_MAPPER)
+              .build());
+
+  private ErrorService service;
+
+  @BeforeEach
+  void initService() {
+    service = extension.client().errorMapper(ERROR_MAPPER).api(ErrorService.class);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnMono() {
+    StepVerifier.create(service.oneError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+}

services-gateway-tests/src/test/java/io/scalecube/services/gateway/http/HttpLocalGatewayErrorMapperTest.java

@@ -0,0 +1,37 @@
+package io.scalecube.services.gateway.http;
+
+import static io.scalecube.services.gateway.TestUtils.TIMEOUT;
+import static io.scalecube.services.gateway.exeptions.GatewayErrorMapperImpl.ERROR_MAPPER;
+
+import io.scalecube.services.ServiceInfo;
+import io.scalecube.services.gateway.BaseTest;
+import io.scalecube.services.gateway.exeptions.ErrorService;
+import io.scalecube.services.gateway.exeptions.ErrorServiceImpl;
+import io.scalecube.services.gateway.exeptions.SomeException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import reactor.test.StepVerifier;
+
+@Disabled("Cannot deserialize instance of `java.lang.String` out of START_OBJECT token")
+class HttpLocalGatewayErrorMapperTest extends BaseTest {
+
+  @RegisterExtension
+  static HttpLocalGatewayExtension extension =
+      new HttpLocalGatewayExtension(
+          ServiceInfo.fromServiceInstance(new ErrorServiceImpl()).errorMapper(ERROR_MAPPER).build(),
+          opts -> new HttpGateway(opts.call(opts.call().errorMapper(ERROR_MAPPER)), ERROR_MAPPER));
+
+  private ErrorService service;
+
+  @BeforeEach
+  void initService() {
+    service = extension.client().errorMapper(ERROR_MAPPER).api(ErrorService.class);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnMono() {
+    StepVerifier.create(service.oneError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+}

services-gateway-tests/src/test/java/io/scalecube/services/gateway/rsocket/RsocketClientErrorMapperTest.java

@@ -0,0 +1,41 @@
+package io.scalecube.services.gateway.rsocket;
+
+import static io.scalecube.services.gateway.TestUtils.TIMEOUT;
+import static io.scalecube.services.gateway.exeptions.GatewayErrorMapperImpl.ERROR_MAPPER;
+
+import io.scalecube.services.ServiceInfo;
+import io.scalecube.services.gateway.BaseTest;
+import io.scalecube.services.gateway.exeptions.ErrorService;
+import io.scalecube.services.gateway.exeptions.ErrorServiceImpl;
+import io.scalecube.services.gateway.exeptions.SomeException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import reactor.test.StepVerifier;
+
+class RsocketClientErrorMapperTest extends BaseTest {
+
+  @RegisterExtension
+  static RsocketGatewayExtension extension =
+      new RsocketGatewayExtension(
+          ServiceInfo.fromServiceInstance(new ErrorServiceImpl())
+              .errorMapper(ERROR_MAPPER)
+              .build());
+
+  private ErrorService service;
+
+  @BeforeEach
+  void initService() {
+    service = extension.client().errorMapper(ERROR_MAPPER).api(ErrorService.class);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnFlux() {
+    StepVerifier.create(service.manyError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnMono() {
+    StepVerifier.create(service.oneError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+}

services-gateway-tests/src/test/java/io/scalecube/services/gateway/rsocket/RsocketLocalGatewayErrorMapperTest.java

@@ -0,0 +1,41 @@
+package io.scalecube.services.gateway.rsocket;
+
+import static io.scalecube.services.gateway.TestUtils.TIMEOUT;
+import static io.scalecube.services.gateway.exeptions.GatewayErrorMapperImpl.ERROR_MAPPER;
+
+import io.scalecube.services.ServiceInfo;
+import io.scalecube.services.gateway.BaseTest;
+import io.scalecube.services.gateway.exeptions.ErrorService;
+import io.scalecube.services.gateway.exeptions.ErrorServiceImpl;
+import io.scalecube.services.gateway.exeptions.SomeException;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.RegisterExtension;
+import reactor.test.StepVerifier;
+
+class RsocketLocalGatewayErrorMapperTest extends BaseTest {
+
+  @RegisterExtension
+  static RsocketLocalGatewayExtension extension =
+      new RsocketLocalGatewayExtension(
+          ServiceInfo.fromServiceInstance(new ErrorServiceImpl()).errorMapper(ERROR_MAPPER).build(),
+          opts ->
+              new RSocketGateway(opts.call(opts.call().errorMapper(ERROR_MAPPER)), ERROR_MAPPER));
+
+  private ErrorService service;
+
+  @BeforeEach
+  void initService() {
+    service = extension.client().errorMapper(ERROR_MAPPER).api(ErrorService.class);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnFlux() {
+    StepVerifier.create(service.manyError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+
+  @Test
+  void shouldReturnSomeExceptionOnMono() {
+    StepVerifier.create(service.oneError()).expectError(SomeException.class).verify(TIMEOUT);
+  }
+}