Added error handling in lambda

Author: pokki-deploy

pom.xml

@@ -3,7 +3,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>in.erail</groupId>
     <artifactId>api-framework-amazon-lambda</artifactId>
-    <version>2.5.2-SNAPSHOT</version>
+    <version>2.5.3-SNAPSHOT</version>
     <packaging>jar</packaging>
     <developers>
         <developer>

src/main/java/in/erail/amazon/lambda/service/ProxyService.java

@@ -107,7 +107,7 @@ public Maybe<Event> handle(Event pEvent) {
     //Send Request
     return clientRequest
             .rxSendBuffer(Buffer.buffer(body))
-            .map((resp) -> {
+            .flatMapMaybe((resp) -> {
               ResponseEvent responseEvent = pEvent.getResponse();
 
               //Add Headers
@@ -125,10 +125,13 @@ public Maybe<Event> handle(Event pEvent) {
                       .ofNullable(resp.body())
                       .ifPresent(b -> responseEvent.setBody(b.getBytes()));
 
-              return pEvent;
+              if (resp.statusCode() >= 400 && resp.statusCode() <= 599) {
+                return Maybe.error(new RuntimeException(responseEvent.toString()));
+              }
+
+              return Maybe.just(pEvent);
             })
-            .doOnSuccess(e -> getLog().debug(() -> e.toString()))
-            .toMaybe();
+            .doOnSuccess(e -> getLog().debug(() -> e.toString()));
 
   }