validations.js

const db = require("./database");
const util = require("util");
const { error } = require("console");
const query = util.promisify(db.query).bind(db);

async function personValidation(email, apellido, nombre, alias) {
  if (!email || !apellido || !nombre || !alias) {
    throw new Error("faltan datos");
  }

  const persons = await query("SELECT * FROM persona WHERE email= ?", [email]);
  if (persons.length) {
    throw new Error("el email ya se encuentra registrado");
  }
}

async function validatePersonFound(id) {
  const person = await query("SELECT * FROM persona WHERE id=?", [id]);
  if (!person.length) {
    throw new Error("no se encuentra esa persona");
  }
  return person[0];
}

async function validatePersonExist(id) {
  const person = await query("SELECT * FROM persona WHERE id=?", [id]);
  if (!person.length) {
    throw new Error("no existe esa persona");
  }
  return person[0];
}

async function validatePersonHasBook(id) {
  const person = await query("SELECT * FROM libro WHERE persona_id=?", [id]);
  if (person.length) {
    throw new Error("Esa persona tiene libros asociados, no se puede eliminar");
  }
  return person[0];
}

//---------------------------------------------------------------------
async function bookValidation(nombre, descripcion, categoria_id, persona_id) {
  if (!nombre || !categoria_id || !descripcion || !persona_id) {
    throw new Error("faltan datos");
  }
}

async function validateBookFound(id) {
  const book = await query("SELECT * FROM libro WHERE id=?", [id]);
  if (!book.length) {
    throw new Error("no se encuentra ese libro");
  }
  return book[0];
}

async function validateBookExist(id) {
  const book = await query("SELECT * FROM libro WHERE nombre=?", [id]);
  if (book.length) {
    throw new Error("Ya existe ese libro");
  }
  return book[0];
}

async function validateBookLend(id) {
  const book = await query(
    "SELECT * FROM libro WHERE persona_id IS NOT NULL AND id=?",
    [id]
  );
  if (book.length) {
    throw new Error(
      "El libro ya se encuentra prestado no se puede prestar hasta que se devuelva."
    );
  }
  return book[0];
}

async function validateBookIsNotLend(id) {
  const book = await query(
    "SELECT * FROM libro WHERE persona_id IS NULL AND id=?",
    [id]
  );
  if (book.length) {
    throw new Error("Ese libro no estaba prestado!");
  }
  return book[0];
}

async function validateBookLendDelete(id) {
  const book = await query(
    "SELECT * FROM libro WHERE persona_id is NOT NULL AND id=?",
    [id]
  );
  if (book.length) {
    throw new Error("ese libro esta prestado no se puede borrar");
  }
  return book[0];
}

//---------------------------------------------------------------------
async function categoryValidation(nombre) {
  if (!nombre) {
    throw new Error("faltan datos");
  }
  const category = await query("SELECT * FROM categoria WHERE nombre=?", [
    nombre,
  ]);
  if (category.length) {
    throw new Error("ese nombre de categoria ya existe");
  }
  return category[0];
}

async function validateCategoryFound(id) {
  const category = await query("SELECT * FROM categoria WHERE id=?", [id]);
  if (!category.length) {
    throw new Error("categoría no encontrada");
  }
  return category[0];
}

async function validateCategoryExist(id) {
  const category = await query("SELECT * FROM categoria WHERE id=?", [id]);
  if (!category.length) {
    throw new Error("no existe la categoria indicada");
  }
  return category[0];
}

async function validateCategoryHasBook(id) {
  const category = await query("SELECT * FROM libro WHERE categoria_id=?", [
    id,
  ]);
  if (category.length) {
    throw new Error("categoria con libros asociados, no se puede eliminar");
  }
  return category[0];
}

module.exports = {
  personValidation,
  validatePersonExist,
  validatePersonFound,
  validatePersonHasBook,
  bookValidation,
  validateBookIsNotLend,
  validateBookFound,
  validateBookExist,
  validateBookLend,
  validateBookLendDelete,
  categoryValidation,
  validateCategoryFound,
  validateCategoryExist,
  validateCategoryHasBook,
};