MusareFork/backend/logic/actions/news.js

'use strict';

const async = require('async');

const db = require('../db');
const cache = require('../cache');
const utils = require('../utils');
const logger = require('../logger');
const hooks = require('./hooks');

cache.sub('news.create', news => {
	utils.socketsFromUser(news.createdBy, sockets => {
		sockets.forEach(socket => {
			socket.emit('event:admin.news.created', news);
		});
	});
});

cache.sub('news.remove', news => {
	utils.socketsFromUser(news.createdBy, sockets => {
		sockets.forEach(socket => {
			socket.emit('event:admin.news.removed', news);
		});
	});
});

cache.sub('news.update', news => {
	utils.socketsFromUser(news.createdBy, sockets => {
		sockets.forEach(socket => {
			socket.emit('event:admin.news.updated', news);
		});
	});
});

module.exports = {

	/**
	 * Gets all news items
	 *
	 * @param {Object} session - the session object automatically added by socket.io
	 * @param {Function} cb - gets called with the result
	 */
	index: (session, cb) => {
		async.waterfall([
			(next) => {
				db.models.news.find({}).sort({ createdAt: 'desc' }).exec(next);
			}
		], (err, news) => {
			if (err) {
				err = utils.getError(err);
				logger.error("NEWS_INDEX", `Indexing news failed. "${err}"`);
				return cb({status: 'failure', message: err});
			}
			logger.success("NEWS_INDEX", `Indexing news successful.`);
			return cb({ status: 'success', data: news });
		});
	},

	/**
	 * Creates a news item
	 *
	 * @param {Object} session - the session object automatically added by socket.io
	 * @param {Object} data - the object of the news data
	 * @param {Function} cb - gets called with the result
	 * @param {String} userId - the userId automatically added by hooks
	 */
	create: hooks.adminRequired((session, data, cb, userId) => {
		async.waterfall([
			(next) => {
				data.createdBy = userId;
				data.createdAt = Date.now();
				db.models.news.create(data, next);
			}
		], (err, news) => {
			if (err) {
				err = utils.getError(err);
				logger.error("NEWS_CREATE", `Creating news failed. "${err}"`);
				return cb({ 'status': 'failure', 'message': err });
			}
			cache.pub('news.create', news);
			logger.success("NEWS_CREATE", `Creating news successful.`);
			return cb({ 'status': 'success', 'message': 'Successfully created News' });
		});
	}),

	/**
	 * Gets the latest news item
	 *
	 * @param {Object} session - the session object automatically added by socket.io
	 * @param {Function} cb - gets called with the result
	 */
	newest: (session, cb) => {
		async.waterfall([
			(next) => {
				db.models.news.findOne({}).sort({ createdAt: 'desc' }).exec(next);
			}
		], (err, news) => {
			if (err) {
				err = utils.getError(err);
				logger.error("NEWS_NEWEST", `Getting the latest news failed. "${err}"`);
				return cb({ 'status': 'failure', 'message': err });
			}
			logger.success("NEWS_NEWEST", `Successfully got the latest news.`);
			return cb({ status: 'success', data: news });
		});
	},

	/**
	 * Removes a news item
	 *
	 * @param {Object} session - the session object automatically added by socket.io
	 * @param {Object} news - the news object
	 * @param {Function} cb - gets called with the result
	 */
	//TODO Pass in an id, not an object
	//TODO Fix this
	remove: hooks.adminRequired((session, news, cb, userId) => {
		db.models.news.remove({ _id: news._id }, err => {
			if (err) {
				err = utils.getError(err);
				logger.error("NEWS_REMOVE", `Removing news "${news._id}" failed for user "${userId}". "${err}"`);
				return cb({ 'status': 'failure', 'message': err });
			} else {
				cache.pub('news.remove', news);
				logger.success("NEWS_REMOVE", `Removing news "${news._id}" successful by user "${userId}".`);
				return cb({ 'status': 'success', 'message': 'Successfully removed News' });
			}
		});
	}),

	/**
	 * Removes a news item
	 *
	 * @param {Object} session - the session object automatically added by socket.io
	 * @param {String} _id - the news id
	 * @param {Object} news - the news object
	 * @param {Function} cb - gets called with the result
	 */
	//TODO Fix this
	update: hooks.adminRequired((session, _id, news, cb, userId) => {
		db.models.news.update({ _id }, news, { upsert: true }, err => {
			if (err) {
				err = utils.getError(err);
				logger.error("NEWS_UPDATE", `Updating news "${_id}" failed for user "${userId}". "${err}"`);
				return cb({ 'status': 'failure', 'message': err });
			} else {
				cache.pub('news.update', news);
				logger.success("NEWS_UPDATE", `Updating news "${_id}" successful for user "${userId}".`);
				return cb({ 'status': 'success', 'message': 'Successfully updated News' });
			}
		});
	}),

};