chore: Migrate AWS tests from LocalStack to Floci and add sink tests (#2913)

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

LocalStack's community edition was sunset in March 2026, now requiring
auth tokens. This migrates all AWS integration tests to use Floci, the
MIT-licensed drop-in replacement, via Citrus's native floci support in
citrus-testcontainers.

Also migrates all Pipe-format integration definitions to Camel route
YAML format (issue #2873) and adds new Citrus integration tests for
aws-s3-sink, aws-sqs-sink, and aws-sns-sink kamelets.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Signed-off-by: Andrea Cosentino <ancosen@gmail.com>

* fix: Add camel-aws2-sns test dependency for SNS sink test

The SNS sink test Groovy script imports SnsClient which requires
the camel-aws2-sns dependency on the test classpath. Without it,
all AWS tests fail with ClassNotFoundException.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
Signed-off-by: Andrea Cosentino <ancosen@gmail.com>

---------

Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: oscerd

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"

…tbridge/aws-sqs-event-listener-pipe.yaml …esources/aws/ddb/aws-ddb-sink-route.yamltests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-pipe.yaml renamed to tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-sink-route.yaml tests/camel-kamelets-itest/src/test/resources/aws/eventbridge/aws-sqs-event-listener-pipe.yaml renamed to 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"

…/resources/aws/sqs/aws-sqs-uri-pipe.yaml …ources/aws/ddb/aws-ddb-source-route.yamltests/camel-kamelets-itest/src/test/resources/aws/sqs/aws-sqs-uri-pipe.yaml renamed to tests/camel-kamelets-itest/src/test/resources/aws/ddb/aws-ddb-source-route.yaml tests/camel-kamelets-itest/src/test/resources/aws/sqs/aws-sqs-uri-pipe.yaml renamed to 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"