Fix lambda tests on localstack apache#2595

aldettinger · Sep 15, 2021 · 6895f38 · 6895f38
1 parent 2469db7
commit 6895f38
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 16 deletions.
diff --git a/...a/src/main/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaResource.java b/...a/src/main/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaResource.java
@@ -43,6 +43,7 @@
 import software.amazon.awssdk.services.lambda.model.FunctionConfiguration;
 import software.amazon.awssdk.services.lambda.model.InvalidParameterValueException;
 import software.amazon.awssdk.services.lambda.model.ListFunctionsResponse;
+import software.amazon.awssdk.services.lambda.model.Runtime;
 
 @Path("/aws2-lambda")
 @ApplicationScoped
@@ -64,7 +65,7 @@ public Response createFunction(byte[] message, @PathParam("functionName") String
                 new LinkedHashMap<String, Object>() {
                     {
                         put(Lambda2Constants.ROLE, roleArn);
-                        put(Lambda2Constants.RUNTIME, "nodejs12.x");
+                        put(Lambda2Constants.RUNTIME, Runtime.PYTHON3_9);
                         put(Lambda2Constants.HANDLER, "index.handler");
                     }
                 },

diff --git a/...-lambda/src/test/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaIT.java b/...-lambda/src/test/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaIT.java
@@ -17,10 +17,7 @@
 package org.apache.camel.quarkus.component.aws2.lambda.it;
 
 import io.quarkus.test.junit.NativeImageTest;
-import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
 
-//TODO disabled on Localstack, see https://github.com/apache/camel-quarkus/issues/2595
-@EnabledIfEnvironmentVariable(named = "AWS_ACCESS_KEY", matches = "[a-zA-Z0-9]+")
 @NativeImageTest
 class Aws2LambdaIT extends Aws2LambdaTest {
 

diff --git a/...ambda/src/test/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaTest.java b/...ambda/src/test/java/org/apache/camel/quarkus/component/aws2/lambda/it/Aws2LambdaTest.java
@@ -33,10 +33,7 @@
 import org.hamcrest.Matchers;
 import org.jboss.logging.Logger;
 import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
 
-//TODO disabled on Localstack, see https://github.com/apache/camel-quarkus/issues/2595
-@EnabledIfEnvironmentVariable(named = "AWS_ACCESS_KEY", matches = "[a-zA-Z0-9]+")
 @QuarkusTest
 @QuarkusTestResource(Aws2TestResource.class)
 class Aws2LambdaTest {
@@ -118,7 +115,7 @@ public void e2e() {
     static byte[] createFunctionZip() {
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         try (ZipOutputStream out = new ZipOutputStream(baos)) {
-            out.putNextEntry(new ZipEntry("index.js"));
+            out.putNextEntry(new ZipEntry("index.py"));
             out.write(FUNCTION_SOURCE.getBytes(StandardCharsets.UTF_8));
             out.closeEntry();
         } catch (IOException e) {
@@ -127,12 +124,9 @@ static byte[] createFunctionZip() {
         return baos.toByteArray();
     }
 
-    private static final String FUNCTION_SOURCE = "exports.handler = function(event, context, callback) {\n"
-            + "   console.log(\"Received event: \", event);\n"
-            + "   var data = {\n"
-            + "       \"greetings\": \"Hello \" + event.firstName\n"
-            + "   };\n"
-            + "   callback(null, data);\n"
-            + "}\n";
-
+    private static final String FUNCTION_SOURCE = "def handler(event, context):\n" +
+            "    message = 'Hello {}'.format(event['firstName'])\n" +
+            "    return {\n" +
+            "        'greetings' : message\n" +
+            "    }\n";
 }