Skip to content

Commit e9364c2

Browse files
authored
Serverless Model: Change Handled to HandleFailure (#686)
1 parent 2bedf0e commit e9364c2

File tree

12 files changed

+279
-164
lines changed

12 files changed

+279
-164
lines changed

gxawsserverless/src/main/java/com/genexus/cloud/serverless/GXProcedureExecutor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,6 @@ public EventMessageResponse execute(ModelContext modelContext, EventMessages msg
8080
break;
8181
case 2:
8282
parameters = new Object[]{rawJsonEvent};
83-
response.setHandled(true);
8483
returnsValue = false;
8584
break;
8685
case 3:
@@ -89,7 +88,6 @@ public EventMessageResponse execute(ModelContext modelContext, EventMessages msg
8988
default:
9089
parameters = new Object[]{};
9190
returnsValue = false;
92-
response.setHandled(true);
9391
break;
9492
}
9593

gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaBaseEventHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ protected EventMessageResponse dispatchEvent(EventMessages eventMessages, String
8080
throw e;
8181
}
8282

83-
if (!response.isHandled()) {
83+
if (response.hasFailed()) {
8484
logger.info("dispatchEventmessages - messages not handled with success: " + response.getErrorMessage());
8585
} else {
8686
logger.debug("dispatchEventmessages - message handled with success");

gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaEventBridgeHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,7 @@ public String handleRequest(Map<String, Object> stringObjectMap, Context context
5858
return "";
5959
}
6060

61-
if (!response.isHandled()) {
61+
if (response.hasFailed()) {
6262
//Throw exception in order to mark the message as not processed.
6363
logger.error(String.format("Messages were not handled. Error: %s", response.getErrorMessage()));
6464
throw new RuntimeException(response.getErrorMessage());

gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaSQSHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ public SQSBatchResponse handleRequest(SQSEvent sqsEvent, Context context) {
6565

6666
try {
6767
EventMessageResponse response = dispatchEvent(msgs, Helper.toJSONString(sqsEvent));
68-
wasHandled = response.isHandled();
68+
wasHandled = !response.hasFailed();
6969
errorMessage = response.getErrorMessage();
7070
} catch (Exception e) {
7171
errorMessage = "HandleRequest execution error";

gxawsserverless/src/main/java/com/genexus/cloud/serverless/model/EventMessageResponse.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -3,18 +3,18 @@
33
import com.fasterxml.jackson.annotation.JsonProperty;
44

55
public class EventMessageResponse {
6-
@JsonProperty("Handled")
7-
private boolean handled = false;
6+
@JsonProperty("HandleFailure")
7+
private boolean hasFailed = false;
88

99
@JsonProperty("ErrorMessage")
1010
private String errorMessage = "";
1111

12-
public boolean isHandled() {
13-
return handled;
12+
public boolean hasFailed() {
13+
return hasFailed;
1414
}
1515

16-
public void setHandled(boolean handled) {
17-
this.handled = handled;
16+
public void setAsFailed(boolean hasFailed) {
17+
this.hasFailed = hasFailed;
1818
}
1919

2020
public String getErrorMessage() {

gxawsserverless/src/test/java/com/genexus/cloud/aws/events/TestLambdaEventBridgeHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,21 +30,21 @@ private Map<String, Object> createEvent() {
3030
public void simpleEvent() throws Exception {
3131
LambdaEventBridgeHandler handler = new LambdaEventBridgeHandler(SIMPLE_HANDLER);
3232
String result = handler.handleRequest(createEvent(), new MockContext());
33-
Assert.assertEquals("{\"Handled\":true,\"ErrorMessage\":\"\"}", result);
33+
Assert.assertEquals("{\"HandleFailure\":false,\"ErrorMessage\":\"\"}", result);
3434
}
3535

3636
@Test
3737
public void simpleEventRaw() throws Exception {
3838
LambdaEventBridgeHandler handler = new LambdaEventBridgeHandler(SIMPLE_RAW_HANDLER);
3939
String result = handler.handleRequest(createEvent(), new MockContext());
40-
Assert.assertEquals("{\"Handled\":true,\"ErrorMessage\":\"\"}", result);
40+
Assert.assertEquals("{\"HandleFailure\":false,\"ErrorMessage\":\"\"}", result);
4141
}
4242

4343
@Test
4444
public void simpleEventNoParms() throws Exception {
4545
LambdaEventBridgeHandler handler = new LambdaEventBridgeHandler(handlesimplenoparmsevent.class.getName());
4646
String result = handler.handleRequest(createEvent(), new MockContext());
47-
Assert.assertEquals("{\"Handled\":true,\"ErrorMessage\":\"\"}", result);
47+
Assert.assertEquals("{\"HandleFailure\":false,\"ErrorMessage\":\"\"}", result);
4848
}
4949

5050

0 commit comments

Comments
 (0)