API Migrada

functions/userFunctions.js

@@ -0,0 +1,120 @@
+import pg from 'pg'
+import bcrypt from "bcrypt";
+import { pool } from '../lib/database.js';
+
+
+export const getAllUsers = async (req, res) => {
+  try {
+    const result = await pool.query("SELECT nombre, apellido_pa, apellido_ma, fecha_registro, nombre_carrera, nombre_facultad FROM usuarios JOIN carreras ON usuarios.id_carrera = carreras.id_carrera JOIN facultades ON carreras.id_facultad = facultades.id_facultad;");
+    res.json(result.rows);
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+}
+
+export const getSpecificUser = async (req, res) => {
+  try {
+    const result = await pool.query("SELECT nombre, apellido_pa, apellido_ma, fecha_registro, nombre_carrera, nombre_facultad FROM usuarios  JOIN carreras ON usuarios.id_carrera = carreras.id_carrera JOIN facultades ON carreras.id_facultad = facultades.id_facultad WHERE id_usuario = $1;",
+        [req.params.userId]
+    );
+    res.json(result.rows);
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+}
+
+export const validateForUser = async (req, res) => {
+    try {
+        const { correo_unach, clave } = req.body;
+        const query = await pool.query(`
+            SELECT usuarios.*, carreras.nombre_carrera, facultades.nombre_facultad 
+            FROM usuarios 
+            JOIN carreras ON usuarios.id_carrera = carreras.id_carrera 
+            JOIN facultades ON carreras.id_facultad = facultades.id_facultad 
+            WHERE correo_unach = $1
+        `, [correo_unach]);
+        const user = query.rows[0];
+
+        if (!user) {
+            return res.status(404).json({ error: 'User not found' });
+        }
+
+        const match = await bcrypt.compare(clave, user.clave_hasheada);
+        if (!match) {
+            return res.status(401).json({ error: 'Invalid credentials' });
+        }
+
+        // Clean sensitive data and return user info
+        const userResponse = {
+            id_usuario: user.id_usuario,
+            nombre: user.nombre,
+            apellido_pa: user.apellido_pa,
+            apellido_ma: user.apellido_ma,
+            correo_unach: user.correo_unach,
+            carrera: user.nombre_carrera,
+            facultad: user.nombre_facultad
+        };
+
+        res.json(userResponse);
+    }
+    catch (err) {
+        console.error(err);
+        res.status(500).json({ error: err.message });
+    }
+}
+
+export const editUser = async (req, res) => {
+    try {
+        const { userId } = req.params;
+        const { nombre, apellido_pa, apellido_ma, id_carrera } = req.body;
+        const query = await pool.query(
+            'UPDATE usuarios SET nombre = $1, apellido_pa = $2, apellido_ma = $3, id_carrera = $5 WHERE id_usuario = $4 RETURNING *',
+            [nombre, apellido_pa, apellido_ma, userId, id_carrera]
+        );
+        res.json(query.rows[0]);
+    }
+    catch (err) {
+        console.error(err);
+        res.status(500).json({ error: err.message });
+        throw err;
+    }
+}
+
+export const deleteUser = async (req, res) => {
+    try {
+        const { userId } = req.params;
+        const query = await pool.query(
+            'DELETE FROM usuarios WHERE id_usuario = $1 RETURNING *',
+            [userId]
+        );
+        res.json({ message: `User ${userId} deleted`, user: query.rows[0] });
+    }
+    catch (err) {
+        console.error(err);
+        res.status(500).json({ error: err.message });
+        throw err;
+    }
+}
+
+export const createNewUser = async (req,res) => {
+    try {
+        const { correo_unach, clave, matricula, nombre, apellido_pa, apellido_ma, id_carrera } = req.body;
+        const query = await pool.query(
+            'INSERT INTO public.Usuarios (correo_unach, clave_hasheada, matricula, nombre, apellido_ma, apellido_pa, id_carrera) VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING *',
+            [correo_unach, hashPassword(clave), matricula, nombre, apellido_ma, apellido_pa, id_carrera]
+        );
+        console.log(`Creado el usuario: ${JSON.stringify(query.rows[0])}`);
+        res.json(query.rows[0]);
+    }
+    catch (err) {
+        console.error(err);
+        res.status(500).json({ error: err.message });
+        throw err;
+    }
+}
+
+function hashPassword(password) {
+    const saltRounds = 15;
+    const salt = bcrypt.genSaltSync(saltRounds);
+    return bcrypt.hashSync(password, salt);
+}