isleward/src/server/misc/mail.js

let io = require('../security/io');

module.exports = {
	queue: {},
	busy: {},

	init: function (instance) {
		this.instance = instance;
	},

	getMail: function (playerName) {
		let player = this.instance.objects.objects.find(o => (o.name === playerName));
		if (!player) {
			process.send({
				method: 'callDifferentThread',
				playerName: playerName,
				data: {
					module: 'mail',
					method: 'getMail',
					args: [playerName]
				}
			});

			this.processQueue(playerName);
			return;
		}

		io.get({
			ent: playerName,
			field: 'mail',
			callback: this.onGetMail.bind(this, player)
		});
	},
	onGetMail: function (player, result) {
		if (result === 'null')
			result = null;
		else if (result) {
			result = result.split('`').join('\'');
			//Hack for weird google datastore error
			if (result[0] === '<')
				return;
		}

		result = JSON.parse(result || '[]');

		let sentMessages = [];

		let inventory = player.inventory;
		let stash = player.stash;

		result.forEach(function (r) {
			if (r.removeAll) {
				for (let i = 0; i < inventory.items.length; i++) {
					let item = inventory.items[i];
					if ((r.nameLike) && (item.name.indexOf(r.nameLike) > -1)) {
						inventory.destroyItem(item.id, item.quantity ? item.quantity : null);
						i--;
					}
				}

				if (stash) {
					for (let i = 0; i < stash.items.length; i++) {
						let item = stash.items[i];
						if ((r.nameLike) && (item.name.indexOf(r.nameLike) > -1)) {
							stash.destroyItem(item.id);
							i--;
						}
					}
				} else 
					console.log(player.name + ' has no stash');
			} else {
				if ((r.msg) && (!sentMessages.some(s => (s === r.msg)))) {
					player.instance.syncer.queue('onGetMessages', {
						id: player.id,
						messages: [{
							class: 'color-greenB',
							message: r.msg,
							type: 'info'
						}]
					}, [player.serverId]);

					sentMessages.push(r.msg);
					delete r.msg;
				}
				inventory.getItem(r);
			}
		});

		io.set({
			ent: player.name,
			field: 'mail',
			value: null,
			callback: this.processQueue.bind(this, player.name)
		});
	},

	processQueue: function (playerName) {
		delete this.busy[playerName];
		let queue = this.queue[playerName];
		if (!queue)
			return;

		delete this.queue[playerName];
		this.sendMail(playerName, queue);
	},

	sendMail: function (playerName, items, callback) {
		if (this.busy[playerName]) {
			let queue = this.queue[playerName];
			if (!queue) 
				queue = this.queue[playerName] = [];
			
			items.forEach(function (i) {
				queue.push(extend(true, {}, i));
			});

			return;
		}

		this.busy[playerName] = true;

		if (!items.push)
			items = [items];

		let player = null;
		if (this.instance)
			player = this.instance.objects.objects.find(o => (o.name === playerName));

		io.get({
			ent: playerName,
			field: 'mail',
			callback: this.doSendMail.bind(this, playerName, items, callback)
		});
	},
	doSendMail: function (playerName, items, callback, result) {
		if (result === 'null')
			result = null;

		result = JSON.parse(result || '[]');

		items.forEach(function (i) {
			result.push(i);
		});

		let itemString = JSON.stringify(result).split('\'').join('`');

		io.set({
			ent: playerName,
			field: 'mail',
			value: itemString,
			callback: callback || this.getMail.bind(this, playerName)
		});
	}
};