Merge pull request #20 from tiki/release/fix-filter

fix: wildcard filter

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "publish-data-s3"
-version = "0.0.7"
+version = "0.0.8"
 edition = "2021"
 
 [dependencies]

infra/function/template.yml

@@ -17,12 +17,9 @@ Parameters:
     Type: String
     Default: csv
     Description: Enter the source file type (csv).
-  StagePrefix:
+  StageWildcard:
     Type: String
-    Description: Enter the key prefix to filter events by (wildcards allowed)
-  StageSuffix:
-    Type: String
-    Description: Enter the key suffix to filter events by (wildcards allowed)
+    Description: Enter the wildcard syntax to filter events.
   DestBucket:
     Type: String
     Description: Enter the name of the output file bucket.
@@ -47,7 +44,7 @@ Resources:
         EventBridgeRule:
           Type: EventBridgeRule
           Properties:
-            Pattern: !Sub "{\"source\":[\"aws.s3\"],\"detail-type\":[\"Object Created\"],\"detail\":{\"bucket\":{\"name\":[\"mytiki-publish\"]},\"object\":{\"key\":[{\"prefix\":\"${StagePrefix}\"},{\"suffix\":\"${StageSuffix}\"}]}}}"
+            Pattern: !Sub "{\"source\":[\"aws.s3\"],\"detail-type\":[\"Object Created\"],\"detail\":{\"bucket\":{\"name\":[\"mytiki-publish\"]},\"object\":{\"key\":[{\"wildcard\":\"${StageWildcard}\"}]}}}"
             RuleName: !Ref DestTable
             State: ENABLED
       Environment:

src/handler.rs

@@ -14,6 +14,7 @@ use lambda_runtime::{Error, LambdaEvent};
 use processor::Processor;
 
 pub async fn handle(event: LambdaEvent<CloudWatchEvent<S3Entity>>) -> Result<(), Error> {
+    tracing::debug!("{:?}", event);
     let processor = &Processor::new()
         .from_env()
         .auto_schema()