diff --git a/packages/mongo/oplog_tailing.ts b/packages/mongo/oplog_tailing.ts index fe99db2833..440339fa6f 100644 --- a/packages/mongo/oplog_tailing.ts +++ b/packages/mongo/oplog_tailing.ts @@ -226,14 +226,9 @@ export class OplogHandle { ); try { - const isMasterDoc = await new Promise((resolve, reject) => { - this._oplogLastEntryConnection!.db - .admin() - .command({ ismaster: 1 }, (err: Error | null, result: any) => { - if (err) reject(err); - else resolve(result); - }); - }); + const isMasterDoc = await this._oplogLastEntryConnection!.db + .admin() + .command({ ismaster: 1 }); if (!(isMasterDoc && isMasterDoc.setName)) { throw new Error("$MONGO_OPLOG_URL must be set to the 'local' database of a Mongo replica set"); @@ -426,4 +421,4 @@ export function idForOp(op: OplogEntry): string { } else { throw Error("Unknown op: " + JSON.stringify(op)); } -} \ No newline at end of file +}