feat/implement business roles

src/app/operations/product/createProductOperation.js

@@ -1,6 +1,15 @@
-module.exports = ({ createProductUsecase }) => ({
+module.exports = ({ createProductUsecase, createWarehouseUsecase, bindingProductWarehouse }) => ({
   execute: async (data) => {
-    const response = await createProductUsecase.execute(data);
-    return response;
+    const { warehouse } = data;
+    const product = await createProductUsecase.execute(data);
+    if (!product) {
+      return;
+    }
+    if (warehouse) {
+      const warehouseCretead = await Promise.all(warehouse.map((element) => createWarehouseUsecase.execute(element)));
+      // TODO: validate warehouseCreated
+      await bindingProductWarehouse.execute(product.id, warehouseCretead);
+    }
+    return product;
   }
 });

src/app/usecases/bindingProductWarehouse.js

@@ -0,0 +1,15 @@
+module.exports = ({ createProductWarehouseUsecase }) => ({
+  execute: async (productId, warehouseIds) => {
+    const bind = [];
+    if (Array.isArray(warehouseIds) === false) {
+      const created = await createProductWarehouseUsecase.execute({ productId, warehouseIds });
+      bind.push(created);
+      return bind;
+    }
+    for (const { id } of warehouseIds) {
+      const created = await createProductWarehouseUsecase.execute({ productId, warehouseId: id });
+      bind.push(created);
+    }
+    return bind;
+  }
+});

src/app/usecases/createProductWarehouseUsecase.js

@@ -0,0 +1,6 @@
+module.exports = ({ productWarehouseRepository }) => ({
+  execute: async (data) => {
+    const response = await productWarehouseRepository.create(data);
+    return response;
+  }
+});

src/app/usecases/createWarehouseUsecase.js

@@ -0,0 +1,6 @@
+module.exports = ({ warehouseRepository }) => ({
+  execute: async (data) => {
+    const response = await warehouseRepository.create(data);
+    return response;
+  }
+});

src/domain/entities/Warehouse.js

@@ -17,4 +17,11 @@ const Warehouse = attributes({
   type: { ...types.required_number }
 })(class Warehouse {});
 
-module.exports = Warehouse;
+const WarehouseOutput = attributes({
+  id: { ...types.required_number },
+  locality: { ...types.required_string },
+  quantity: Number,
+  type: { ...types.required_number }
+})(class Warehouse {});
+
+module.exports = { Warehouse, WarehouseOutput };

src/infra/repositories/Repository.js

@@ -8,7 +8,6 @@ class Repository {
   async create(domainEntity) {
     const model = await new this.ResourceModel(this.ResourceMapper.toInputDatabase(domainEntity));
     const dbCreatedResource = await model.save();
-    console.log('dbCreatedResource', dbCreatedResource);
     return this.ResourceMapper.toOutputDabase(dbCreatedResource);
   }
 

src/infra/repositories/productWarehouse/ProductWarehouseMapper.js

@@ -0,0 +1,13 @@
+// const { Warehouse, WarehouseOutput } = require('../../../domain/entities/Warehouse');
+
+const ProductWarehouseMapper = {
+  toInputDatabase(entry) {
+    console.log(entry);
+    return entry;
+  },
+  toOutputDabase({ dataValues }) {
+    return dataValues;
+  }
+};
+
+module.exports = () => ProductWarehouseMapper;

src/infra/repositories/productWarehouse/ProductWarehouseRepository.js

@@ -0,0 +1,14 @@
+const Repository = require('../Repository');
+
+class WarehouseRepository extends Repository {
+  constructor({ sequelize, productWarehouseMapper, exceptions }) {
+    const { ProductWarehouse } = sequelize.models;
+    super({
+      ResourceModel: ProductWarehouse,
+      ResourceMapper: productWarehouseMapper,
+      Exceptions: exceptions
+    });
+  }
+}
+
+module.exports = WarehouseRepository;

src/infra/repositories/warehouse/WarehouseMapper.js

@@ -0,0 +1,12 @@
+const { Warehouse, WarehouseOutput } = require('../../../domain/entities/Warehouse');
+
+const WarehouseMapper = {
+  toInputDatabase(entry) {
+    return new Warehouse({ ...entry }).toJSON();
+  },
+  toOutputDabase({ dataValues }) {
+    return new WarehouseOutput({ ...dataValues }).toJSON();
+  }
+};
+
+module.exports = () => WarehouseMapper;

src/infra/repositories/warehouse/WarehouseRepository.js

@@ -0,0 +1,14 @@
+const Repository = require('../Repository');
+
+class WarehouseRepository extends Repository {
+  constructor({ sequelize, warehouseMapper, exceptions }) {
+    const { Warehouse } = sequelize.models;
+    super({
+      ResourceModel: Warehouse,
+      ResourceMapper: warehouseMapper,
+      Exceptions: exceptions
+    });
+  }
+}
+
+module.exports = WarehouseRepository;