queries.js

const { pool } = require('./config')

const API_KEY = process.env.API_KEY; // change this to env variable
const API_ERROR = 'API key is incorrect...';

// returns all recipes
const getRecipes = (request, response) => {
	if (request.headers.key !== API_KEY) {
		response.status(500).json({ 'error' : API_ERROR})
	} else {
		pool.query('SELECT * FROM recipes ORDER BY id ASC', (error, results) => {
			if (error) {
				throw error
			}
			response.status(200).json(results.rows)
		})
	}
}

// include error checking to see that the name is not null
const createRecipe = (request, response) => {
	if (request.headers.key !== API_KEY) {
		response.status(500).json({ 'error' : API_ERROR})
	} else {
		const { name, category, ingredients } = request.body;
		if (!name || !category) {
			response.status(500).json({ 'error' : 'Name or category cannot be null'})
		} else {
			pool.query('INSERT INTO recipes (name, category, ingredients) VALUES ($1, $2, $3) RETURNING name, category, ingredients', [name, category, ingredients], (error, results) => {
		    if (error) {
					console.log(error);
		      throw error;
		    }
				if (results.rowCount === 0) {
					response.status(500).json({ 'error' : 'Unable to add recipe'})
				} else {
					response.status(201).json({ 'addedRecipe' : results.rows});
				}
	  	})
		}
	}
}

// delete recipe
const deleteRecipe = (request, response) => {
	if (request.headers.key !== API_KEY) {
		response.status(500).json({ 'error' : API_ERROR})
	} else {
		const { name } = request.body;
		if (!name) {
			response.status(500).json({ 'error' : 'Name cannot be null'})
		} else {
			pool.query('DELETE FROM recipes WHERE name = $1', [name], (error, results) => {
		    if (error) {
					console.log(error);
		      throw error;
		    }
				if (results.rowCount === 0) {
					response.status(500).json({ 'error' : 'Unable to find recipe'})
				} else {
					response.status(201).json({ 'deletedItems' : results.rowCount});
				}
	  	})
		}
	}
}

// search Name
const searchName = (request, response) => {
	if (request.headers.key !== API_KEY) {
		response.status(500).json({ 'error' : API_ERROR})
	} else {
		const { name } = request.body;
		if (!name) {
			response.status(500).json({ 'error' : 'Name cannot be null'})
		} else {
			pool.query('SELECT * FROM recipes WHERE name = $1', [name], (error, results) => {
				if (error) {
					console.log(error);
		      throw error;
		    } else {
					if (results.rowCount === 0) {
						response.status(500).json({ 'error' : 'Unable to find recipe'})
					} else {
						response.status(201).send(results.rows)
					}
				}
			})
		}
	}
}

// search category
const searchCategory = (request, response) => {
	if (request.headers.key !== API_KEY) {
		response.status(500).json({ 'error' : API_ERROR})
	} else {
		const { category } = request.body;
		if (!category) {
			response.status(500).json({ 'error' : 'Category cannot be null'})
		} else {
			pool.query('SELECT * FROM recipes WHERE category = $1', [category], (error, results) => {
				if (error) {
					console.log(error);
		      throw error;
		    } else {
					if (results.rowCount === 0) {
						response.status(500).json({ 'error' : 'Unable to find recipe'})
					} else {
						response.status(201).send(results.rows)
					}
				}
			})
		}
	}
}

// TODO: Update recipes UPDATE recipes SET category = 'dessert' WHERE name = 'cake';

module.exports = {
	getRecipes,
	createRecipe,
	deleteRecipe,
	searchCategory,
	searchName
}