feat(bucket): add table to insert filename bucket on database and list all

douglasfdev · douglasfdev · commit 57a4de04337d · 2023-11-05T19:31:36.000-03:00
diff --git a/src/api/db/migrations/create_tb_filename.ts b/src/api/db/migrations/create_tb_filename.ts
@@ -0,0 +1,19 @@
+import { mySqlConfig } from "../../../common/mysql.config.ts";
+import { client } from "../connection.ts";
+
+await client.connect(mySqlConfig);
+
+client.query(
+  `
+    CREATE TABLE IF NOT EXISTS tb_filename (
+      id VARCHAR(255) DEFAULT(UUID_TO_BIN(UUID())),
+      name VARCHAR(255) NOT NULL,
+      created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+      updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+      deleted_at TIMESTAMP DEFAULT NULL,
+      PRIMARY KEY (id),
+      INDEX idx_id (id),
+      INDEX idx_name (name)
+    );
+  `
+);
diff --git a/src/api/db/migrations/create_tb_pessoa.ts b/src/api/db/migrations/create_tb_pessoa.ts
@@ -12,7 +12,11 @@ client.query(
       sex ENUM("M", "F", "O") NOT NULL,
       size DECIMAL(5,2) NOT NULL,
       weight DECIMAL(5,2) NOT NULL,
+      created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+      updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+      deleted_at TIMESTAMP DEFAULT NULL,
       PRIMARY KEY (id),
+      INDEX idx_id (id),
       INDEX idx_name (name),
       INDEX idx_age (age),
       INDEX idx_sex (sex),
diff --git a/src/api/db/migrations/index.ts b/src/api/db/migrations/index.ts
@@ -1 +1,2 @@
 export * from './create_tb_pessoa.ts';
+export * from './create_tb_filename.ts'
diff --git a/src/api/modules/v1/components/aws.component.ts b/src/api/modules/v1/components/aws.component.ts
@@ -16,6 +16,7 @@ class SimpleCloudStorage {
   ) {
     this.s3 = s3;
     this.apiFactory = apiFactory;
+    this.init();
   }
 
   public async init() {
@@ -28,6 +29,7 @@ class SimpleCloudStorage {
 
   private async setBucket(body: Uint8Array, objectKey: string): Promise<PutObjectOutput> {
     const s3 = await this.makeNewBucket();
+
     return s3.putObject({
       Body: body,
       Bucket: this.bucketName,
@@ -117,19 +119,15 @@ await new SimpleCloudStorage(
   new ApiFactory({
     region: awsS3Config.region,
     credentials: awsS3Config,
-    fixedEndpoint: 'http://localhost:4566'
+    fixedEndpoint: env.AWS_ENDPOINT,
   }),
 ).init();
 
 export default new SimpleCloudStorage(
-  new S3(new ApiFactory({
-    region: awsS3Config.region,
-    credentials: awsS3Config,
-    fixedEndpoint: 'http://localhost:4566'
-  }
-  )),
+  new S3(new ApiFactory()),
   new ApiFactory({
     region: awsS3Config.region,
     credentials: awsS3Config,
+    fixedEndpoint: env.AWS_ENDPOINT,
   })
 );
diff --git a/src/api/modules/v1/controllers/files/FileController.ts b/src/api/modules/v1/controllers/files/FileController.ts
@@ -6,13 +6,13 @@ import { IFileController } from "../../../../../common/interfaces/index.ts";
 
 
 class Files implements IFileController {
-  public async uploadCsvCoordinator(ctx: RouterContext<string>): Promise<void> {
+  public async uploadCsv(ctx: RouterContext<string>): Promise<void> {
     try {
       const formData = ctx.request.body({ type: "form-data" });
       const body = await formData.value.read();
 
       if (body.files) {
-       await FileService.handlerFilesCoordinator(body.files);
+       await FileService.handlerFilesPerson(body.files);
 
         ctx.response.status = Status.Created;
         ctx.response.body = {
@@ -28,6 +28,19 @@ class Files implements IFileController {
       log.error(er.message);
     }
   }
+
+  public async listAllFiles(ctx: RouterContext<string>) {
+    try {
+      ctx.response.status = Status.OK;
+      ctx.response.body = await FileService.listFiles();
+    } catch (er: Error | any | unknown) {
+      ctx.response.status = Status.BadRequest;
+      ctx.response.body = {
+        error: er.message,
+      };
+      log.error(er.message);
+    }
+  }
 }
 
 export default new Files();
diff --git a/src/api/modules/v1/models/file/File.ts b/src/api/modules/v1/models/file/File.ts
@@ -0,0 +1,8 @@
+import { IFileDTO } from "../../../../../common/interfaces/index.ts";
+
+export class File implements IFileDTO {
+  id!: string;
+  name!: string;
+}
+
+export default new File();
diff --git a/src/api/modules/v1/models/index.ts b/src/api/modules/v1/models/index.ts
@@ -0,0 +1,7 @@
+import Person from "./person/Person.ts";
+import File from "./file/File.ts";
+
+export {
+  Person,
+  File,
+}
diff --git a/src/api/modules/v1/repository/File/FileRespository.ts b/src/api/modules/v1/repository/File/FileRespository.ts
@@ -0,0 +1,41 @@
+import { IFileDTO } from "../../../../../common/interfaces/index.ts";
+import { client } from "../../../../db/connection.ts";
+import { File } from "../../models/file/File.ts";
+
+class FileRepository extends File {
+  public table: string = 'tb_filename';
+
+  public async handleCreate(file: string): Promise<IFileDTO> {
+    return this.create(file);
+  }
+
+  private async create(file: string): Promise<IFileDTO> {
+    const q = `
+        INSERT INTO ${this.table} (
+          id,
+          name
+        ) VALUES (
+          UUID(),
+          ?
+        );
+      `;
+
+    return await client.query(q, [file.replace(/\n/, "")]);
+  }
+
+  public async list(): Promise<Array<IFileDTO>> {
+    return this.listAll();
+  }
+
+  private async listAll(): Promise<Array<IFileDTO>> {
+    return client.query(`
+      SELECT
+        id,
+        name,
+        created_at
+      FROM ${this.table};
+    `);
+  }
+}
+
+export default new FileRepository();
diff --git a/src/api/modules/v1/repository/Person/PersonRepository.ts b/src/api/modules/v1/repository/Person/PersonRepository.ts
@@ -1,14 +1,12 @@
 import { client } from '../../../../db/connection.ts';
 
 class PersonRepository {
-  public table() {
-    return 'tb_person';
-  };
+  public table: string = 'tb_person';
 
   public listPersons() {
     return client.query(
       `
-        SELECT * FROM ${this.table()};
+        SELECT * FROM ${this.table};
       `
     );
   }
diff --git a/src/api/modules/v1/repository/index.ts b/src/api/modules/v1/repository/index.ts
@@ -0,0 +1,7 @@
+import PersonRepository from "./Person/PersonRepository.ts";
+import FileRespository from "./File/FileRespository.ts";
+
+export {
+  PersonRepository,
+  FileRespository,
+}
diff --git a/src/api/modules/v1/routes/file.ts b/src/api/modules/v1/routes/file.ts
@@ -3,6 +3,7 @@ import { FileController } from "../controllers/index.ts";
 
 const file = new Router();
 
-file.post("uploadFile/", FileController.uploadCsvCoordinator)
+file.post("uploadFile/", FileController.uploadCsv);
+file.get("listAll/", FileController.listAllFiles);
 
 export { file };
diff --git a/src/api/modules/v1/services/file/FileService.ts b/src/api/modules/v1/services/file/FileService.ts
@@ -1,27 +1,31 @@
 import { FormDataFile } from "https://deno.land/x/oak@v12.6.1/mod.ts";
 import SimpleCloudStorage from "../../components/aws.component.ts";
-import { IFileService } from '../../../../../common/interfaces/index.ts';
+import { IFileDTO, IFileService } from '../../../../../common/interfaces/index.ts';
+import { FileRespository } from "../../repository/index.ts";
 
 class FileService implements IFileService {
   private s3: typeof SimpleCloudStorage;
+  private fileRepository: typeof FileRespository;
+
   constructor(s3: typeof SimpleCloudStorage) {
     this.s3 = s3;
+    this.fileRepository = FileRespository;
   }
 
-  public async handlerFilesCoordinator(files: Array<FormDataFile>): Promise<void> {
-    return this.processFilesCoordinator(files);
+  public async handlerFilesPerson(files: Array<FormDataFile>): Promise<void> {
+    return this.processFilesPerson(files);
   }
 
-  private async processFilesCoordinator(files: Array<FormDataFile>): Promise<void> {
-    const emailsCoordinator: Array<string> = []
-    const emailsCoordinated: Array<string> = []
+  private async processFilesPerson(files: Array<FormDataFile>): Promise<void> {
+    const person: Array<string> = [];
 
     for (const file of files) {
       const isTypeCsvOrXml = file.contentType === "text/csv" ||
         file.contentType === "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet";
 
       if (isTypeCsvOrXml) {
-        const filename = `Coordinator-${crypto.randomUUID()}.csv`;
+        const filename = `${crypto.randomUUID()}.csv`;
+
         const read = await Deno.readFile(String(file.filename));
 
         const decoder = new TextDecoder("utf-8");
@@ -31,16 +35,22 @@ class FileService implements IFileService {
         const whithoutHeader = new TextEncoder().encode(lines.join("\n"));
 
         await this.s3.handlerBucket(whithoutHeader, filename);
+
         const readS3 = await this.s3.readFileFromS3(filename) as Array<string>;
 
+        await this.fileRepository.handleCreate(filename);
+
         for (const result of readS3) {
-          const [coordinatedEmails, coordinatorEmails, Coordinator] = result.split(",");
-          emailsCoordinated.push(coordinatedEmails);
-          emailsCoordinator.push(coordinatorEmails);
+          const [name, age, sex, size, weight] = result.split(",");
+          console.log(result.split(','))
         }
       }
     }
   }
+
+  public async listFiles(): Promise<Array<IFileDTO>> {
+    return this.fileRepository.list();
+  }
 }
 
 export default new FileService(SimpleCloudStorage)
diff --git a/src/common/interfaces/IFIleController.ts b/src/common/interfaces/IFIleController.ts
@@ -1,4 +1,4 @@
 import { RouterContext } from 'https://deno.land/x/oak@v12.6.1/mod.ts';
 export interface IFileController {
-  uploadCsvCoordinator(ctx: RouterContext<string>): Promise<void>;
+  uploadCsv(ctx: RouterContext<string>): Promise<void>;
 }
diff --git a/src/common/interfaces/IFileDTO.ts b/src/common/interfaces/IFileDTO.ts
@@ -0,0 +1,7 @@
+export interface IFileDTO {
+  id: string;
+  name: string;
+  created_at?: Date;
+  updated_at?: Date;
+  deleted_at?: Date;
+};
diff --git a/src/common/interfaces/IFleService.ts b/src/common/interfaces/IFleService.ts
@@ -1,5 +1,5 @@
 import { FormDataFile } from 'https://deno.land/x/oak@v12.6.1/mod.ts';
 import { PutObjectOutput } from 'https://deno.land/x/aws_api@v0.8.1/services/s3/structs.ts';
 export interface IFileService {
-  handlerFilesCoordinator(files: Array<FormDataFile>): Promise<void>
+  handlerFilesPerson(files: Array<FormDataFile>): Promise<void>
 }
diff --git a/src/common/interfaces/IPerson.ts b/src/common/interfaces/IPerson.ts
@@ -7,4 +7,7 @@ export interface IPersonDTO {
   sex: PersonEnum;
   size: number;
   weight: number;
-}
+  created_at?: Date;
+  updated_at?: Date;
+  deleted_at?: Date;
+};
diff --git a/src/common/interfaces/index.ts b/src/common/interfaces/index.ts
@@ -1,3 +1,4 @@
 export * from "./IPerson.ts";
 export * from "./IFleService.ts";
 export * from "./IFIleController.ts";
+export * from './IFileDTO.ts';
diff --git a/src/environments/development.env b/src/environments/development.env
@@ -12,4 +12,5 @@ MYSQL_ROOT_PASSWORD=p@a55w0rd
 AWS_ACCESS_KEY_ID=fakeAccessKeyId
 AWS_SECRET_ACCESS_KEY=fakeSecretAccessKey
 AWS_REGION="us-east-1"
-S3_BUCKET_NAME=person
+S3_BUCKET_NAME=person
+AWS_ENDPOINT="http://localhost:4566/health"
diff --git a/src/environments/local.env b/src/environments/local.env
@@ -12,4 +12,5 @@ MYSQL_ROOT_PASSWORD=p@a55w0rd
 AWS_ACCESS_KEY_ID=fakeAccessKeyId
 AWS_SECRET_ACCESS_KEY=fakeSecretAccessKey
 AWS_REGION="us-east-1"
-S3_BUCKET_NAME=person
+S3_BUCKET_NAME=person
+AWS_ENDPOINT="http://localhost:4566/health"
diff --git a/src/environments/production.env b/src/environments/production.env
@@ -12,4 +12,5 @@ MYSQL_ROOT_PASSWORD=p@a55w0rd
 AWS_ACCESS_KEY_ID=fakeAccessKeyId
 AWS_SECRET_ACCESS_KEY=fakeSecretAccessKey
 AWS_REGION="us-east-1"
-S3_BUCKET_NAME=person
+S3_BUCKET_NAME=person
+AWS_ENDPOINT="http://localhost:4566/health"

Original file line number	Diff line number	Diff line change
`@@ -1 +1,2 @@`
`1`	`1`	`export * from './create_tb_pessoa.ts';`
	`2`	`+export * from './create_tb_filename.ts'`
Original file line number	Diff line number	Diff line change
`@@ -1,14 +1,12 @@`
`1`	`1`	`import { client } from '../../../../db/connection.ts';`
`2`	`2`
`3`	`3`	`class PersonRepository {`
`4`		`- public table() {`
`5`		`- return 'tb_person';`
`6`		`- };`
	`4`	`+ public table: string = 'tb_person';`
`7`	`5`
`8`	`6`	`public listPersons() {`
`9`	`7`	`return client.query(`
`10`	`8`	`
`11`		`- SELECT * FROM ${this.table()};`
	`9`	`+ SELECT * FROM ${this.table};`
`12`	`10`	`
`13`	`11`	`);`
`14`	`12`	`}`