feat: add methods to find, create, update and delete products

Author: Victor

src/controllers/ProductController.js

@@ -1,23 +1,71 @@
+import Product from "../models/Product";
+import User from "../models/User";
+
 class ProductController {
     async index(request, response) {
+        const products = await Product.find();
 
+        return response.json(products);
     }
 
     async find(request, response) {
         const { id } = request.params;
+        const result = await Product.find({ where: { id } });
+        const product = result[0];
+
+        if (!product)
+            return response.status(400).json({ erro: 'Product not found!' });
+
+        return response.json(product);
     }
 
     async create(request, response) {
-        const { description } = req.body;
+        const { description, user_id } = request.body;
+
+        if (!description)
+            return response.status(400).json({ error: 'Product description can\'t be null' });
+
+        if (user_id === null)
+            return response.status(400).json({ error: 'User ID can\'t be null' });
+
+        const result = await User.find({ where: { id: user_id } });
+        const user = result[0];
+
+        if (!user)
+            return response.status(400).json({ erro: 'User not found!' });
+
+        const product = await Product.create({ description, user_id });
+
+        return response.status(201).json(product);
     }
 
     async update(request, response) {
         const { id } = request.params;
-        const { description } = req.body;
+        const { description } = request.body;
+        const result = await Product.find({ where: { id } });
+        const product = result[0];
+
+        if (!product)
+            return response.status(400).json({ error: 'Product not found!' });
+
+        if (!description)
+            return response.status(400).json({ error: 'Product description can\'t be null' });
+
+        await Product.update({ description }, { where: { id } });
+
+        return response.status(204).send();
     }
 
     async delete(request, response) {
         const { id } = request.params;
+        const result = await Product.find({ where: { id } });
+        const product = result[0];
+
+        if (!product)
+            return response.status(400).json({ error: 'Product not found!' });
+
+        await Product.delete({ where: { id } });
+        return response.status(204).send();
     }
 }
 

src/models/Product.js

@@ -2,19 +2,93 @@ import { connection as database } from '../config/database';
 
 class Product {
     async find(filters) {
+        let query = 'SELECT * FROM products';
 
+        if (filters)
+            Object.keys(filters).forEach(filter => {
+                query += ` ${filter}`;
+
+                Object.keys(filters[filter]).forEach(field => {
+                    if (filters[filter][field] !== null)
+                        query += ` ${field} = '${filters[filter][field]}'`;
+                    else
+                        query = ` ${field} = null`;
+                });
+            });
+
+        const result = await database.query(query);
+        const products = result.rows;
+
+        return products;
     }
 
     async create(data) {
+        const fields = [];
+        const values = [];
+
+        Object.keys(data).forEach(field => {
+            fields.push(field);
+
+            if (data[field] !== null) {
+                if (Array.isArray(data[field])) {
+                    const newArray = data[field].map(item => `'${item}'`);
+
+                    values.push(`ARRAY[${newArray}]`);
+                } else
+                    values.push(`'${data[field]}'`);
+            } else
+                values.push('null');
+        });
+
+        const query = `INSERT INTO products (${fields.join(', ')}) VALUES (${values.join(', ')}) RETURNING *`;
+        const result = await database.query(query);
+        const user = result.rows[0];
 
+        return user;
     }
 
     async update(data, filters) {
+        const fieldsToUpdate = [];
 
+        Object.keys(data).forEach(field => {
+            fieldsToUpdate.push(`${field} = '${data[field]}'`);
+        });
+
+        let query = `UPDATE products SET ${fieldsToUpdate.join(', ')}`;
+
+        if (filters)
+            Object.keys(filters).forEach(filter => {
+                query += ` ${filter.toUpperCase()}`;
+
+                Object.keys(filters[filter]).forEach(field => {
+                    if (filters[filter][field] !== null)
+                        query += ` ${field} = '${filters[filter][field]}'`;
+                    else
+                        query += ` ${field} = null`;
+                });
+            });
+
+        await database.query(query);
+        return;
     }
 
     async delete(filters) {
+        let query = 'DELETE FROM products';
+
+        if (filters)
+            Object.keys(filters).forEach(filter => {
+                query += ` ${filter.toUpperCase()}`;
+
+                Object.keys(filters[filter]).forEach(field => {
+                    if (filters[filter][field] !== null)
+                        query += ` ${field} = '${filters[filter][field]}'`;
+                    else
+                        query += ` ${field} = null`;
+                });
+            });
 
+        await database.query(query);
+        return;
     }
 }