Added default authenticator; cleanup in test services

Author: artem-v

services-api/src/main/java/io/scalecube/services/auth/DelegatingAuthenticator.java

@@ -0,0 +1,19 @@
+package io.scalecube.services.auth;
+
+import io.scalecube.services.exceptions.UnauthorizedException;
+import java.util.Map;
+import reactor.core.publisher.Mono;
+
+public final class DelegatingAuthenticator implements Authenticator<Object> {
+
+  @Override
+  public Mono<Object> authenticate(Map<String, String> credentials) {
+    return Mono.deferWithContext(
+        context -> {
+          if (!context.hasKey(Authenticator.AUTH_CONTEXT_KEY)) {
+            throw new UnauthorizedException("Authentication failed (auth context not found)");
+          }
+          return context.get(Authenticator.AUTH_CONTEXT_KEY);
+        });
+  }
+}

services-api/src/main/java/io/scalecube/services/methods/ServiceMethodInvoker.java

@@ -157,9 +157,6 @@ private Mono<Object> authenticate(ServiceMessage message, Context context) {
     if (context.hasKey(Authenticator.AUTH_CONTEXT_KEY)) {
       return Mono.just(context.get(Authenticator.AUTH_CONTEXT_KEY));
     }
-    if (authenticator == null) {
-      throw new UnauthorizedException("Authenticator not found");
-    }
     return authenticator.authenticate(message.headers()).onErrorMap(this::toUnauthorizedException);
   }
 

services/src/main/java/io/scalecube/services/Microservices.java

@@ -3,6 +3,7 @@
 import io.scalecube.net.Address;
 import io.scalecube.services.api.ServiceMessage;
 import io.scalecube.services.auth.Authenticator;
+import io.scalecube.services.auth.DelegatingAuthenticator;
 import io.scalecube.services.auth.PrincipalMapper;
 import io.scalecube.services.discovery.api.ServiceDiscovery;
 import io.scalecube.services.discovery.api.ServiceDiscoveryEvent;
@@ -314,7 +315,7 @@ public static final class Builder {
     private List<ServiceProvider> serviceProviders = new ArrayList<>();
     private ServiceRegistry serviceRegistry = new ServiceRegistryImpl();
     private ServiceMethodRegistry methodRegistry = new ServiceMethodRegistryImpl();
-    private Authenticator<Object> authenticator = null;
+    private Authenticator<Object> authenticator = new DelegatingAuthenticator();
     private ServiceDiscoveryBootstrap discoveryBootstrap = new ServiceDiscoveryBootstrap();
     private ServiceTransportBootstrap transportBootstrap = new ServiceTransportBootstrap();
     private GatewayBootstrap gatewayBootstrap = new GatewayBootstrap();

services/src/test/java/io/scalecube/services/ServiceAuthRemoteTest.java

@@ -47,7 +47,8 @@ final class ServiceAuthRemoteTest extends BaseTest {
           return Mono.just(authData);
         }
 
-        return Mono.error(new UnauthorizedException("Authentication failed"));
+        return Mono.error(
+            new UnauthorizedException("Authentication failed (username or password incorrect)"));
       };
 
   private static Microservices caller;

services/src/test/java/io/scalecube/services/sut/GreetingServiceImpl.java

@@ -3,7 +3,7 @@
 import io.scalecube.services.Microservices;
 import io.scalecube.services.annotations.Inject;
 import io.scalecube.services.api.ServiceMessage;
-import io.scalecube.services.exceptions.UnauthorizedException;
+import io.scalecube.services.exceptions.ForbiddenException;
 import java.util.stream.LongStream;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
@@ -41,7 +41,7 @@ public Mono<GreetingResponse> greetingPojo(GreetingRequest name) {
 
   @Override
   public Mono<GreetingResponse> greetingNotAuthorized(GreetingRequest name) {
-    return Mono.error(new UnauthorizedException(500, "Not authorized"));
+    return Mono.error(new ForbiddenException("Not authorized"));
   }
 
   @Override
@@ -80,7 +80,7 @@ public Flux<GreetingResponse> bidiGreeting(Publisher<GreetingRequest> request) {
 
   @Override
   public Flux<GreetingResponse> bidiGreetingNotAuthorized(Flux<GreetingRequest> request) {
-    return Flux.error(new UnauthorizedException(500, "Not authorized"));
+    return Flux.error(new ForbiddenException("Not authorized"));
   }
 
   @Override