chore: Migrate AWS tests from LocalStack to Floci and add sink tests

tests/camel-kamelets-itest/pom.xml

@@ -98,6 +98,11 @@
             <artifactId>camel-aws2-eventbridge</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-aws2-sns</artifactId>
+            <scope>test</scope>
+        </dependency>
 
         <!-- Citrus -->
         <dependency>

tests/camel-kamelets-itest/src/test/java/AwsIT.java

@@ -84,4 +84,9 @@ public Stream<DynamicTest> awsEventBridge() {
         return CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("aws.eventbridge");
     }
 
+    @CitrusTestFactory
+    public Stream<DynamicTest> awsSns() {
+        return CitrusTestFactorySupport.factory(TestLoader.YAML).packageScan("aws.sns");
+    }
+
 }

tests/camel-kamelets-itest/src/test/resources-filtered/citrus-application.properties

@@ -32,6 +32,10 @@ citrus.camel.jbang.kamelets.version=${project.version}
 # Enable dump of Camel JBang integration output
 citrus.camel.jbang.dump.integration.output=true
 
+# Use Floci as the AWS emulator (drop-in replacement for LocalStack)
+citrus.testcontainers.localstack.image.name=floci/floci
+citrus.testcontainers.localstack.version=latest
+
 # Use general registry mirror for Docker images (e.g. Testcontainers)
 citrus.testcontainers.registry.mirror=mirror.gcr.io
 citrus.testcontainers.registry.mirror.enabled=false

tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-delete-item.citrus.it.yaml.disabled

@@ -26,7 +26,7 @@ variables:
   - name: "timer.source.period"
     value: "10000"
 actions:
-  # Create LocalStack infrastructure
+  # Create AWS infrastructure (Floci container)
   - testcontainers:
       start:
         localstack:
@@ -86,7 +86,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/ddb/aws-ddb-sink-pipe.yaml"
+            file: "aws/ddb/aws-ddb-sink-route.yaml"
             systemProperties:
               properties:
                 - name: "timer.source.period"

tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-put-item.citrus.it.yaml.disabled

@@ -26,7 +26,7 @@ variables:
   - name: "timer.source.period"
     value: "10000"
 actions:
-  # Create LocalStack infrastructure
+  # Create AWS infrastructure (Floci container)
   - testcontainers:
       start:
         localstack:
@@ -73,7 +73,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/ddb/aws-ddb-sink-pipe.yaml"
+            file: "aws/ddb/aws-ddb-sink-route.yaml"
             systemProperties:
               properties:
                 - name: "timer.source.period"

tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-pipe.yaml → tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-route.yaml

@@ -15,27 +15,25 @@
 # limitations under the License.
 # ---------------------------------------------------------------------------
 
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
-  name: aws-sqs-event-listener-pipe
-spec:
-  source:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: aws-sqs-source
-    properties:
-      queueNameOrArn: "{{aws.sqs.queueName}}"
-      uriEndpointOverride: "{{aws.eventbridge.uriEndpointOverride}}"
-      overrideEndpoint: "{{aws.eventbridge.overrideEndpoint}}"
-      accessKey: "{{aws.eventbridge.accessKey}}"
-      secretKey: "{{aws.eventbridge.secretKey}}"
-      region: "{{aws.eventbridge.region}}"
-  sink:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: log-sink
-    properties:
-      showHeaders: true
+- route:
+    from:
+      uri: "timer:tick"
+      parameters:
+        period: "{{timer.source.period}}"
+        repeatCount: 1
+      steps:
+      - setBody:
+          constant: "{{aws.ddb.json.data}}"
+      - log:
+          message: "${body}"
+          showHeaders: true
+      - to:
+          uri: "kamelet:aws-ddb-sink"
+          parameters:
+            table: "{{aws.ddb.tableName}}"
+            operation: "{{aws.ddb.operation}}"
+            overrideEndpoint: "{{aws.ddb.overrideEndpoint}}"
+            uriEndpointOverride: "{{aws.ddb.uriEndpointOverride}}"
+            accessKey: "{{aws.ddb.accessKey}}"
+            secretKey: "{{aws.ddb.secretKey}}"
+            region: "{{aws.ddb.region}}"

tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-update-item.citrus.it.yaml.disabled

@@ -26,7 +26,7 @@ variables:
   - name: "timer.source.period"
     value: "10000"
 actions:
-  # Create LocalStack infrastructure
+  # Create AWS infrastructure (Floci container)
   - testcontainers:
       start:
         localstack:
@@ -91,7 +91,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/ddb/aws-ddb-sink-pipe.yaml"
+            file: "aws/ddb/aws-ddb-sink-route.yaml"
             systemProperties:
               properties:
                 - name: "timer.source.period"

tests/camel-kamelets-itest/src/test/resources/aws/sqs/aws-sqs-uri-pipe.yaml → tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-source-route.yaml

@@ -15,27 +15,19 @@
 # limitations under the License.
 # ---------------------------------------------------------------------------
 
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
-  name: aws-sqs-uri-pipe
-spec:
-  source:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: aws-sqs-source
-    properties:
-      queueNameOrArn: "{{aws.sqs.queueName}}"
-      uriEndpointOverride: "{{aws.sqs.uriEndpointOverride}}"
-      overrideEndpoint: "{{aws.sqs.overrideEndpoint}}"
-      accessKey: "{{aws.sqs.accessKey}}"
-      secretKey: "{{aws.sqs.secretKey}}"
-      region: "{{aws.sqs.region}}"
-  sink:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: log-sink
-    properties:
-      showHeaders: true
+- route:
+    from:
+      uri: "kamelet:aws-ddb-streams-source"
+      parameters:
+        streamIteratorType: "FROM_START"
+        table: "{{aws.ddb.tableName}}"
+        overrideEndpoint: "{{aws.ddb.overrideEndpoint}}"
+        uriEndpointOverride: "{{aws.ddb.uriEndpointOverride}}"
+        accessKey: "{{aws.ddb.accessKey}}"
+        secretKey: "{{aws.ddb.secretKey}}"
+        region: "{{aws.ddb.region}}"
+      steps:
+      - to:
+          uri: "kamelet:log-sink"
+          parameters:
+            showHeaders: true

tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-source.citrus.it.yaml.disabled

@@ -30,7 +30,7 @@ variables:
   - name: "aws.ddb.item.title"
     value: "Star Wars IV"
 actions:
-  # Create LocalStack infrastructure
+  # Create AWS infrastructure (Floci container)
   - testcontainers:
       start:
         localstack:
@@ -50,7 +50,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/ddb/aws-ddb-source-pipe.yaml"
+            file: "aws/ddb/aws-ddb-source-route.yaml"
             systemProperties:
               file: "aws/ddb/application.properties"
 
@@ -62,6 +62,6 @@ actions:
   - camel:
       jbang:
         verify:
-          integration: "aws-ddb-source-pipe"
+          integration: "aws-ddb-source-route"
           logMessage: |
             "Star Wars IV"

tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-pipe.yaml → tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-eventbridge-sink-route.yaml

@@ -15,36 +15,26 @@
 # limitations under the License.
 # ---------------------------------------------------------------------------
 
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
-  name: aws-ddb-sink-pipe
-spec:
-  source:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: timer-source
-    properties:
-      period: "{{timer.source.period}}"
-      message: "{{aws.ddb.json.data}}"
-  steps:
-    - ref:
-        kind: Kamelet
-        apiVersion: camel.apache.org/v1
-        name: log-action
-      properties:
-        showHeaders: true
-  sink:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: aws-ddb-sink
-    properties:
-      table: "{{aws.ddb.tableName}}"
-      operation: "{{aws.ddb.operation}}"
-      overrideEndpoint: "{{aws.ddb.overrideEndpoint}}"
-      uriEndpointOverride: "{{aws.ddb.uriEndpointOverride}}"
-      accessKey: "{{aws.ddb.accessKey}}"
-      secretKey: "{{aws.ddb.secretKey}}"
-      region: "{{aws.ddb.region}}"
+- route:
+    from:
+      uri: "timer:tick"
+      parameters:
+        period: "{{timer.source.period}}"
+        repeatCount: 1
+      steps:
+      - setBody:
+          constant: "{{aws.eventbridge.json.data}}"
+      - log: "${body}"
+      - to:
+          uri: "kamelet:aws-eventbridge-sink"
+          parameters:
+            eventbusNameOrArn: "{{aws.eventbridge.eventbusName}}"
+            overrideEndpoint: "{{aws.eventbridge.overrideEndpoint}}"
+            uriEndpointOverride: "{{aws.eventbridge.uriEndpointOverride}}"
+            accessKey: "{{aws.eventbridge.accessKey}}"
+            secretKey: "{{aws.eventbridge.secretKey}}"
+            region: "{{aws.eventbridge.region}}"
+            resourcesArn: "{{aws.eventbridge.resourcesArn}}"
+            eventSource: "{{aws.eventbridge.eventSource}}"
+            eventSourcePrefix: "{{aws.eventbridge.eventSourcePrefix}}"
+            detailType: "{{aws.eventbridge.detailType}}"

tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-eventbridge-sink.citrus.it.yaml

@@ -37,7 +37,7 @@ variables:
   - name: "timer.source.period"
     value: "10000"
 actions:
-  # Create LocalStack infrastructure
+  # Create AWS infrastructure (Floci container)
   - testcontainers:
       start:
         localstack:
@@ -59,7 +59,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/eventbridge/aws-eventbridge-sink-pipe.yaml"
+            file: "aws/eventbridge/aws-eventbridge-sink-route.yaml"
             systemProperties:
               properties:
                 - name: "timer.source.period"
@@ -73,7 +73,7 @@ actions:
       jbang:
         run:
           integration:
-            file: "aws/eventbridge/aws-sqs-event-listener-pipe.yaml"
+            file: "aws/eventbridge/aws-sqs-event-listener-route.yaml"
             systemProperties:
               properties:
                 - name: "aws.sqs.queueName"
@@ -84,6 +84,6 @@ actions:
   - camel:
       jbang:
         verify:
-          integration: "aws-sqs-event-listener-pipe"
+          integration: "aws-sqs-event-listener-route"
           logMessage: |
             "detail":{"message":"Hello AWS EventBridge!"}

tests/camel-kamelets-itest/src/test/resources/aws/kinesis/aws-kinesis-source-pipe.yaml → tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-route.yaml

@@ -15,27 +15,18 @@
 # limitations under the License.
 # ---------------------------------------------------------------------------
 
-apiVersion: camel.apache.org/v1
-kind: Pipe
-metadata:
-  name: aws-kinesis-source-pipe
-spec:
-  source:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: aws-kinesis-source
-    properties:
-      stream: '{{aws.kinesis.streamName}}'
-      overrideEndpoint: '{{aws.kinesis.overrideEndpoint}}'
-      uriEndpointOverride: '{{aws.kinesis.uriEndpointOverride}}'
-      accessKey: '{{aws.kinesis.accessKey}}'
-      secretKey: '{{aws.kinesis.secretKey}}'
-      region: '{{aws.kinesis.region}}'
-  sink:
-    ref:
-      kind: Kamelet
-      apiVersion: camel.apache.org/v1
-      name: log-sink
-      properties:
-        showHeaders: true
+- route:
+    from:
+      uri: "kamelet:aws-sqs-source"
+      parameters:
+        queueNameOrArn: "{{aws.sqs.queueName}}"
+        uriEndpointOverride: "{{aws.eventbridge.uriEndpointOverride}}"
+        overrideEndpoint: "{{aws.eventbridge.overrideEndpoint}}"
+        accessKey: "{{aws.eventbridge.accessKey}}"
+        secretKey: "{{aws.eventbridge.secretKey}}"
+        region: "{{aws.eventbridge.region}}"
+      steps:
+      - to:
+          uri: "kamelet:log-sink"
+          parameters:
+            showHeaders: true