optimize code of blobstorage function

Author: sjuarezgx

gxazureserverless/pom.xml

@@ -88,10 +88,11 @@
 
         <dependency>
             <groupId>org.junit.jupiter</groupId>
-            <artifactId>junit-jupiter</artifactId>
-            <version>RELEASE</version>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>5.10.3</version>
             <scope>test</scope>
         </dependency>
+
     </dependencies>
 
     <build>

gxazureserverless/src/main/java/com/genexus/cloud/serverless/azure/handler/AzureBlobStorageHandler.java

@@ -1,4 +1,5 @@
 package com.genexus.cloud.serverless.azure.handler;
+import com.genexus.cloud.serverless.Helper;
 import com.genexus.cloud.serverless.model.*;
 
 import com.microsoft.azure.functions.annotation.*;
@@ -9,6 +10,10 @@
 import java.util.*;
 
 public class AzureBlobStorageHandler extends AzureEventHandler{
+
+	EventMessages msgs = new EventMessages();
+	String rawMessage ="";
+
 	public AzureBlobStorageHandler() throws Exception {
 		super();
 	}
@@ -17,28 +22,35 @@ public void run(
 		@BindingName("name") String name,
 		final ExecutionContext context
 	) throws Exception {
+
 		context.getLogger().info("GeneXus Blob Storage trigger handler. Function processed: " + context.getFunctionName() + " Invocation Id: " + context.getInvocationId());
+		setupServerlessMappings(context.getFunctionName());
 
-		EventMessages msgs = new EventMessages();
-		EventMessage msg = new EventMessage();
-		msg.setMessageId(context.getInvocationId());
-		msg.setMessageSourceType(EventMessageSourceType.BLOB);
+		switch (executor.getMethodSignatureIdx()) {
+			case 0:
 
-		Instant nowUtc = Instant.now();
-		msg.setMessageDate(Date.from(nowUtc));
-		msg.setMessageData(Base64.getEncoder().encodeToString(content));
+				EventMessage msg = new EventMessage();
+				msg.setMessageId(context.getInvocationId());
+				msg.setMessageSourceType(EventMessageSourceType.BLOB);
 
-		List<EventMessageProperty> msgAtts = msg.getMessageProperties();
+				Instant nowUtc = Instant.now();
+				msg.setMessageDate(Date.from(nowUtc));
+				msg.setMessageData(Base64.getEncoder().encodeToString(content));
 
-		msgAtts.add(new EventMessageProperty("Id", context.getInvocationId()));
-		msgAtts.add(new EventMessageProperty("name", name));
+				List<EventMessageProperty> msgAtts = msg.getMessageProperties();
 
-		msgs.add(msg);
+				msgAtts.add(new EventMessageProperty("Id", context.getInvocationId()));
+				msgAtts.add(new EventMessageProperty("name", name));
 
-		setupServerlessMappings(context.getFunctionName());
+				msgs.add(msg);
+				break;
+			case 1:
+			case 2:
+				rawMessage = Base64.getEncoder().encodeToString(content);
+		}
 
 		try {
-			EventMessageResponse response = dispatchEvent(msgs, Base64.getEncoder().encodeToString(content));
+			EventMessageResponse response = dispatchEvent(msgs, rawMessage);
 			if (response.hasFailed()) {
 				logger.error(String.format("Messages were not handled. Error: %s", response.getErrorMessage()));
 				throw new RuntimeException(response.getErrorMessage()); //Throw the exception so the runtime can Retry the operation.
@@ -47,6 +59,5 @@ public void run(
 			logger.error("HandleRequest execution error", e);
 			throw e; 		//Throw the exception so the runtime can Retry the operation.
 		}
-
 	}
 }