diff --git a/app/models/server/models/_oplogHandle.ts b/app/models/server/models/_oplogHandle.ts index eb0e7eba779a0..811a8fb9db3c3 100644 --- a/app/models/server/models/_oplogHandle.ts +++ b/app/models/server/models/_oplogHandle.ts @@ -105,7 +105,7 @@ class OplogHandle { this.stream = oplogCollection.find(oplogSelector, { tailable: true, - // awaitData: true, + awaitData: true, }).stream(); // Prevent warning about many listeners, we add 11 diff --git a/mongodb.aug.d.ts b/mongodb.aug.d.ts new file mode 100644 index 0000000000000..450b440065b23 --- /dev/null +++ b/mongodb.aug.d.ts @@ -0,0 +1,8 @@ +import 'mongodb'; + +declare module 'mongodb' { + // eslint-disable-next-line @typescript-eslint/interface-name-prefix + export interface FindOneOptions { + awaitData?: boolean; + } +}