Musare/backend/logic/actions/news.js

"use strict";

const async = require("async");

const hooks = require("./hooks");
const moduleManager = require("../../index");

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

cache.runJob("SUB", {
    channel: "news.create",
    cb: (news) => {
        utils.runJob("SOCKETS_FROM_USER", {
            userId: news.createdBy,
            cb: (response) => {
                response.sockets.forEach((socket) => {
                    socket.emit("event:admin.news.created", news);
                });
            },
        });
    },
});

cache.runJob("SUB", {
    channel: "news.remove",
    cb: (news) => {
        utils.runJob("SOCKETS_FROM_USER", {
            userId: news.createdBy,
            cb: (response) => {
                response.sockets.forEach((socket) => {
                    socket.emit("event:admin.news.removed", news);
                });
            },
        });
    },
});

cache.runJob("SUB", {
    channel: "news.update",
    cb: (news) => {
        utils.runJob("SOCKETS_FROM_USER", {
            userId: news.createdBy,
            cb: (response) => {
                response.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: async (session, cb) => {
        const newsModel = await db.runJob("GET_MODEL", { modelName: "news" });
        async.waterfall(
            [
                (next) => {
                    newsModel
                        .find({})
                        .sort({ createdAt: "desc" })
                        .exec(next);
                },
            ],
            async (err, news) => {
                if (err) {
                    err = await utils.runJob("GET_ERROR", { error: err });
                    console.log(
                        "ERROR",
                        "NEWS_INDEX",
                        `Indexing news failed. "${err}"`
                    );
                    return cb({ status: "failure", message: err });
                }
                console.log(
                    "SUCCESS",
                    "NEWS_INDEX",
                    `Indexing news successful.`,
                    false
                );
                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
     */
    create: hooks.adminRequired(async (session, data, cb) => {
        const newsModel = await db.runJob("GET_MODEL", { modelName: "news" });
        async.waterfall(
            [
                (next) => {
                    data.createdBy = session.userId;
                    data.createdAt = Date.now();
                    newsModel.create(data, next);
                },
            ],
            async (err, news) => {
                if (err) {
                    err = await utils.runJob("GET_ERROR", { error: err });
                    console.log(
                        "ERROR",
                        "NEWS_CREATE",
                        `Creating news failed. "${err}"`
                    );
                    return cb({ status: "failure", message: err });
                }
                cache.runJob("PUB", { channel: "news.create", value: news });
                console.log(
                    "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: async (session, cb) => {
        const newsModel = await db.runJob("GET_MODEL", { modelName: "news" });
        async.waterfall(
            [
                (next) => {
                    newsModel
                        .findOne({})
                        .sort({ createdAt: "desc" })
                        .exec(next);
                },
            ],
            async (err, news) => {
                if (err) {
                    err = await utils.runJob("GET_ERROR", { error: err });
                    console.log(
                        "ERROR",
                        "NEWS_NEWEST",
                        `Getting the latest news failed. "${err}"`
                    );
                    return cb({ status: "failure", message: err });
                }
                console.log(
                    "SUCCESS",
                    "NEWS_NEWEST",
                    `Successfully got the latest news.`,
                    false
                );
                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(async (session, news, cb) => {
        const newsModel = await db.runJob("GET_MODEL", { modelName: "news" });
        newsModel.deleteOne({ _id: news._id }, async (err) => {
            if (err) {
                err = await utils.runJob("GET_ERROR", { error: err });
                console.log(
                    "ERROR",
                    "NEWS_REMOVE",
                    `Removing news "${news._id}" failed for user "${session.userId}". "${err}"`
                );
                return cb({ status: "failure", message: err });
            } else {
                cache.runJob("PUB", { channel: "news.remove", value: news });
                console.log(
                    "SUCCESS",
                    "NEWS_REMOVE",
                    `Removing news "${news._id}" successful by user "${session.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(async (session, _id, news, cb) => {
        const newsModel = await db.runJob("GET_MODEL", { modelName: "news" });
        newsModel.updateOne({ _id }, news, { upsert: true }, async (err) => {
            if (err) {
                err = await utils.runJob("GET_ERROR", { error: err });
                console.log(
                    "ERROR",
                    "NEWS_UPDATE",
                    `Updating news "${_id}" failed for user "${session.userId}". "${err}"`
                );
                return cb({ status: "failure", message: err });
            } else {
                cache.runJob("PUB", { channel: "news.update", value: news });
                console.log(
                    "SUCCESS",
                    "NEWS_UPDATE",
                    `Updating news "${_id}" successful for user "${session.userId}".`
                );
                return cb({
                    status: "success",
                    message: "Successfully updated News",
                });
            }
        });
    }),
};