file upload added

.example.env

@@ -4,4 +4,7 @@ SECRETORPRIVATEKEY=
 
 
 GOOGLE_CLIENT_ID=
-GOOGLE_SECRET_ID=
+GOOGLE_SECRET_ID=
+
+
+CLOUDINARY_URL=

.gitignore

@@ -2,4 +2,7 @@
 
 node_modules/
 
-.env
+.env
+
+uploads/productos/**.*
+uploads/usuarios/**.*

controllers/uploads.js

@@ -0,0 +1,188 @@
+const path = require('path');
+const fs   = require('fs');
+
+const cloudinary = require('cloudinary').v2
+cloudinary.config( process.env.CLOUDINARY_URL );
+
+const { response } = require('express');
+const { subirArchivo } = require('../helpers');
+
+const { Usuario, Producto } = require('../models');
+
+
+const cargarArchivo = async(req, res = response) => {
+
+
+    try {
+
+        // txt, md
+        // const nombre = await subirArchivo( req.files, ['txt','md'], 'textos' );
+        const nombre = await subirArchivo( req.files, undefined, 'imgs' );
+        res.json({ nombre });
+
+    } catch (msg) {
+        res.status(400).json({ msg });
+    }
+
+}
+
+
+const actualizarImagen = async(req, res = response ) => {
+
+    const { id, coleccion } = req.params;
+
+    let modelo;
+
+    switch ( coleccion ) {
+        case 'usuarios':
+            modelo = await Usuario.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un usuario con el id ${ id }`
+                });
+            }
+
+        break;
+
+        case 'productos':
+            modelo = await Producto.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un producto con el id ${ id }`
+                });
+            }
+
+        break;
+
+        default:
+            return res.status(500).json({ msg: 'Se me olvidó validar esto'});
+    }
+
+
+    // Limpiar imágenes previas
+    if ( modelo.img ) {
+        // Hay que borrar la imagen del servidor
+        const pathImagen = path.join( __dirname, '../uploads', coleccion, modelo.img );
+        if ( fs.existsSync( pathImagen ) ) {
+            fs.unlinkSync( pathImagen );
+        }
+    }
+
+
+    const nombre = await subirArchivo( req.files, undefined, coleccion );
+    modelo.img = nombre;
+
+    await modelo.save();
+
+
+    res.json( modelo );
+
+}
+
+
+const actualizarImagenCloudinary = async(req, res = response ) => {
+
+    const { id, coleccion } = req.params;
+
+    let modelo;
+
+    switch ( coleccion ) {
+        case 'usuarios':
+            modelo = await Usuario.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un usuario con el id ${ id }`
+                });
+            }
+
+        break;
+
+        case 'productos':
+            modelo = await Producto.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un producto con el id ${ id }`
+                });
+            }
+
+        break;
+
+        default:
+            return res.status(500).json({ msg: 'Se me olvidó validar esto'});
+    }
+
+
+    // Limpiar imágenes previas
+    if ( modelo.img ) {
+        const nombreArr = modelo.img.split('/');
+        const nombre    = nombreArr[ nombreArr.length - 1 ];
+        const [ public_id ] = nombre.split('.');
+        cloudinary.uploader.destroy( public_id );
+    }
+
+
+    const { tempFilePath } = req.files.archivo
+    const { secure_url } = await cloudinary.uploader.upload( tempFilePath );
+    modelo.img = secure_url;
+
+    await modelo.save();
+
+
+    res.json( modelo );
+
+}
+
+const mostrarImagen = async(req, res = response ) => {
+
+    const { id, coleccion } = req.params;
+
+    let modelo;
+
+    switch ( coleccion ) {
+        case 'usuarios':
+            modelo = await Usuario.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un usuario con el id ${ id }`
+                });
+            }
+
+        break;
+
+        case 'productos':
+            modelo = await Producto.findById(id);
+            if ( !modelo ) {
+                return res.status(400).json({
+                    msg: `No existe un producto con el id ${ id }`
+                });
+            }
+
+        break;
+
+        default:
+            return res.status(500).json({ msg: 'Se me olvidó validar esto'});
+    }
+
+
+    // Limpiar imágenes previas
+    if ( modelo.img ) {
+        // Hay que borrar la imagen del servidor
+        const pathImagen = path.join( __dirname, '../uploads', coleccion, modelo.img );
+        if ( fs.existsSync( pathImagen ) ) {
+            return res.sendFile( pathImagen )
+        }
+    }
+
+    const pathImagen = path.join( __dirname, '../assets/no-image.jpg');
+    res.sendFile( pathImagen );
+}
+
+
+
+
+module.exports = {
+    cargarArchivo,
+    actualizarImagen,
+    mostrarImagen,
+    actualizarImagenCloudinary
+}

helpers/db-validators.js

@@ -51,12 +51,25 @@ const existeProductoPorId = async( id ) => {
     }
 }
 
+/**
+ * Validar colecciones permitidas
+ */
+const coleccionesPermitidas = ( coleccion = '', colecciones = []) => {
+
+    const incluida = colecciones.includes( coleccion );
+    if ( !incluida ) {
+        throw new Error(`La colección ${ coleccion } no es permitida, ${ colecciones }`);
+    }
+    return true;
+}
+
 
 module.exports = {
     esRoleValido,
     emailExiste,
     existeUsuarioPorId,
     existeCategoriaPorId,
-    existeProductoPorId
+    existeProductoPorId,
+    coleccionesPermitidas
 }
 

helpers/index.js

@@ -0,0 +1,14 @@
+
+
+const dbValidators = require('./db-validators');
+const generarJWT   = require('./generar-jwt');
+const googleVerify = require('./google-verify');
+const subirArchivo = require('./subir-archivo');
+
+
+module.exports = {
+    ...dbValidators,
+    ...generarJWT,
+    ...googleVerify,
+    ...subirArchivo,
+}

helpers/subir-archivo.js

@@ -0,0 +1,36 @@
+const path = require('path');
+const { v4: uuidv4 } = require('uuid');
+
+const subirArchivo = ( files, extensionesValidas = ['png','jpg','jpeg','gif'], carpeta = '' ) => {
+
+    return new Promise( (resolve, reject) => {
+
+        const { archivo } = files;
+        const nombreCortado = archivo.name.split('.');
+        const extension = nombreCortado[ nombreCortado.length - 1 ];
+
+        // Validar la extension
+        if ( !extensionesValidas.includes( extension ) ) {
+            return reject(`La extensión ${ extension } no es permitida - ${ extensionesValidas }`);
+        }
+
+        const nombreTemp = uuidv4() + '.' + extension;
+        const uploadPath = path.join( __dirname, '../uploads/', carpeta, nombreTemp );
+
+        archivo.mv(uploadPath, (err) => {
+            if (err) {
+                reject(err);
+            }
+
+            resolve( nombreTemp );
+        });
+
+    });
+
+}
+
+
+
+module.exports = {
+    subirArchivo
+}

middlewares/index.js

@@ -1,11 +1,13 @@
 
 
 const validaCampos = require('../middlewares/validar-campos');
-const validarJWT = require('../middlewares/validar-jwt');
-const validaRoles = require('../middlewares/validar-roles');
+const validarJWT   = require('../middlewares/validar-jwt');
+const validaRoles  = require('../middlewares/validar-roles');
+const validarArchivo = require('../middlewares/validar-archivo');
 
 module.exports = {
     ...validaCampos,
     ...validarJWT,
     ...validaRoles,
+    ...validarArchivo
 }

middlewares/validar-archivo.js

@@ -0,0 +1,19 @@
+const { response } = require("express")
+
+
+const validarArchivoSubir = (req, res = response, next ) => {
+
+    if (!req.files || Object.keys(req.files).length === 0 || !req.files.archivo ) {
+        return res.status(400).json({
+            msg: 'No hay archivos que subir - validarArchivoSubir'
+        });
+    }
+
+    next();
+
+}
+
+
+module.exports = {
+    validarArchivoSubir
+}

models/producto.js

@@ -27,6 +27,7 @@ const ProductoSchema = Schema({
     },
     descripcion: { type: String },
     disponible: { type: Boolean, defult: true },
+    img: { type: String },
 });
 
 

models/server.js

@@ -1,5 +1,6 @@
 const express = require('express');
 const cors = require('cors');
+const fileUpload = require('express-fileupload');
 
 const { dbConnection } = require('../database/config');
 
@@ -15,6 +16,7 @@ class Server {
             categorias: '/api/categorias',
             productos:  '/api/productos',
             usuarios:   '/api/usuarios',
+            uploads:    '/api/uploads',
         }
 
 
@@ -44,6 +46,13 @@ class Server {
         // Directorio Público
         this.app.use( express.static('public') );
 
+        // Fileupload - Carga de archivos
+        this.app.use( fileUpload({
+            useTempFiles : true,
+            tempFileDir : '/tmp/',
+            createParentPath: true
+        }));
+
     }
 
     routes() {
@@ -53,6 +62,8 @@ class Server {
         this.app.use( this.paths.categorias, require('../routes/categorias'));
         this.app.use( this.paths.productos, require('../routes/productos'));
         this.app.use( this.paths.usuarios, require('../routes/usuarios'));
+        this.app.use( this.paths.uploads, require('../routes/uploads'));
+
     }
 
     listen() {