mirror of
https://github.com/smogon/pokemon-showdown.git
synced 2026-05-17 18:51:43 -05:00
7436c1f0f2
`import =` and `export =` are really only intended for backwards compatibility with CommonJS. While I really don't like the new module system TC39 has designed for us, it's what we should be using, and consistency is important.
123 lines
3.5 KiB
JavaScript
123 lines
3.5 KiB
JavaScript
/**
|
|
* Team Validator
|
|
* Pokemon Showdown - http://pokemonshowdown.com/
|
|
*
|
|
* Spawns a child process to validate teams.
|
|
*
|
|
* @license MIT
|
|
*/
|
|
|
|
'use strict';
|
|
|
|
/** @type {typeof import('../lib/crashlogger').crashlogger} */
|
|
let crashlogger = require(/** @type {any} */('../.lib-dist/crashlogger')).crashlogger;
|
|
|
|
class ValidatorAsync {
|
|
/**
|
|
* @param {string} format
|
|
*/
|
|
constructor(format) {
|
|
this.format = Dex.getFormat(format);
|
|
}
|
|
|
|
/**
|
|
* @param {string} team
|
|
* @param {boolean} [removeNicknames]
|
|
*/
|
|
validateTeam(team, removeNicknames = false) {
|
|
let formatid = this.format.id;
|
|
if (this.format.customRules) formatid += '@@@' + this.format.customRules.join(',');
|
|
return PM.query({formatid, removeNicknames, team});
|
|
}
|
|
}
|
|
|
|
/*********************************************************
|
|
* Process manager
|
|
*********************************************************/
|
|
|
|
/** @type {typeof import('../lib/process-manager').QueryProcessManager} */
|
|
const QueryProcessManager = require(/** @type {any} */('../.lib-dist/process-manager')).QueryProcessManager;
|
|
|
|
/** @type {QueryProcessManager} */
|
|
// @ts-ignore
|
|
const PM = new QueryProcessManager(module, async message => {
|
|
let {formatid, removeNicknames, team} = message;
|
|
let parsedTeam = Dex.fastUnpackTeam(team);
|
|
|
|
let problems;
|
|
try {
|
|
problems = TeamValidator(formatid).validateTeam(parsedTeam, removeNicknames);
|
|
} catch (err) {
|
|
crashlogger(err, 'A team validation', {
|
|
formatid: formatid,
|
|
team: team,
|
|
});
|
|
problems = [`Your team crashed the team validator. We've been automatically notified and will fix this crash, but you should use a different team for now.`];
|
|
}
|
|
|
|
if (problems && problems.length) {
|
|
return '0' + problems.join('\n');
|
|
}
|
|
let packedTeam = Dex.packTeam(parsedTeam);
|
|
// console.log('FROM: ' + message.substr(pipeIndex2 + 1));
|
|
// console.log('TO: ' + packedTeam);
|
|
return '1' + packedTeam;
|
|
});
|
|
|
|
if (!PM.isParentProcess) {
|
|
// This is a child process!
|
|
// @ts-ignore This file doesn't exist on the repository, so Travis checks fail if this isn't ignored
|
|
global.Config = require('../config/config');
|
|
|
|
global.TeamValidator = require(/** @type {any} */ ('../.sim-dist/team-validator')).TeamValidator;
|
|
// @ts-ignore ???
|
|
global.Monitor = {
|
|
/**
|
|
* @param {Error} error
|
|
* @param {string} source
|
|
* @param {{}?} details
|
|
*/
|
|
crashlog(error, source = 'A team validator process', details = null) {
|
|
const repr = JSON.stringify([error.name, error.message, source, details]);
|
|
// @ts-ignore
|
|
process.send(`THROW\n@!!@${repr}\n${error.stack}`);
|
|
},
|
|
};
|
|
|
|
if (Config.crashguard) {
|
|
process.on('uncaughtException', err => {
|
|
Monitor.crashlog(err, `A team validator process`);
|
|
});
|
|
process.on('unhandledRejection', err => {
|
|
if (err instanceof Error) {
|
|
Monitor.crashlog(err, 'A team validator process Promise');
|
|
}
|
|
});
|
|
}
|
|
|
|
global.Dex = require(/** @type {any} */ ('../.sim-dist/dex')).Dex.includeData();
|
|
global.toID = Dex.getId;
|
|
global.Chat = require('./chat');
|
|
|
|
/** @type {typeof import('../lib/repl').Repl} */
|
|
const Repl = require(/** @type {any} */('../.lib-dist/repl')).Repl;
|
|
Repl.start(`team-validator-${process.pid}`, cmd => eval(cmd));
|
|
} else {
|
|
PM.spawn(global.Config ? Config.validatorprocesses : 1);
|
|
}
|
|
|
|
/*********************************************************
|
|
* Exports
|
|
*********************************************************/
|
|
|
|
function getAsyncValidator(/** @type {string} */ format) {
|
|
return new ValidatorAsync(format);
|
|
}
|
|
|
|
let TeamValidatorAsync = Object.assign(getAsyncValidator, {
|
|
ValidatorAsync,
|
|
PM,
|
|
});
|
|
|
|
module.exports = TeamValidatorAsync;
|