ensl_gathers/db/models/event.js

"use strict";

const mongoose = require("mongoose");
const Schema = mongoose.Schema;
const path = require("path");
const pubsub = require(path.join(__dirname, "../../lib/event/pubsub.js"));
const winston = require("winston");

const eventSchema = new Schema({
	eventType: { type: String, required: true },
	description: { type: String },
	meta: { type: Schema.Types.Mixed },
	public: { type: Boolean, default: false },
	createdAt: { type: Date, default: Date.now, required: true }
});

eventSchema.index({ createdAt: -1 });
eventSchema.index({ eventType: 1 });

eventSchema.post("save", event => {
	pubsub.emit("newEvent", event);
});

eventSchema.statics.joiner = function (user) {
	winston.info("Gather Joiner", JSON.stringify(user));
	this.create({
		eventType: "gather:joiner",
		description: `${user.username} joined the gather`,
		public: true
	});
};

eventSchema.statics.leaver = function (user) {
	winston.info("Gather Leaver", JSON.stringify(user));
	this.create({
		eventType: "gather:leaver",
		description: `${user.username} left the gather`,
		public: true
	});
};

eventSchema.statics.playerSelected = function (user, data, gather) {
	winston.info("Selection Data", JSON.stringify(user), JSON.stringify(data));
	const gatherer = gather.getGatherer({id: data.player});
	const description = `${user.username} selected ${gatherer.user.username} into ${gatherer.team} team`;
	this.create({
		eventType: "gather:select",
		description: description,
		public: true
	});
};

eventSchema.statics.leaderVote = function (user, data, gather) {
	winston.info("Vote Data", JSON.stringify(user), JSON.stringify(data));
	const gatherer = gather.getGatherer({ id: data.leader.candidate });
	if (gatherer === null) return;
	this.create({
		eventType: "gather:vote:leader",
		description: `${user.username} voted for ${gatherer.user.username}`,
		public: true
	});
};

eventSchema.statics.adminRegather = function (user) {
	this.create({
		eventType: "gather:reset",
		description: `${user.username} reset the gather`,
		public: true
	});
};

eventSchema.statics.mapVote = function (user, data, gather, maps) {
	const gatherer = gather.getGatherer(user);
	if (gatherer.mapVote.some(mapId => mapId === data.map.id)) {
		let map = maps.reduce((prev, curr) => {
			if (curr.id === data.map.id) return curr;
			return prev;
		});
		this.create({
			eventType: "gather:vote:map",
			description: `${user.username} voted for map ${map.name}`,
			public: true
		});
	}
};

eventSchema.statics.serverVote = function (user, data, gather, servers) {
	const gatherer = gather.getGatherer(user);
	if (gatherer.serverVote.some(serverId => serverId === data.server.id)) {
		let server = servers.reduce((prev, curr) => {
			if (curr.id === data.server.id) return curr;
			return prev;
		});
		this.create({
			eventType: "gather:vote:server",
			description: `${user.username} voted for server ${server.name || server.description}`,
			public: true
		});
	}
};

module.exports = mongoose.model('Event', eventSchema);