isleward/src/server/components/trade.js

let generator = require('../items/generator');
let statGenerator = require('../items/generators/stats');
let skins = require('../config/skins');
const events = require('../misc/events');

const sendMessage = ({ instance, id, serverId }, color, message) => {
	instance.syncer.queue('onGetMessages', {
		id: id,
		messages: [{
			class: color,
			message,
			type: 'info'
		}]
	}, [serverId]);
};

module.exports = {
	type: 'trade',

	items: [],
	buybackList: {},

	maxBuyback: 10,

	blueprint: null,
	gold: 0,

	target: null,

	regenCd: 0,
	regenCdMax: 1710,
	genLeft: 0,

	markup: {
		buy: 1,
		sell: 1
	},

	init: function (blueprint) {
		this.blueprint = blueprint;
		this.gold = blueprint.gold;		
		this.items = [];
		this.regenCd = this.regenCdMax;

		(blueprint.forceItems || []).forEach(function (f, i) {
			let item = extend({}, f);

			let id = 0;
			this.items.forEach(function (checkItem) {
				if (checkItem.id >= id)
					id = checkItem.id + 1;
			});

			if (item.type === 'skin') {
				let skinBlueprint = skins.getBlueprint(item.skinId);
				item.name = skinBlueprint.name;
				item.sprite = skinBlueprint.sprite;
				item.spritesheet = skinBlueprint.spritesheet;
				item.skinId = item.skinId;
			}

			item.id = id;

			this.items.push(item);
		}, this);

		if (!blueprint.items)
			return;

		this.markup = blueprint.markup;

		if (blueprint.faction) {
			this.obj.extendComponent('trade', 'factionVendor', blueprint);
			return;
		}

		this.genLeft = blueprint.items.max;
	},

	update: function () {
		if (this.regenCd > 0) {
			this.regenCd--;
			return;
		}

		this.regenCd = this.regenCdMax;

		if (!this.genLeft)
			return;

		this.genLeft--;

		let blueprint = this.blueprint;
		let level = 1;
		if (blueprint.level)
			level = blueprint.level.min + ~~(Math.random() * (blueprint.level.max - blueprint.level.min));

		let item = generator.generate({
			noSpell: true,
			level: level
		});

		let id = 0;
		this.items.forEach(function (checkItem) {
			if (checkItem.id >= id)
				id = checkItem.id + 1;
		});

		item.id = id;

		this.items.push(item);
	},

	startBuy: function (msg) {
		if (!msg.has('target') && !msg.targetName)
			return false;

		let target = msg.target;

		if (target && !target.id)
			target = this.obj.instance.objects.objects.find(o => o.id === target);
		else if (msg.targetName)
			target = this.obj.instance.objects.objects.find(o => ((o.name) && (o.name.toLowerCase() === msg.targetName.toLowerCase())));

		this.target = null;

		if ((!target) || (!target.trade))
			return false;

		this.target = target;

		let itemList = target.trade.getItems(this.obj);
		let markup = target.trade.markup.sell;

		if (msg.action === 'buyback') {
			itemList = target.trade.buybackList[this.obj.name] || [];
			markup = target.trade.markup.buy;
		}

		const eventMsg = {
			items: itemList,
			markup,
			action: msg.action
		};

		events.emit('onBeforeGetTradeList', eventMsg);

		this.obj.syncer.set(true, 'trade', 'buyList', {
			markup,
			items: itemList,
			buyback: (msg.action === 'buyback')
		});
	},

	buySell: function (msg) {
		if (msg.action === 'buy')
			this.buy(msg);
		else if (msg.action === 'sell')
			this.sell(msg);
		else if (msg.action === 'buyback')
			this.buyback(msg);
	},

	buy: function (msg) {
		let target = this.target;
		if (!target)
			return;

		let item = null;
		let targetTrade = target.trade;
		let markup = targetTrade.markup.sell;

		if (msg.action === 'buyback') {
			item = targetTrade.findBuyback(msg.itemId, this.obj.name);
			markup = targetTrade.markup.buy;
		} else
			item = targetTrade.findItem(msg.itemId, this.obj.name);

		if (!item) {
			this.resolveCallback(msg);
			return;
		}

		let canAfford = false;
		if (item.worth.currency) {
			let currencyItem = this.obj.inventory.items.find(i => (i.name === item.worth.currency));
			canAfford = ((currencyItem) && (currencyItem.quantity >= item.worth.amount));
		} else
			canAfford = this.gold >= ~~(item.worth * markup);

		if (!canAfford) {
			sendMessage(this.obj, 'color-redA', 'You can\'t afford that item.');
			this.resolveCallback(msg);
			return;
		}

		if (!targetTrade.canBuy(msg.itemId, this.obj, msg.action)) {
			this.resolveCallback(msg);
			return;
		}

		if (item.type === 'skin') {
			let haveSkin = this.obj.auth.doesOwnSkin(item.skinId);

			if (haveSkin) {
				sendMessage(this.obj, 'color-redA', 'You have already unlocked that skin.');
				this.resolveCallback(msg);
				return;
			}
		}

		if (msg.action === 'buyback')
			targetTrade.removeBuyback(msg.itemId, this.obj.name);
		else if ((item.type !== 'skin') && (!item.infinite)) {
			targetTrade.removeItem(msg.itemId, this.obj.name);
			targetTrade.genLeft++;
		}

		if (item.type !== 'skin') {
			let clonedItem = extend({}, item);
			if (item.worth.currency)
				clonedItem.worth = 0;
			if ((item.stats) && (item.stats.stats)) {
				delete clonedItem.stats;
				statGenerator.generate(clonedItem, {});
			}

			delete clonedItem.infinite;

			if (clonedItem.generate) {
				clonedItem = generator.generate(clonedItem);
				delete clonedItem.generate;

				if (item.factions)
					clonedItem.factions = item.factions;
			}

			if (!this.obj.inventory.getItem(clonedItem)) {
				this.resolveCallback(msg);
				return;
			}

			if (!item.infinite)
				this.obj.syncer.setArray(true, 'trade', 'removeItems', item.id);
		} else {
			this.obj.auth.saveSkin(item.skinId);
			sendMessage(this.obj, 'color-greenB', `Unlocked skin: ${item.name}.`);
		}

		const eventMsg = {
			item,
			worth: ~~(item.worth * targetTrade.markup.buy),
			action: msg.action
		};
		events.emit('onBeforeTradeItem', eventMsg);
		
		let { worth } = eventMsg;

		if (typeof(worth) === 'number') {
			targetTrade.gold += ~~(worth * markup);
			this.gold -= ~~(worth * markup);
			this.obj.syncer.set(true, 'trade', 'gold', this.gold);
		} else {
			if (!worth.push)
				worth = [worth];

			worth.forEach(w => {
				let currencyItem = this.obj.inventory.items.find(i => (i.name === w.name));
				this.obj.inventory.destroyItem(currencyItem.id, w.quantity, true);
			});
		}

		//Hack to always redraw the UI (to give items the red overlay if they can't be afforded)
		this.obj.syncer.setArray(true, 'trade', 'redraw', true);

		this.resolveCallback(msg);
	},

	buyback: function (msg) {
		msg.action = 'buyback';
		this.buy(msg);
	},

	sell: function (msg) {
		let target = this.target;
		if (!target)
			return;

		const { obj: { inventory, syncer } } = this;

		let targetTrade = target.trade;

		const item = inventory.findItem(msg.itemId);
		if (!item)
			return;

		const oldQuantity = item.quantity;
		inventory.destroyItem(msg.itemId);

		if (oldQuantity)
			item.quantity = oldQuantity;

		const eventMsg = {
			item,
			worth: ~~(item.worth * targetTrade.markup.buy),
			action: 'sell'
		};
		events.emit('onBeforeTradeItem', eventMsg);
		
		let { worth } = eventMsg;

		if (typeof(worth) === 'number') {
			this.gold += worth;
			syncer.set(true, 'trade', 'gold', this.gold);
		} else {
			if (!worth.push)
				worth = [worth];

			worth.forEach(w => inventory.getItem(w, false, false, false, true));
		}

		syncer.setArray(true, 'trade', 'removeItems', item.id);

		let buybackList = targetTrade.buybackList;
		let name = this.obj.name;
		if (!buybackList[name])
			buybackList[name] = [];

		buybackList[name].push(item);
		if (buybackList[name].length > this.maxBuyback)
			buybackList[name].splice(0, 1);
	},

	startSell: function (msg) {
		let target = msg.target;
		let targetName = (msg.targetName || '').toLowerCase();

		if (!target && !targetName)
			return false;

		if (target && !target.id)
			target = this.obj.instance.objects.objects.find(o => o.id === target);
		else if (targetName)
			target = this.obj.instance.objects.objects.find(o => ((o.name) && (o.name.toLowerCase() === targetName)));

		this.target = null;

		if ((!target) || (!target.trade))
			return false;

		this.target = target;

		const itemList = extend([], this.obj.inventory.items.filter(i => i.worth && !i.eq));

		const eventMsg = {
			items: itemList,
			markup: target.trade.markup.sell,
			action: 'sell'
		};

		events.emit('onBeforeGetTradeList', eventMsg);

		this.obj.syncer.set(true, 'trade', 'sellList', eventMsg);
	},

	startBuyback: function (msg) {
		msg.action = 'buyback';
		this.startBuy(msg);
	},

	removeItem: function (itemId) {
		return this.items.spliceFirstWhere(i => i.id === itemId);
	},

	removeBuyback: function (itemId, name) {
		return (this.buybackList[name] || []).spliceFirstWhere(i => i.id === itemId);
	},

	getItems: function (requestedBy) {
		let items = this.items.map(i => requestedBy.inventory.simplifyItem(i));

		return items;
	},

	canBuy: function (itemId, requestedBy, action) {
		return true;
	},

	findItem: function (itemId, sourceName) {
		return this.items.find(i => i.id === itemId);
	},

	findBuyback: function (itemId, sourceName) {
		return (this.buybackList[sourceName] || []).find(i => i.id === itemId);
	},

	resolveCallback: function (msg, result) {
		let callbackId = msg.has('callbackId') ? msg.callbackId : msg;
		result = result || [];

		if (!callbackId)
			return;

		process.send({
			module: 'atlas',
			method: 'resolveCallback',
			msg: {
				id: callbackId,
				result: result
			}
		});
	},

	simplify: function (self) {
		let result = {
			type: 'trade'
		};

		if (self)
			result.gold = this.gold;

		return result;
	},

	events: {
		beforeMove: function () {
			if (!this.target)
				return;

			this.obj.syncer.set(true, 'trade', 'closeTrade', true);

			this.target = null;
		}
	}
};