Leahnaya/pokemon-showdown
1
0
Fork 0
mirror of https://github.com/smogon/pokemon-showdown.git synced 2026-05-09 04:23:45 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Chat: Actually spawn child processes

Browse Source 
SQL() to be called in something instantiated directly in the file, or at the top level, or the PM will not work.
This commit is contained in:
Mia 2021-08-15 15:42:58 -05:00
parent 0a2ed42d13
commit c8dc1adb9c
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
server/chat.ts
View File

@ -1690,13 +1690,12 @@ export const Chat = new class {
* All chat plugins share one database.
* Chat.databaseReadyPromise will be truthy if the database is not yet ready.
*/
database: SQLDatabaseManager | null = null;
database = SQL(module, {file: ('Config' in global && Config.nofswriting) ? ':memory:' : PLUGIN_DATABASE_PATH});
databaseReadyPromise: Promise<void> | null = null;
async prepareDatabase() {
if (process.send) return; // We don't need a database in a subprocess that requires Chat.
if (!Config.usesqlite) return;
this.database = SQL(module, {file: ('Config' in global && Config.nofswriting) ? ':memory:' : PLUGIN_DATABASE_PATH});
// check if we have the db_info table, which will always be present unless the schema needs to be initialized
let statement = await this.database.prepare(
`SELECT count(*) AS hasDBInfo FROM sqlite_master WHERE type = 'table' AND name = 'db_info'`
@ -2500,3 +2499,20 @@ export interface Monitor {
condition?: string;
monitor?: MonitorHandler;
}
if (Chat.database.isParentProcess) {
Chat.database.spawn(Config.chatdbprocesses || 1);
} else {
global.Monitor = {
crashlog(error: Error, source = 'A chat child process', details: AnyObject | null = null) {
const repr = JSON.stringify([error.name, error.message, source, details]);
process.send!(`THROW\n@!!@${repr}\n${error.stack}`);
},
};
process.on('uncaughtException', err => {
Monitor.crashlog(err, 'A chat database process');
});
process.on('unhandledRejection', err => {
Monitor.crashlog(err as Error, 'A chat database process');
});
}