dao_users.js

"use strict";

class DAOUsers {
    /**
     * Inicializa el DAO de usuarios.
     * 
     * @param {Pool} pool Pool de conexiones MySQL. Todas las operaciones
     *                    sobre la BD se realizarán sobre este pool.
     */
    constructor(pool) {
        this.pool = pool;
    }
    /**
 * Busca en la base de datos la información del usuario que ha insertado el email
 * 
 * @param {string} id Identificador del usuario a buscar
 * @param {function} callback Función que recibirá el objeto error y el resultado
 */
    getUserData(id, callback) {

        this.pool.getConnection((err, connection) => {
            if (err) {
                callback(err);
                return;
            }
            connection.query("SELECT user_id, email, password, name, gender, dateOfBirth, points, image FROM user WHERE user_id=?", [id], (err, usr) => {
                connection.release();
                if (err) {
                    callback(err);
                    return;
                }
                if (usr.length === 0) {
                    callback(null, undefined);
                } else {
                    let edad = null;
                    let date = null;
                    /* Fecha nacimiento */
                    if (usr[0].dateOfBirth != null) {
                        let moment = require ("moment");
                        let hoy = moment();
                        var fechaNacimiento = moment(new Date(usr[0].dateOfBirth));
                        edad = hoy.diff(fechaNacimiento, "years");

                        var month = usr[0].dateOfBirth.getMonth() + 1; //months from 1-12
                        var day = usr[0].dateOfBirth.getDate();
                         
                        if(day < '10') {
                            day = `0${day}`;
                        }
                        if(month < '10') {
                            month = `0${month}`;
                        }
                        var year = usr[0].dateOfBirth.getFullYear();
                        date = `${year}-${month}-${day}`;
                    }
                    /* ----- */

                    let obj = { user_id:usr[0].user_id, email: usr[0].email, password: usr[0].password, name: usr[0].name, 
                        gender: usr[0].gender, dateOfBirth: date, points: usr[0].points, image: usr[0].image, age: edad};
                    callback(null, obj);
                } 
            });
        })
    }
    /**
 * Determina si un determinado usuario aparece en la BD con la contraseña
 * pasada como parámetro.
 * 
 * Es una operación asíncrona, de modo que se llamará a la función callback
 * pasando, por un lado, el objeto Error (si se produce, o null en caso contrario)
 * y, por otro lado, un booleano indicando el resultado de la operación
 * (true => el usuario existe, false => el usuario no existe o la contraseña es incorrecta)
 * En caso de error error, el segundo parámetro de la función callback será indefinido.
 * 
 * @param {string} email Identificador del usuario a buscar
 * @param {string} password Contraseña a comprobar
 * @param {function} callback Función que recibirá el objeto error y el resultado
 */
    isUserCorrect(email, password, callback) {

        /* Implementar */
        this.pool.getConnection((err, connection) => {
            if (err) { callback(err); return; }
            connection.query("SELECT user_id, email, password FROM user WHERE email = ? AND password = ?", [email, password],
                (err, filas) => {
                    /* Conecction release se puede poner justo aqui, ya que tenemos la
                    información de la tabla en filas y no vamos a necesitarlo más */
                    connection.release();
                    if (err) { callback(err); return; }
                    if (filas.length === 0) {
                        callback(null, -1);
                    }
                    else {
                        callback(null, filas[0].user_id);
                    }
                })
        })

    }

    userExist(email, callback) {
        this.pool.getConnection((err, connection) => {
            if (err) { callback(err); return; }
            connection.query("SELECT email FROM user WHERE email = ?", [email],
                (err, filas) => {
                    /* Conecction release se puede poner justo aqui, ya que tenemos la
                    información de la tabla en filas y no vamos a necesitarlo más */
                    connection.release();
                    if (err) { callback(err); return; }
                    if (filas.length === 0) {
                        callback(null, -1);
                    }
                    else {
                        callback(null, filas[0].email);
                    }
                })
        })
    }

    insertUser(email, password, name, gender, date, image, callback) {
        this.pool.getConnection((err, connection) => {
            if (err) { callback(err); return; }
            connection.query("INSERT INTO user (email, password, name, gender, dateOfBirth, image)" +
                " VALUES (?, ?, ?, ?, ?, ?)", [email, password, name, gender, date, image],
                function (err, resultado) {
                    if (err) { callback(err); return; }
                    else {
                        callback(null, resultado.insertId);
                        connection.release();
                    }
                })
        })
    }
    modifyUser(id, email, password, name, gender, date, image, callback){
        this.pool.getConnection((err, connection) => {
            if (err) { callback(err); return; }
            connection.query("UPDATE user SET email=?, password=?,name=?,gender=?,dateOfBirth=?,image=? WHERE user_id=?",
            [email, password, name, gender, date, image, id],
            function (err, resultado) {
                if (err) { callback(err); return; }
            })
            callback(null);
            connection.release();
        })
    }

    addUserPoints(id, points, callback) {
        this.pool.getConnection((err, connection) => {
            if (err) { callback(err); return; }
            connection.query("UPDATE user SET points=? WHERE user_id=?",
            [points, id],
            function (err, resultado) {
                if (err) { callback(err); return; }
            })
            callback(null);
            connection.release();
        })
    }
}

module.exports = {
    DAOUsers: DAOUsers
}