/**
* @fileOverview A service that handles CRUD operations for user's emails
*
* @author Ralfs Lagzda
*
* @requires NPM:lodash
* @requires ../models/email
*/
const _ = require('lodash');
const Email = require('../models/email');
/**
* List all emails
*
* @memberOf EmailService
* @function list
* @param {Object} params the parameters to limit the query to desired results
* @returns {Promise<Email[]>} Promise that eventually resolves an array
* of emails or throws error
*/
const list = params => new Promise(async (resolve, reject) => {
try {
if (typeof (params) !== 'object' || _.isEmpty(params)) throw (Error('Invalid parameters'));
resolve(await Email.find(params));
} catch (err) {
reject(err);
}
});
/**
* Create a email
*
* @memberOf EmailService
* @function create
* @param {String} userId the owner of the email
* @param {Object} email the email object to create
* @returns {Promise<Email>} Promise that eventually creates and resolves
* a email or throws error
*/
const create = (userId, email) => new Promise(async (resolve, reject) => {
try {
const creatableEmail = await Object.assign(email, { createdBy: userId });
const newEmail = await new Email(creatableEmail).save();
resolve(newEmail);
} catch (err) {
reject(err);
}
});
/**
* Retrieves a single email by ID
*
* @memberOf EmailService
* @function read
* @param {String} emailId the ID of the email
* @returns {Promise<Email>} Promise that eventually resolves a email or throws error
*/
const read = emailId => new Promise(async (resolve, reject) => {
try {
resolve(await Email.findById(emailId));
} catch (err) {
reject(err);
}
});
/**
* Updates a single email
*
* @memberOf EmailService
* @function update
* @param {String} emailId the ID of the email
* @param {Object} body key/value pairs of the fields that should be changed
* @returns {Promise<Email>} Promise that eventually updates and
* resolves a email or throws error
*/
const update = (emailId, body) => new Promise(async (resolve, reject) => {
try {
const updatedEmail = await Object.assign(await Email.findById(emailId), body);
resolve(await updatedEmail.save());
} catch (err) {
reject(err);
}
});
/**
* Deletes a single email
*
* @memberOf EmailService
* @function del
* @param {String} emailId the ID of the email
* @returns {Promise} Promise that eventually deletes
* an email or throws error
*/
const del = emailId => new Promise(async (resolve, reject) => {
try {
await Email.remove({ _id: emailId });
resolve();
} catch (err) {
reject(err);
}
});
/**
* Find or Create a email
*
* @memberOf EmailService
* @function findOrCreate
* @param {String} userId the owner of the email
* @param {Object} email the email object to create
* @param {String} email.email the email string in the object
* @returns {Promise<Email>} eventually creates and returns a
* email or throws error
*/
const findOrCreate = (userId, email) => new Promise(async (resolve, reject) => {
try {
if (!email) return resolve('');
const existingEmail = await Email.findOne({ email });
if (!existingEmail) {
const creatableEmail = await Object.assign({ email }, { createdBy: userId });
return resolve(await new Email(creatableEmail).save());
}
return resolve(existingEmail);
} catch (err) {
return reject(err);
}
});
/**
* A service that handles CRUD operations for user's emails
* @namespace EmailService
*/
module.exports = {
list,
create,
read,
update,
del,
findOrCreate,
};
|