feat: adding processor

wasedatime · Sep 30, 2023 · b71b6ef · b71b6ef
1 parent 97bae4e
commit b71b6ef
Showing 1 changed file with 22 additions and 22 deletions.
diff --git a/lib/constructs/persistence/data-pipeline.ts b/lib/constructs/persistence/data-pipeline.ts
@@ -243,28 +243,28 @@ export class ThreadImgDataPipeline extends AbstractDataPipeline {
     });
     this.dataWarehouse.addToResourcePolicy(publicReadStatement);
 
-    // this.processor = new ThreadImageProcessFunctions(
-    //   this,
-    //   'image-process-func',
-    //   {
-    //     envVars: {
-    //       INPUT_BUCKET: this.dataSource.bucketName,
-    //       OUTPUT_BUCKET: this.dataWarehouse.bucketName,
-    //       TABLE_NAME: 'wasedatime-thread-img',
-    //     },
-    //   },
-    // ).resizeImageFunction;
-
-    // const supportedExtensions = ['jpeg', 'png', 'gif', 'jpg'];
-
-    // for (const ext of supportedExtensions) {
-    //   this.processor.addEventSource(
-    //     new event_sources.S3EventSource(this.dataSource, {
-    //       events: [s3.EventType.OBJECT_CREATED_PUT],
-    //       filters: [{ prefix: `/image.${ext}` }],
-    //     }),
-    //   );
-    // }
+    this.processor = new ThreadImageProcessFunctions(
+      this,
+      'image-process-func',
+      {
+        envVars: {
+          INPUT_BUCKET: this.dataSource.bucketName,
+          OUTPUT_BUCKET: this.dataWarehouse.bucketName,
+          TABLE_NAME: 'wasedatime-thread-img',
+        },
+      },
+    ).resizeImageFunction;
+
+    const supportedExtensions = ['jpeg', 'png', 'gif', 'jpg'];
+
+    for (const ext of supportedExtensions) {
+      this.processor.addEventSource(
+        new event_sources.S3EventSource(this.dataSource, {
+          events: [s3.EventType.OBJECT_CREATED_PUT],
+          filters: [{ prefix: `/image.${ext}` }],
+        }),
+      );
+    }
   }
 }