install_db.js

'use strict'

require('dotenv').config()
const fs = require('fs')
const db = require('./lib/connectMongoose')
const Anuncio = require('./models/Anuncio')
const Usuario = require('./models/Usuario')

/**
 * Read file
 * @param {Object} file
 */
function readFile (file) {
  return new Promise((resolve, reject) => {
    fs.readFile(file, 'utf8', (err, data) => {
      if (err) {
        reject(new Error(`Error to read file ${file}, ${err}`))
      }
      resolve(data)
    })
  })
}

/**
 * Parse file
 * @param {Object} fileReaded
 */
function parseFile (fileReaded) {
  return new Promise((resolve, reject) => {
    if (!fileReaded) {
      reject(new Error(`Error to parse file`))
    }

    try {
      resolve(JSON.parse(fileReaded))
    } catch (err) {
      reject(err)
    }
  })
}

/**
 *
 * @param {Object} fileParsed
 * @param {String} model
 */
function saveDB (fileParsed, model) {
  return new Promise((resolve, reject) => {
    const datos = fileParsed[model]

    if (datos.length === 0 || !datos) {
      reject(new Error(`No data in ${model}`))
    }

    if (fileParsed.anuncios) {
      for (const anuncio of fileParsed.anuncios) {
        let anuncioSave = new Anuncio(anuncio)
        anuncioSave.save((err, data) => {
          if (err) {
            reject(err)
          }
          resolve()
        })
      }
    } else {
      for (const usuario of fileParsed.usuarios) {
        let usuarioSave = new Usuario(usuario)
        usuarioSave.save((err, data) => {
          if (err) {
            reject(err)
          }
          resolve()
        })
      }
    }
  })
}

/**
 * Main function
 */
async function main () {
  const fileAnuncios = './anuncios.json'
  const fileUsuarios = './usuarios.json'
  let fileReaded
  let fileParsed

  try {
    // Remove models
    await Anuncio.deleteMany()
    console.log('Remove Anuncio.....................OK')
    await Usuario.deleteMany()
    console.log('Remove Usuario.....................OK')

    // Reading, parsing and saving Anuncios file
    console.log('---- Reading, parsing and saving Anuncios file ----')
    fileReaded = await readFile(fileAnuncios)
    console.log(`File ${fileAnuncios} readed........Ok`)
    fileParsed = await parseFile(fileReaded)
    console.log(`File ${fileAnuncios} parsed........Ok`)
    await saveDB(fileParsed, 'anuncios')
    console.log(`File ${fileAnuncios} saved.........Ok`)

    // Reading, parsing and saving Usuarios file
    console.log('---- Reading, parsing and saving Usuarios file ----')
    fileReaded = await readFile(fileUsuarios)
    console.log(`File ${fileUsuarios} readed........Ok`)
    fileParsed = await parseFile(fileReaded)
    console.log(`File ${fileUsuarios} parsed........Ok`)
    await saveDB(fileParsed, 'usuarios')
    console.log(`File ${fileUsuarios} saved.........Ok`)

    console.log('Initialized Data Base!!!!')
    process.exit(0)
  } catch (err) {
    console.log('Error:', err)
    process.exit(1)
  }
}
db.once('open', () => {
  main()
})