apps/meteor/server/database/DatabaseWatcher.ts
Function watchOplog
has 42 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
private async watchOplog(): Promise<void> {
if (!process.env.MONGO_OPLOG_URL) {
throw Error('No $MONGO_OPLOG_URL provided');
}
Function watchChangeStream
has 41 lines of code (exceeds 25 allowed). Consider refactoring. Open
Open
private watchChangeStream(resumeToken?: unknown): void {
try {
const options = {
...(useFullDocument ? { fullDocument: 'updateLookup' } : {}),
...(resumeToken ? { startAfter: resumeToken } : {}),