Skip to content

Java Azure functions #881

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 21 commits into from
Jan 9, 2025
Merged

Java Azure functions #881

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
21 commits
Select commit Hold shift + click to select a range
7f8563a
Java Azure functions
sjuarezgx Jul 5, 2024
0b6a956
Merge branch 'master' into AzureFunctions
sjuarezgx Jul 5, 2024
21da70e
Use a singleton to access configuration file once and try to guarante…
sjuarezgx Jul 7, 2024
6cc9f30
Add Azure Timer Trigger
sjuarezgx Jul 14, 2024
7f88c2b
fix POM error
sjuarezgx Jul 15, 2024
beac028
Add CosmosDB, EventGrid, Service Bus triggered functions.
sjuarezgx Jul 25, 2024
a034b44
Add unit tests.
sjuarezgx Aug 1, 2024
eb83811
optimize code of blobstorage function
sjuarezgx Aug 2, 2024
42a3193
Refactor to use common clases from gxserverlesscommon module
sjuarezgx Aug 6, 2024
e25a266
Avoid using GetrealPath to logging.
Dec 6, 2024
54d97d2
Merge branch 'master' into AzureFunctions
Dec 6, 2024
6bced11
Merge branch 'master' into AzureFunctions
sjuarezgx Dec 6, 2024
5d99a57
Merge branch 'master' into AzureFunctions
sjuarezgx Dec 23, 2024
e00db77
Resolve code review issues
Dec 30, 2024
afa52fa
Add handlers for single processing messages for Service Bus functions
Dec 30, 2024
8fe988c
Fixes related to message date JSON serialization.
Jan 6, 2025
2a6858f
Fix build error
Jan 6, 2025
de737e3
Use fake Id (function invocation Id) por Message Id for Service Bus.
Jan 7, 2025
2a8bd97
Fix CosmosDB trigger and other minor fixes
Jan 8, 2025
6cc6a89
use current date for the message date data
Jan 9, 2025
575267d
Merge branch 'master' into AzureFunctions
sjuarezgx Jan 9, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions gxawsserverless/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,12 @@
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>gxserverlesscommon</artifactId>
<version>${project.version}</version>
</dependency>

<dependency>
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
Expand Down
27 changes: 0 additions & 27 deletions gxawsserverless/src/main/java/com/genexus/cloud/serverless/Helper.java
View file
Open in desktop

This file was deleted.

7 changes: 3 additions & 4 deletions ...erless/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaBaseEventHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,7 @@
import com.genexus.ApplicationContext;
import com.genexus.ModelContext;
import com.genexus.cloud.serverless.*;
import com.genexus.cloud.serverless.model.EventMessageResponse;
import com.genexus.cloud.serverless.model.EventMessages;
import com.genexus.cloud.serverless.model.*;
import com.genexus.diagnostics.core.ILogger;
import com.genexus.specific.java.Connect;
import com.genexus.specific.java.LogManager;
Expand Down Expand Up @@ -64,7 +63,7 @@ private void initialize() throws Exception {
}

protected EventMessageResponse dispatchEvent(EventMessages eventMessages, String lambdaRawMessageBody) throws Exception {
String jsonStringMessages = Helper.toJSONString(eventMessages);
String jsonStringMessages = JSONHelper.toJSONString(eventMessages);

if (logger.isDebugEnabled()) {
logger.debug(String.format("dispatchEventMessages (%s) - serialized messages: %s", functionConfiguration.getEntryPointClassName(), jsonStringMessages));
Expand All @@ -74,7 +73,7 @@ protected EventMessageResponse dispatchEvent(EventMessages eventMessages, String
EventMessageResponse response = null;

try {
response = executor.execute(modelContext, eventMessages, lambdaRawMessageBody);
response = executor.execute(modelContext, eventMessages, null, lambdaRawMessageBody);
} catch (Exception e) {
logger.error(String.format("dispatchEventmessages - program '%s' execution error", entryPointClass.getName()), e);
throw e;
Expand Down
13 changes: 5 additions & 8 deletions ...less/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaEventBridgeHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,9 @@

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.genexus.cloud.serverless.Helper;
import com.genexus.cloud.serverless.JSONHelper;
import com.genexus.cloud.serverless.model.*;
import com.genexus.cloud.serverless.exception.FunctionRuntimeException;
import com.genexus.cloud.serverless.model.EventMessage;
import com.genexus.cloud.serverless.model.EventMessageResponse;
import com.genexus.cloud.serverless.model.EventMessageSourceType;
import com.genexus.cloud.serverless.model.EventMessages;
import com.genexus.json.JSONObjectWrapper;
import org.apache.http.client.utils.DateUtils;

Expand All @@ -25,7 +22,7 @@ public LambdaEventBridgeHandler(String entryPointClassName) throws Exception {

@Override
public String handleRequest(Map<String, Object> stringObjectMap, Context context) {
String jsonEventRaw = Helper.toJSONString(stringObjectMap);
String jsonEventRaw = JSONHelper.toJSONString(stringObjectMap);

logger.debug("handleRequest started with event: " + jsonEventRaw);

Expand All @@ -44,7 +41,7 @@ public String handleRequest(Map<String, Object> stringObjectMap, Context context
msgItem.setMessageData(new JSONObjectWrapper(jsonEventRaw).getJSONObject("detail").toString());
}
for (Map.Entry<String, Object> entry : stringObjectMap.entrySet()) {
Helper.addEventMessageProperty(msgItem, entry.getKey(), entry.getValue().toString());
JSONHelper.addEventMessageProperty(msgItem, entry.getKey(), entry.getValue().toString());
}
msgs.add(msgItem);
response = dispatchEvent(msgs, jsonEventRaw);
Expand All @@ -63,6 +60,6 @@ public String handleRequest(Map<String, Object> stringObjectMap, Context context
logger.error(String.format("Messages were not handled. Error: %s", response.getErrorMessage()));
throw new RuntimeException(response.getErrorMessage());
}
return Helper.toJSONString(response);
return JSONHelper.toJSONString(response);
}
}
8 changes: 2 additions & 6 deletions gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/handler/LambdaSQSHandler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,11 +6,7 @@
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
import com.genexus.cloud.serverless.*;
import com.genexus.cloud.serverless.model.EventMessageProperty;
import com.genexus.cloud.serverless.model.EventMessage;
import com.genexus.cloud.serverless.model.EventMessageResponse;
import com.genexus.cloud.serverless.model.EventMessageSourceType;
import com.genexus.cloud.serverless.model.EventMessages;
import com.genexus.cloud.serverless.model.*;

import java.util.ArrayList;
import java.util.Date;
Expand Down Expand Up @@ -64,7 +60,7 @@ public SQSBatchResponse handleRequest(SQSEvent sqsEvent, Context context) {
String errorMessage;

try {
EventMessageResponse response = dispatchEvent(msgs, Helper.toJSONString(sqsEvent));
EventMessageResponse response = dispatchEvent(msgs, JSONHelper.toJSONString(sqsEvent));
wasHandled = !response.hasFailed();
errorMessage = response.getErrorMessage();
} catch (Exception e) {
Expand Down
98 changes: 0 additions & 98 deletions ...c/test/java/com/genexus/genexusserverlessapi/SdtEventCustomPayload_CustomPayloadItem.java
View file
Open in desktop

This file was deleted.

Loading
Loading