feat(S3): list all objects uploaded to S3

Author: douglasfdev

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

@@ -4,7 +4,7 @@ import {
   CreateBucketRequest,
   PutObjectOutput,
   GetObjectOutput,
-  ListObjectsOutput,
+  _Object,
   S3,
 } from "$deps";
 import {
@@ -72,19 +72,19 @@ export class SimpleCloudStorage {
     }
   }
 
-  public async listObjects(): Promise<ListObjectsOutput | undefined> {
+  public async listObjects() {
     return this.handleListObjects();
   }
 
-  private async handleListObjects() {
+  private async handleListObjects(): Promise<Array<_Object> | undefined> {
     const s3 = this.makeNewBucket();
 
     try {
-      const listObjects = await s3.listObjects({
+      const listObjects = await s3.listObjectsV2({
         Bucket: this.bucketName,
       });
 
-      return listObjects;
+      return listObjects.Contents;
     } catch (er) {
       log.error(er.message);
     }

src/api/modules/v1/controllers/files/FileController.ts

@@ -52,6 +52,16 @@ class Files implements IFileController {
       log.error(er.message);
     }
   }
+
+  public async listAllObjectsBuckets(ctx: RouterContext<string>) {
+    try {
+      ctx.response.status = Status.OK;
+      return ctx.response.body = await FileService.listAllObjectsFromBucket()
+    } catch (er) {
+      ctx.response.status = Status.BadRequest;
+      log.error(er.message);
+    }
+  }
 }
 
 export default new Files();

src/api/modules/v1/repository/File/FileRespository.ts

@@ -46,6 +46,7 @@ class FileRepository extends File {
     return this.mysql.buildQuery(
       `
         SELECT
+          id,
           name,
           status
         FROM ${this.table}
@@ -54,17 +55,17 @@ class FileRepository extends File {
     );
   }
 
-  public updatedAfterListenAll() {
-    return this.updateStatusAfterListenAll();
+  public updatedAfterListenAll(id: string) {
+    return this.updateStatusAfterListenAll(id);
   }
 
-  private updateStatusAfterListenAll() {
+  private updateStatusAfterListenAll(id: string) {
     return this.mysql.buildQuery(
       `
         UPDATE ${this.table}
         SET status = ?
-        WHERE status = ?;
-      `, [FilenameEnum.LAUNCHED, FilenameEnum.PENDING]
+        WHERE id = ?;
+      `, [FilenameEnum.LAUNCHED, id]
     );
   }
 }

src/api/modules/v1/routes/file.ts

@@ -6,5 +6,6 @@ const file = new Router();
 file.post("uploadFile/", FileController.uploadCsv);
 file.get("listAllFiles/", FileController.listAllFiles);
 file.get("listenAllFiles/", FileController.listenFiles)
+file.get("listAllObjectsBuckets/", FileController.listAllObjectsBuckets)
 
 export { file };

src/api/modules/v1/services/file/FileService.ts

@@ -1,4 +1,4 @@
-import { FormDataFile } from "$deps";
+import { FormDataFile, _Object } from "$deps";
 import { S3 } from "$components";
 import {
   FilenameEnum,
@@ -69,15 +69,28 @@ export class FileService implements IFileService {
     );
 
     for (const pending of pendings) {
-      if (pending.status === 0) {
+      if (pending.status === FilenameEnum.PENDING) {
         this.personService.listenAndCreatePerson(pending.name);
-        await this.fileRepository.updatedAfterListenAll();
+        await this.fileRepository.updatedAfterListenAll(pending.id)
         continue;
       };
     }
 
     return files;
   }
+
+  public async listAllObjectsFromBucket() {
+    const objects = await this.s3.listObjects() as Array<_Object>;
+
+    const objectsFiltered = objects.map(object => {
+        return {
+          name: object.Key,
+          size: object.Size,
+        }
+    });
+
+    return objectsFiltered;
+  }
 }
 
 export default new FileService()

src/deps/index.ts

@@ -26,6 +26,7 @@ export {
   type CreateBucketRequest,
   type PutObjectOutput,
   type ListObjectsOutput,
+  type _Object,
 } from "https://deno.land/x/[email protected]/services/s3/structs.ts";
 
 export {