bamazonManager_es6.js

// Pull in required dependencies
const inquirer = require('inquirer');
const mysql = require('mysql');

// Define the MySQL connection parameters
const connection = mysql.createConnection({
	host: 'localhost',
	port: 3306,

	// Your username
	user: 'root',

	// Your password
	password: 'password',
	database: 'Bamazon'
});

// promptManagerAction will present menu options to the manager and trigger appropriate logic
function promptManagerAction() {
	// console.log('___ENTER promptManagerAction___');

	// Prompt the manager to select an option
	inquirer.prompt([
		{
			type: 'list',
			name: 'option',
			message: 'Please select an option:',
			choices: ['View Products for Sale', 'View Low Inventory', 'Add to Inventory', 'Add New Product'],
			filter(val) {
				if (val === 'View Products for Sale') {
					return 'sale';
				} else if (val === 'View Low Inventory') {
					return 'lowInventory';
				} else if (val === 'Add to Inventory') {
					return 'addInventory';
				} else if (val === 'Add New Product') {
					return 'newProduct';
				} else {
					// This case should be unreachable
					console.log('ERROR: Unsupported operation!');
					exit(1);
				}
			}
		}
	]).then(input => {
		// console.log('User has selected: ' + JSON.stringify(input));

		// Trigger the appropriate action based on the user input
		if (input.option ==='sale') {
			displayInventory();
		} else if (input.option === 'lowInventory') {
			displayLowInventory();
		} else if (input.option === 'addInventory') {
			addInventory();
		} else if (input.option === 'newProduct') {
			createNewProduct();
		} else {
			// This case should be unreachable
			console.log('ERROR: Unsupported operation!');
			exit(1);
		}
	})
}

// displayInventory will retrieve the current inventory from the database and output it to the console
function displayInventory() {
	// console.log('___ENTER displayInventory___');

	// Construct the db query string
	queryStr = 'SELECT * FROM products';

	// Make the db query
	connection.query(queryStr, (err, data) => {
		if (err) throw err;

		console.log('Existing Inventory: ');
		console.log('...................\n');

		let strOut = '';
		for (let i = 0; i < data.length; i++) {
			strOut = '';
			strOut += `Item ID: ${data[i].item_id}  //  `;
			strOut += `Product Name: ${data[i].product_name}  //  `;
			strOut += `Department: ${data[i].department_name}  //  `;
			strOut += `Price: $${data[i].price}  //  `;
			strOut += `Quantity: ${data[i].stock_quantity}\n`;

			console.log(strOut);
		}

	  	console.log("---------------------------------------------------------------------\n");

		// End the database connection
		connection.end();
	})
}

// displayLowInventory will display a list of products with the available quantity below 100
function displayLowInventory() {
	// console.log('___ENTER displayLowInventory');

	// Construct the db query string
	queryStr = 'SELECT * FROM products WHERE stock_quantity < 100';

	// Make the db query
	connection.query(queryStr, (err, data) => {
		if (err) throw err;

		console.log('Low Inventory Items (below 100): ');
		console.log('................................\n');

		let strOut = '';
		for (let i = 0; i < data.length; i++) {
			strOut = '';
			strOut += `Item ID: ${data[i].item_id}  //  `;
			strOut += `Product Name: ${data[i].product_name}  //  `;
			strOut += `Department: ${data[i].department_name}  //  `;
			strOut += `Price: $${data[i].price}  //  `;
			strOut += `Quantity: ${data[i].stock_quantity}\n`;

			console.log(strOut);
		}

	  	console.log("---------------------------------------------------------------------\n");

		// End the database connection
		connection.end();
	})
}

// validateInteger makes sure that the user is supplying only positive integers for their inputs
function validateInteger(value) {
	const integer = Number.isInteger(parseFloat(value));
	const sign = Math.sign(value);

	if (integer && (sign === 1)) {
		return true;
	} else {
		return 'Please enter a whole non-zero number.';
	}
}

// validateNumeric makes sure that the user is supplying only positive numbers for their inputs
function validateNumeric(value) {
	// Value must be a positive number
	const number = (typeof parseFloat(value)) === 'number';
	const positive = parseFloat(value) > 0;

	if (number && positive) {
		return true;
	} else {
		return 'Please enter a positive number for the unit price.'
	}
}

// addInventory will guilde a user in adding additional quantify to an existing item
function addInventory() {
	// console.log('___ENTER addInventory___');

	// Prompt the user to select an item
	inquirer.prompt([
		{
			type: 'input',
			name: 'item_id',
			message: 'Please enter the Item ID for stock_count update.',
			validate: validateInteger,
			filter: Number
		},
		{
			type: 'input',
			name: 'quantity',
			message: 'How many would you like to add?',
			validate: validateInteger,
			filter: Number
		}
	]).then(input => {
		// console.log('Manager has selected: \n    item_id = '  + input.item_id + '\n    additional quantity = ' + input.quantity);

		const item = input.item_id;
		const addQuantity = input.quantity;

		// Query db to confirm that the given item ID exists and to determine the current stock_count
		const queryStr = 'SELECT * FROM products WHERE ?';

		connection.query(queryStr, {item_id: item}, (err, data) => {
			if (err) throw err;

			// If the user has selected an invalid item ID, data attay will be empty
			// console.log('data = ' + JSON.stringify(data));

			if (data.length === 0) {
				console.log('ERROR: Invalid Item ID. Please select a valid Item ID.');
				addInventory();

			} else {
				const productData = data[0];

				// console.log('productData = ' + JSON.stringify(productData));
				// console.log('productData.stock_quantity = ' + productData.stock_quantity);

				console.log('Updating Inventory...');

				// Construct the updating query string
				const updateQueryStr = `UPDATE products SET stock_quantity = ${productData.stock_quantity + addQuantity} WHERE item_id = ${item}`;
				// console.log('updateQueryStr = ' + updateQueryStr);

				// Update the inventory
				connection.query(updateQueryStr, (err, data) => {
					if (err) throw err;

					console.log(`Stock count for Item ID ${item} has been updated to ${productData.stock_quantity + addQuantity}.`);
					console.log("\n---------------------------------------------------------------------\n");

					// End the database connection
					connection.end();
				})
			}
		})
	})
}

// createNewProduct will guide the user in adding a new product to the inventory
function createNewProduct() {
	// console.log('___ENTER createNewProduct___');

	// Prompt the user to enter information about the new product
	inquirer.prompt([
		{
			type: 'input',
			name: 'product_name',
			message: 'Please enter the new product name.',
		},
		{
			type: 'input',
			name: 'department_name',
			message: 'Which department does the new product belong to?',
		},
		{
			type: 'input',
			name: 'price',
			message: 'What is the price per unit?',
			validate: validateNumeric
		},
		{
			type: 'input',
			name: 'stock_quantity',
			message: 'How many items are in stock?',
			validate: validateInteger
		}
	]).then(input => {
		// console.log('input: ' + JSON.stringify(input));

		console.log(`Adding New Item: \n    product_name = ${input.product_name}\n    department_name = ${input.department_name}\n    price = ${input.price}\n    stock_quantity = ${input.stock_quantity}`);

		// Create the insertion query string
		const queryStr = 'INSERT INTO products SET ?';

		// Add new product to the db
		connection.query(queryStr, input, (error, results, fields) => {
			if (error) throw error;

			console.log(`New product has been added to the inventory under Item ID ${results.insertId}.`);
			console.log("\n---------------------------------------------------------------------\n");

			// End the database connection
			connection.end();
		});
	})
}

// runBamazon will execute the main application logic
function runBamazon() {
	// console.log('___ENTER runBamazon___');

	// Prompt manager for input
	promptManagerAction();
}

// Run the application logic
runBamazon();