Initial bits for lambda trigger events

Author: ggallotti

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

@@ -0,0 +1,13 @@
+package com.genexus.cloud.serverless;
+
+import java.util.Date;
+
+public class EventMessage {
+	private String messageId;
+	private Date messageDate;
+	private String messageSourceType;
+	private String messageData;
+	private String messageCustomPlayload;
+	private String messageVersion = "1.0";
+}
+

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

@@ -0,0 +1,2 @@
+package com.genexus.cloud.serverless;public class EventMessageResponse {
+}

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

@@ -0,0 +1,7 @@
+package com.genexus.cloud.serverless;
+
+public class EventMessageSourceType {
+	public static String QueueMessage = "QueueMessage";
+	public static String ServiceBusMessage = "ServiceBusMessage";
+	public static String Timer = "Timer";
+}

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

@@ -0,0 +1,2 @@
+package com.genexus.cloud.serverless;public class EventMessages {
+}

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

@@ -0,0 +1,2 @@
+package com.genexus.cloud.serverless;public class Helper {
+}

gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/EventMessageProperty.java

@@ -0,0 +1,4 @@
+package com.genexus.cloud.serverless.aws;
+
+public class EventMessageAttribute {
+}

gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/AwsGxServletResponse.java renamed to gxawsserverless/src/main/java/com/genexus/cloud/serverless/aws/handler/AwsGxServletResponse.java

@@ -0,0 +1,51 @@
+package com.genexus.cloud.serverless.aws;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
+import com.genexus.diagnostics.core.ILogger;
+import com.genexus.specific.java.Connect;
+import com.genexus.specific.java.LogManager;
+import com.genexus.util.IniFile;
+
+
+public class LambdaBaseHandler {
+	protected static ILogger logger = null;
+	protected static Class<?> entryPointClass = null;
+	private static final String GX_APPLICATION_CLASS = "GXcfg";
+	private static String ENTRY_POINT_CLASS_NAME_VAR = "GX_MAIN_CLASS_NAME";
+	private static String packageName = null;
+	protected static final String MESSAGE_INPUT_CLASS_NAME = "com.genexusserverlessapi.genexusserverlessapi.SdtEventMessages";
+	protected static final String MESSAGE_OUTPUT_COLLECTION_CLASS_NAME = "com.genexusserverlessapi.genexusserverlessapi.SdtEventMessageResponse";
+
+
+	public LambdaBaseHandler() throws Exception {
+		initialize();
+	}
+
+	private static void initialize() throws Exception {
+		logger = LogManager.initialize(".", LambdaBaseHandler.class);
+		Connect.init();
+
+		String entryPointClassName = System.getenv(ENTRY_POINT_CLASS_NAME_VAR);
+		if (entryPointClassName == null) {
+			throw new Exception(String.format("'%s' Environment Variable must be defined", ENTRY_POINT_CLASS_NAME_VAR));
+		}
+
+		IniFile config = com.genexus.ConfigFileFinder.getConfigFile(null, "client.cfg", null);
+		packageName = config.getProperty("Client", "PACKAGE", null);
+		Class<?> cfgClass;
+		try {
+			cfgClass = Class.forName(packageName.isEmpty() ? GX_APPLICATION_CLASS: String.format("%s.%s", packageName, GX_APPLICATION_CLASS));
+			com.genexus.Application.init(cfgClass);
+			entryPointClassName = packageName.isEmpty() ? entryPointClassName: String.format("%s.%s", packageName, entryPointClassName);
+			logger.debug("Initializing entry Point ClassName: " + entryPointClassName);
+			entryPointClass = Class.forName(entryPointClassName);
+		} catch (Exception e) {
+			logger.error(String.format("Failed to initialize Application for className: %s", entryPointClassName), e);
+			throw e;
+		}
+	}
+}
+

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

@@ -0,0 +1,44 @@
+package com.genexus.cloud.serverless.aws;
+
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent;
+import com.amazonaws.services.lambda.runtime.events.SQSEvent.SQSMessage;
+import com.genexus.GxUserType;
+import com.genexus.ModelContext;
+
+import java.lang.reflect.Constructor;
+
+
+public class LambdaSQSHandler extends LambdaBaseHandler implements RequestHandler<SQSEvent, Void> {
+
+	public LambdaSQSHandler() throws Exception {
+		super();
+	}
+
+	@Override
+	public Void handleRequest(SQSEvent sqsEvent, Context context)  {
+		logger.debug("handleRequest start");
+
+		for(SQSMessage msg : sqsEvent.getRecords()){
+			logger.debug(String.format("Processing sqsEvent Message: %s", msg.getMessageId()));
+
+			try {
+				ModelContext modelContext = new ModelContext( entryPointClass );
+				Object[] parameters = new Object[2];
+
+				Class<?> eventMessagesClass = Class.forName(MESSAGE_INPUT_CLASS_NAME);
+				Constructor constructor = eventMessagesClass.getConstructor(ModelContext.class);
+				GxUserType inputMessage = (GxUserType) constructor.newInstance(modelContext);
+
+				com.genexus.db.DynamicExecute.dynamicExecute(modelContext, -1, entryPointClass, entryPointClass.getName(), parameters);
+			}
+			catch (Exception e) {
+				logger.error("HandleRequest failed: " + entryPointClass.getName(), e);
+			}
+
+		}
+		return null;
+	}
+}
+

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

@@ -0,0 +1,2 @@
+package com.genexus.cloud.aws.events;public class TestLambdaBaseHandler {
+}