@amandioca | feat: adiciona endpoint post user e metodo createUser

Author: amandioca

backend/dbService.js

@@ -22,24 +22,34 @@ async function getUsers() {
     try {
         const result = await client.query('SELECT * FROM users');
         return result.rows;
-    } catch (err) {
-        console.error('Error fetching users: ', err);
-        throw new Error('Error fetching users from database');
+    } catch (error) {
+        console.error('Error fetching users: ', error);
+        throw error;
     }
 }
 
 async function getUserByCpf(cpf) {
     try {
         const result = await client.query('SELECT * FROM users WHERE cpf = $1', [cpf]);
-        console.log(result.rows)
         return result.rows;
-    } catch (err) {
-        console.error('Error fetching user by CPF: ', err);
-        throw new Error('Error fetching users from database');
+    } catch (error) {
+        console.error('Error fetching user by CPF: ', error);
+        throw error;
+    }
+}
+
+async function createUser(cpf, fullName, password) {
+    try {
+        const result = await client.query('INSERT INTO users (cpf, full_name, password) VALUES ($1, $2, $3) RETURNING *', [cpf, fullName, password])
+        return result.rows[0];
+    } catch (error) {
+        console.error('Error creating user in database: ', error);
+        throw error;
     }
 }
 
 module.exports = {
     getUsers,
     getUserByCpf,
+    createUser,
 }

backend/index.js

@@ -3,7 +3,6 @@
 require('dotenv').config();
 const express = require('express');
 const dbService = require('./dbService');
-
 const app = express();
 app.use(express.json());
 
@@ -14,25 +13,41 @@ app.listen(PORT, () => {
 });
 
 app.get('/hello-world', (req, res) => {
-    res.send({'message':'hello world!'})
+    res.send({ message: 'hello world!' })
 });
 
-app.get('/users', async (req, res) =>{
+app.get('/users', async (req, res) => {
     try {
         const data = await dbService.getUsers();
         res.json(data);
-    } catch (err) {
-        res.status(500).json({'message':'Connection to the SQL server failed'})
+    } catch (error) {
+        res.status(500).json({ message: 'Connection to the SQL server failed' })
     }
 });
 
-app.get('/users/:cpf', async (req, res) =>{
+app.get('/users/:cpf', async (req, res) => {
     try {
         const user = await dbService.getUserByCpf(req.params.cpf);
         user.length === 1
             ? res.json(user)
-            : res.status(404).send({'message':'User not found'});
-    } catch (err) {
-        res.status(500).json({'message':'Connection to the SQL server failed'})
+            : res.status(404);
+    } catch (error) {
+        res.status(500).json({ message: 'Connection to the SQL server failed' })
+    }
+});
+
+app.post('/users', async (req, res) => {
+    const { cpf, fullName, password } = req.body;
+    try {
+        const createdUser = await dbService.createUser(cpf, fullName, password);
+        const { password: _, ...userData } = createdUser;
+        res.status(201).send(userData)
+    } catch (error) {
+        if (error.code === '23505')
+            res.status(409).send({ message: 'User with this CPF already exists' });
+        else if (error.code === '22001')
+            res.status(400).send({ message: error.message });
+        else
+            res.status(500).send({ message: error.message })
     }
-});
+})