mirror of
https://github.com/zkldi/Tachi.git
synced 2026-10-10 16:28:17 +03:00
fix: refactor process.exit(1) calls to run after logger flushes
https://stackoverflow.com/questions/18771707/how-to-flush-winston-logs
This commit is contained in:
@@ -113,8 +113,9 @@ if (require.main === module) {
|
||||
process.exit(0);
|
||||
})
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to anonymise database.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to anonymise database.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
@@ -29,8 +29,8 @@ if (require.main === module) {
|
||||
|
||||
process.exit(0);
|
||||
})().catch((err: unknown) => {
|
||||
logger.error(`Failed to send test email.`, { err });
|
||||
|
||||
process.exit(1);
|
||||
logger.error(`Failed to send test email.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -6,6 +6,7 @@ const logger = CreateLogCtx(__filename);
|
||||
InitaliseFolderChartLookup()
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to initialise folder chart lookup.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to initialise folder chart lookup.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -224,7 +224,8 @@ if (require.main === module) {
|
||||
FetchSP12Data()
|
||||
.then(process.exit(0))
|
||||
.catch((err) => {
|
||||
logger.error(err);
|
||||
process.exit(1);
|
||||
logger.error(`Failed to fetch sp12 data. ${err}`, err, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -7,7 +7,8 @@ if (require.main === module) {
|
||||
InitSequenceDocs()
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to initialise sequence documents.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to initialise sequence documents.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -28,10 +28,12 @@ db.invites
|
||||
consumedAt: null,
|
||||
})
|
||||
.then(() => {
|
||||
logger.info(`Created invite ${code}.`);
|
||||
process.exit(0);
|
||||
logger.info(`Created invite ${code}.`, () => {
|
||||
process.exit(0);
|
||||
});
|
||||
})
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to create invite ${code}`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to create invite ${code}`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -54,12 +54,12 @@ if (require.main === module) {
|
||||
}
|
||||
}
|
||||
|
||||
logger.info(`Done!`);
|
||||
|
||||
process.exit(0);
|
||||
logger.info(`Done!`, () => {
|
||||
process.exit(0);
|
||||
});
|
||||
})().catch((err: unknown) => {
|
||||
logger.error(`Failed to patch invalid IIDX grades.`, { err });
|
||||
|
||||
process.exit(1);
|
||||
logger.error(`Failed to patch invalid IIDX grades.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -48,8 +48,8 @@ if (require.main === module) {
|
||||
removedFolders,
|
||||
});
|
||||
})().catch((err: unknown) => {
|
||||
logger.error(`Failed to patch stale showcase-stat folder references.`, { err });
|
||||
|
||||
process.exit(1);
|
||||
logger.error(`Failed to patch stale showcase-stat folder references.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -19,6 +19,7 @@ const options: { db: string; reset?: boolean } = program.opts();
|
||||
SetIndexes(options.db, options.reset === true)
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to set indexes.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to set indexes.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -36,10 +36,12 @@ async function DedupeScoreIDs() {
|
||||
|
||||
DedupeScoreIDs()
|
||||
.then(() => {
|
||||
logger.info(`Finished deduping score IDs.`);
|
||||
process.exit(0);
|
||||
logger.info(`Finished deduping score IDs.`, () => {
|
||||
process.exit(0);
|
||||
});
|
||||
})
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to dedupe score IDs.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to dedupe score IDs.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -6,11 +6,13 @@ const logger = CreateLogCtx(__filename);
|
||||
if (require.main === module) {
|
||||
RecalcAllScores()
|
||||
.then(() => {
|
||||
logger.info(`Successfully recalced all scores.`);
|
||||
process.exit(0);
|
||||
logger.info(`Successfully recalced all scores.`, () => {
|
||||
process.exit(0);
|
||||
});
|
||||
})
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to recalc all scores.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to recalc all scores.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -45,7 +45,8 @@ if (require.main === module) {
|
||||
RecalcGameProfiles()
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to recalc game profiles.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to recalc game profiles.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -7,7 +7,8 @@ if (require.main === module) {
|
||||
RecalcSessions()
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to recalc sessions.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to recalc sessions.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -11,9 +11,11 @@ const logger = CreateLogCtx(__filename);
|
||||
await RecalcGameProfiles();
|
||||
await RecalcSessions();
|
||||
|
||||
logger.info(`Completely done!`);
|
||||
process.exit(0);
|
||||
logger.info(`Completely done!`, () => {
|
||||
process.exit(0);
|
||||
});
|
||||
})().catch((err: unknown) => {
|
||||
logger.error(`Failed to sync state.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to sync state.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
|
||||
@@ -11,7 +11,8 @@ if (require.main === module) {
|
||||
process.exit(0);
|
||||
})
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to update all PBs.`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to update all PBs.`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
@@ -67,15 +67,21 @@ if (require.main === module) {
|
||||
ValidateCollection(options.collection as Databases)
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to validate collection ${options.collection}?`, { err });
|
||||
process.exit(1);
|
||||
logger.error(
|
||||
`Failed to validate collection ${options.collection}?`,
|
||||
{ err },
|
||||
() => {
|
||||
process.exit(1);
|
||||
}
|
||||
);
|
||||
});
|
||||
} else {
|
||||
ValidateAllCollections()
|
||||
.then(() => process.exit(0))
|
||||
.catch((err: unknown) => {
|
||||
logger.error(`Failed to validate all collections?`, { err });
|
||||
process.exit(1);
|
||||
logger.error(`Failed to validate all collections?`, { err }, () => {
|
||||
process.exit(1);
|
||||
});
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user