sineql-demo/server/type-handlers/book-handlers.js

const { Book } = require('../database/models');

//utils
const checkDateFormat = date => /(19\d{2}|20\d{2})[-\/.](0[1-9]|1[012])[-\/.](0[1-9]|[12][0-9]|3[01])/.test(date) || date == 'NULL';

const queryBook = async (query, typeGraph) => {
	//sequelize stuff to find
	const attributes = [];
	const where = {};

	//specify fields to find
	Object.keys(query)
		.filter(key => key != 'typeName') //filter out this meta-field
		.forEach(key => {
			//all book members queried should be scalar
			if (query[key].scalar) {
				//push this key into the attributes list
				attributes.push(key);
			}

			//filter the members to a specific value
			if (query[key].match) {
				where[key] = query[key].match == 'NULL' ? null : query[key].match;
			}
		})
	;

	//search the database
	const result = await Book.findAll({
		attributes: attributes,
		where: where,
	});

	//finally
	return result.map(book => book.dataValues);
};

const createBook = async (query, typeGraph) => {
	//the array of objects to insert
	const inserts = [];

	query.forEach((q, idx) => {
		//just in case
		if (!q.create) {
			throw 'Unexpected create == false';
		}

		//specify fields to create
		Object.keys(q)
			.filter(key => key != 'typeName' && key != 'create') //filter out these meta-fields
			.forEach(key => {
				//check published date
				if (key == 'published' && !checkDateFormat(q[key].create)) {
					throw 'Wrong date format for published';
				}

				//all book members should be scalar
				if (q[key].scalar) {
					//make sure this exists
					inserts[idx] = inserts[idx] || {};

					//push this key into the inserts list
					inserts[idx][key] = q[key].create;
				}
			})
		;
	});

	//insert into the database
	const results = await Book.bulkCreate(inserts, { fields: ['title', 'published']});

	//determine what fields to return
	const returns = [];

	query.map((q, idx) => {
		//make sure it exists
		returns[idx] = returns[idx] || {};

		//specify fields to return in each record
		const keys = Object.keys(q)
			.filter(key => key != 'typeName' && key != 'create') //filter out these meta-fields
			.forEach(key => {
				if (q[key].scalar) {
					returns[idx][key] = results[idx][key];
				}
			})
		;
	});

	//finally
	return returns;
};

const updateBook = async (query, typeGraph) => {
	//total updated
	const totals = [];

	const promises = query.map(async (q, idx) => {
		//the array of objects to update
		const updates = {};
		const where = {};

		//just in case
		if (!q.update && !q.match) {
			throw 'Unexpected field (expected an update or match keyword)';
		}

		//specify fields to update
		Object.keys(q)
			.filter(key => key != 'typeName' && key != 'create') //filter out these meta-fields
			.forEach(key => {
				//check published date format
				if (key == 'published') {
					if (q[key].update && !checkDateFormat(q[key].update)) {
						throw 'Wrong date format for published';
					}
				}

				//all book members should be scalar
				if (q[key].update) {
					//push this key into the updates object
					updates[key] = q[key].update;
				}

				//filter the members to a specific value
				if (q[key].match) {
					where[key] = q[key].match == 'NULL' ? null : q[key].match;
				}
			})
		;

		//update the database
		const [updated] = await Book.update(updates, { where });

		totals.push(updated);
	});

	await Promise.all(promises);

	//finally
	return { totals };
};

const deleteBook = async (query, typeGraph) => {
	//total updated
	const totals = [];

	const promises = query.map(async (q, idx) => {
		//the array of objects to delete
		const where = {};

		//just in case
		if (!q.delete) {
			throw 'Unexpected field (expected match keyword)';
		}

		//specify fields to delete
		Object.keys(q)
			.filter(key => key != 'typeName' && key != 'delete') //filter out these meta-fields
			.forEach(key => {
				//check published date format
				if (key == 'published') {
					if (q[key].match && !checkDateFormat(q[key].match)) {
						throw 'Wrong date format for published';
					}
				}

				//filter the members to a specific value
				if (q[key].match) {
					where[key] = q[key].match == 'NULL' ? null : q[key].match;
				}
			})
		;

		//update the database
		const deleted = await Book.destroy({ where });

		totals.push(deleted);
	});

	await Promise.all(promises);

	//finally
	return { totals };
};

module.exports = {
	queryBook,
	createBook,
	updateBook,
	deleteBook,
};