feat(S3): init handler to list all objetcs of bucket

Author: douglasfdev

src/api/modules/v1/components/AWS/s3.component.ts

@@ -3,8 +3,9 @@ import {
   CreateBucketOutput,
   CreateBucketRequest,
   PutObjectOutput,
-  S3,
   GetObjectOutput,
+  ListObjectsOutput,
+  S3,
 } from "$deps";
 import {
   env,
@@ -71,6 +72,24 @@ export class SimpleCloudStorage {
     }
   }
 
+  public async listObjects(): Promise<ListObjectsOutput | undefined> {
+    return this.handleListObjects();
+  }
+
+  private async handleListObjects() {
+    const s3 = this.makeNewBucket();
+
+    try {
+      const listObjects = await s3.listObjects({
+        Bucket: this.bucketName,
+      });
+
+      return listObjects;
+    } catch (er) {
+      log.error(er.message);
+    }
+  }
+
   public async downloadFileFromS3(objectKey: string): Promise<string | undefined> {
     return this.handleDownloadFile(objectKey);
   }

src/api/modules/v1/components/Commands/Slinger.ts

@@ -3,6 +3,7 @@ import { PersonService } from "$service/person/PersonService.ts";
 import {
   everyMinute,
   every15Minute,
+  start
 } from '$deps';
 
 export class Slinger {
@@ -11,8 +12,9 @@ export class Slinger {
   }
 
   private init() {
-    this.handleDisareByMinute();
+    // this.handleDisareByMinute();
     this.handleDispareByFiftyMinute();
+    start();
   }
 
   private handleDisareByMinute() {
@@ -22,7 +24,7 @@ export class Slinger {
   }
 
   private handleDispareByFiftyMinute() {
-    every15Minute(async () => {
+    everyMinute(async () => {
       await new PersonService().listenAndInsertPersonFromQueue();
     });
   }

src/deps/index.ts

@@ -24,7 +24,8 @@ export {
 export {
   type CreateBucketOutput,
   type CreateBucketRequest,
-  type PutObjectOutput
+  type PutObjectOutput,
+  type ListObjectsOutput,
 } from "https://deno.land/x/[email protected]/services/s3/structs.ts";
 
 export {
@@ -53,7 +54,8 @@ export {
   daily,
   monthly,
   weekly,
-  yearly
+  yearly,
+  start
 } from "https://deno.land/x/[email protected]/cron.ts";
 
 export {