mirror of
https://github.com/smogon/pokemon-showdown.git
synced 2026-03-21 17:25:10 -05:00
4b8c6a4d6d
Some checks failed
Node.js CI / build (18.x) (push) Has been cancelled
This minimizes side effects of import/require across the codebase, and lets the caller be responsible of initializing child processeses, as well as other async logic, such as restoring saved battles.
115 lines
3.2 KiB
TypeScript
115 lines
3.2 KiB
TypeScript
/**
|
|
* Team Validator
|
|
* Pokemon Showdown - http://pokemonshowdown.com/
|
|
*
|
|
* Spawns a child process to validate teams.
|
|
*
|
|
* @license MIT
|
|
*/
|
|
|
|
import { TeamValidator } from '../sim/team-validator';
|
|
import * as ConfigLoader from './config-loader';
|
|
|
|
export const PM = new QueryProcessManager<{
|
|
formatid: string, options?: { removeNicknames?: boolean }, team: string,
|
|
}>('team-validator', module, message => {
|
|
const { formatid, options, team } = message;
|
|
const parsedTeam = Teams.unpack(team);
|
|
|
|
if (Config.debugvalidatorprocesses && process.send) {
|
|
process.send('DEBUG\n' + JSON.stringify(message));
|
|
}
|
|
|
|
let problems;
|
|
try {
|
|
problems = TeamValidator.get(formatid).validateTeam(parsedTeam, options);
|
|
} catch (err) {
|
|
Monitor.crashlog(err, 'A team validation', {
|
|
formatid,
|
|
team,
|
|
});
|
|
problems = [
|
|
`Your team crashed the validator. We'll fix this crash within a few hours (we're automatically notified),` +
|
|
` but if you don't want to wait, just use a different team for now.`,
|
|
];
|
|
}
|
|
|
|
if (problems?.length) {
|
|
return '0' + problems.join('\n');
|
|
}
|
|
const packedTeam = Teams.pack(parsedTeam);
|
|
// console.log('FROM: ' + message.substr(pipeIndex2 + 1));
|
|
// console.log('TO: ' + packedTeam);
|
|
return '1' + packedTeam;
|
|
}, 2 * 60 * 1000);
|
|
|
|
export class TeamValidatorAsync {
|
|
static PM = PM;
|
|
|
|
format: Format;
|
|
|
|
constructor(format: string) {
|
|
this.format = Dex.formats.get(format);
|
|
}
|
|
|
|
validateTeam(team: string, options?: { removeNicknames?: boolean, user?: ID }) {
|
|
let formatid = this.format.id;
|
|
if (this.format.customRules) formatid += '@@@' + this.format.customRules.join(',');
|
|
if (team.length > (25 * 1024 - 6)) { // don't even let it go to the child process
|
|
return Promise.resolve('0Your team is over 25KB. Please use a smaller team.');
|
|
}
|
|
return PM.query({ formatid, options, team });
|
|
}
|
|
|
|
static get(this: void, format: string) {
|
|
return new TeamValidatorAsync(format);
|
|
}
|
|
|
|
static start(processCount: ConfigLoader.SubProcessesConfig) {
|
|
start(processCount);
|
|
}
|
|
}
|
|
|
|
export const get = TeamValidatorAsync.get;
|
|
|
|
/*********************************************************
|
|
* Process manager
|
|
*********************************************************/
|
|
|
|
import { QueryProcessManager } from '../lib/process-manager';
|
|
|
|
if (!PM.isParentProcess) {
|
|
ConfigLoader.ensureLoaded();
|
|
global.Monitor = {
|
|
crashlog(error: Error, source = 'A team validator process', details: AnyObject | null = null) {
|
|
const repr = JSON.stringify([error.name, error.message, source, details]);
|
|
process.send!(`THROW\n@!!@${repr}\n${error.stack}`);
|
|
},
|
|
};
|
|
|
|
if (Config.crashguard) {
|
|
process.on('uncaughtException', (err: Error) => {
|
|
Monitor.crashlog(err, `A team validator process`);
|
|
});
|
|
process.on('unhandledRejection', err => {
|
|
Monitor.crashlog(err as any || {}, 'A team validator process Promise');
|
|
});
|
|
}
|
|
|
|
global.Dex = require('../sim/dex').Dex.includeData();
|
|
global.Teams = require('../sim/teams').Teams;
|
|
|
|
// eslint-disable-next-line no-eval
|
|
PM.startRepl((cmd: string) => eval(cmd));
|
|
}
|
|
|
|
export function start(processCount: ConfigLoader.SubProcessesConfig) {
|
|
PM.spawn(processCount['validator'] ?? 1);
|
|
}
|
|
|
|
export function destroy() {
|
|
// No need to destroy the PM under normal circumstances, since
|
|
// hotpatching uses PM.respawn()
|
|
void PM.destroy();
|
|
}
|