pull up error from executeLegacyOperation

Author: HanaPearlman

src/gridfs-stream/index.ts

@@ -1,4 +1,4 @@
-import { MongoError } from '../error';
+import { MongoClientClosedError, MongoError } from '../error';
 import { EventEmitter } from 'events';
 import {
   GridFSBucketReadStream,
@@ -134,6 +134,7 @@ export class GridFSBucket extends EventEmitter {
   delete(id: TFileId): Promise<undefined>;
   delete(id: TFileId, callback: Callback<void>): void;
   delete(id: TFileId, callback?: Callback<void>): Promise<undefined> | void {
+    if (!this.s.db.topology) throw new MongoClientClosedError();
     return executeLegacyOperation(this.s.db.topology, _delete, [this, id, callback], {
       skipSessions: true
     });
@@ -185,6 +186,7 @@ export class GridFSBucket extends EventEmitter {
   rename(id: TFileId, filename: string): Promise<void>;
   rename(id: TFileId, filename: string, callback: Callback<void>): void;
   rename(id: TFileId, filename: string, callback?: Callback<void>): Promise<void> | void {
+    if (!this.s.db.topology) throw new MongoClientClosedError();
     return executeLegacyOperation(this.s.db.topology, _rename, [this, id, filename, callback], {
       skipSessions: true
     });
@@ -194,6 +196,7 @@ export class GridFSBucket extends EventEmitter {
   drop(): Promise<void>;
   drop(callback: Callback<void>): void;
   drop(callback?: Callback<void>): Promise<void> | void {
+    if (!this.s.db.topology) throw new MongoClientClosedError();
     return executeLegacyOperation(this.s.db.topology, _drop, [this, callback], {
       skipSessions: true
     });

src/utils.ts

@@ -263,7 +263,7 @@ export function mergeOptionsAndWriteConcern(
  * @param options - Options that modify the behavior of the method
  */
 export function executeLegacyOperation<T extends OperationBase>(
-  topology: Topology | undefined,
+  topology: Topology,
   operation: (...args: any[]) => void | Promise<Document>,
   args: any[],
   options?: AnyOptions