Spaces:
Running
Running
File size: 3,022 Bytes
5c2ed06 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 |
/**
* Team Validator
* Pokemon Showdown - http://pokemonshowdown.com/
*
* Spawns a child process to validate teams.
*
* @license MIT
*/
import { TeamValidator } from '../sim/team-validator';
export class TeamValidatorAsync {
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);
}
}
export const get = TeamValidatorAsync.get;
/*********************************************************
* Process manager
*********************************************************/
import { QueryProcessManager } from '../lib/process-manager';
export const PM = new QueryProcessManager<{
formatid: string, options?: { removeNicknames?: boolean }, team: string,
}>(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);
if (!PM.isParentProcess) {
// This is a child process!
global.Config = require('./config-loader').Config;
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
require('../lib/repl').Repl.start(`team-validator-${process.pid}`, (cmd: string) => eval(cmd));
} else {
PM.spawn(global.Config ? Config.validatorprocesses : 1);
}
|