OperationBase => AbstractOperation

Author: mbroadst

src/index.ts

@@ -222,7 +222,7 @@ export type {
   MapReduceOptions,
   FinalizeFunction
 } from './operations/map_reduce';
-export type { Hint, OperationOptions, OperationBase } from './operations/operation';
+export type { Hint, OperationOptions, AbstractOperation as OperationBase } from './operations/operation';
 export type { ProfilingLevelOptions } from './operations/profiling_level';
 export type { RemoveUserOptions } from './operations/remove_user';
 export type { RenameOptions } from './operations/rename';

src/operations/bulk_write.ts

@@ -1,5 +1,5 @@
 import { applyRetryableWrites, Callback } from '../utils';
-import { Aspect, defineAspects, OperationBase } from './operation';
+import { Aspect, defineAspects, AbstractOperation } from './operation';
 import type { Collection } from '../collection';
 import type {
   BulkOperationBase,
@@ -10,7 +10,7 @@ import type {
 import type { Server } from '../sdam/server';
 
 /** @internal */
-export class BulkWriteOperation extends OperationBase<BulkWriteOptions, BulkWriteResult> {
+export class BulkWriteOperation extends AbstractOperation<BulkWriteOptions, BulkWriteResult> {
   collection: Collection;
   operations: AnyBulkWriteOperation[];
 

src/operations/collections.ts

@@ -1,4 +1,4 @@
-import { OperationBase, OperationOptions } from './operation';
+import { AbstractOperation, OperationOptions } from './operation';
 import { loadCollection } from '../dynamic_loaders';
 import type { Callback } from '../utils';
 import type { Db } from '../db';
@@ -12,7 +12,7 @@ export interface CollectionsOptions extends OperationOptions {
 }
 
 /** @internal */
-export class CollectionsOperation extends OperationBase<CollectionsOptions, Collection[]> {
+export class CollectionsOperation extends AbstractOperation<CollectionsOptions, Collection[]> {
   db: Db;
 
   constructor(db: Db, options: CollectionsOptions) {

src/operations/command.ts

@@ -1,4 +1,4 @@
-import { Aspect, OperationBase, OperationOptions } from './operation';
+import { Aspect, AbstractOperation, OperationOptions } from './operation';
 import { ReadConcern } from '../read_concern';
 import { WriteConcern, WriteConcernOptions } from '../write_concern';
 import { maxWireVersion, MongoDBNamespace, Callback, decorateWithExplain } from '../utils';
@@ -48,7 +48,7 @@ export interface OperationParent {
 }
 
 /** @internal */
-export abstract class CommandOperation<TResult = Document> extends OperationBase {
+export abstract class CommandOperation<TResult = Document> extends AbstractOperation {
   options: CommandOperationOptions;
   ns: MongoDBNamespace;
   readConcern?: ReadConcern;

src/operations/delete.ts

@@ -1,4 +1,4 @@
-import { defineAspects, Aspect, OperationBase, Hint } from './operation';
+import { defineAspects, Aspect, AbstractOperation, Hint } from './operation';
 import { removeDocuments } from './common_functions';
 import { CommandOperation, CommandOperationOptions } from './command';
 import { isObject } from 'util';
@@ -28,7 +28,7 @@ export interface DeleteResult {
 }
 
 /** @internal */
-export class DeleteOperation extends OperationBase<DeleteOptions, Document> {
+export class DeleteOperation extends AbstractOperation<DeleteOptions, Document> {
   operations: Document[];
 
   constructor(ns: MongoDBNamespace, ops: Document[], options: DeleteOptions) {

src/operations/execute_operation.ts

@@ -1,6 +1,6 @@
 import { ReadPreference } from '../read_preference';
 import { MongoError, isRetryableError, AnyError } from '../error';
-import { Aspect, OperationBase, OperationOptions } from './operation';
+import { Aspect, AbstractOperation, OperationOptions } from './operation';
 import { maxWireVersion, maybePromise, Callback } from '../utils';
 import { ServerType } from '../sdam/common';
 import type { Server } from '../sdam/server';
@@ -12,13 +12,13 @@ const MMAPv1_RETRY_WRITES_ERROR_CODE = 20;
 const MMAPv1_RETRY_WRITES_ERROR_MESSAGE =
   'This MongoDB deployment does not support retryable writes. Please add retryWrites=false to your connection string.';
 
-type ResultTypeFromOperation<TOperation> = TOperation extends OperationBase<
+type ResultTypeFromOperation<TOperation> = TOperation extends AbstractOperation<
   OperationOptions,
   infer K
 >
   ? K
   : never;
-type OptionsFromOperation<TOperation> = TOperation extends OperationBase<infer K, unknown>
+type OptionsFromOperation<TOperation> = TOperation extends AbstractOperation<infer K, unknown>
   ? K
   : never;
 
@@ -48,26 +48,26 @@ export interface ExecutionResult {
  * @param callback - The command result callback
  */
 export function executeOperation<
-  T extends OperationBase<TOptions, TResult>,
+  T extends AbstractOperation<TOptions, TResult>,
   TOptions = OptionsFromOperation<T>,
   TResult = ResultTypeFromOperation<T>
 >(topology: Topology, operation: T): Promise<TResult>;
 export function executeOperation<
-  T extends OperationBase<TOptions, TResult>,
+  T extends AbstractOperation<TOptions, TResult>,
   TOptions = OptionsFromOperation<T>,
   TResult = ResultTypeFromOperation<T>
 >(topology: Topology, operation: T, callback: Callback<TResult>): void;
 export function executeOperation<
-  T extends OperationBase<TOptions, TResult>,
+  T extends AbstractOperation<TOptions, TResult>,
   TOptions = OptionsFromOperation<T>,
   TResult = ResultTypeFromOperation<T>
 >(topology: Topology, operation: T, callback?: Callback<TResult>): Promise<TResult> | void;
 export function executeOperation<
-  T extends OperationBase<TOptions, TResult>,
+  T extends AbstractOperation<TOptions, TResult>,
   TOptions = OptionsFromOperation<T>,
   TResult = ResultTypeFromOperation<T>
 >(topology: Topology, operation: T, callback?: Callback<TResult>): Promise<TResult> | void {
-  if (!(operation instanceof OperationBase)) {
+  if (!(operation instanceof AbstractOperation)) {
     throw new TypeError('This method requires a valid operation instance');
   }
 

src/operations/indexes.ts

@@ -1,5 +1,5 @@
 import { indexInformation, IndexInformationOptions } from './common_functions';
-import { OperationBase, Aspect, defineAspects } from './operation';
+import { AbstractOperation, Aspect, defineAspects } from './operation';
 import { MongoError } from '../error';
 import {
   maxWireVersion,
@@ -126,7 +126,7 @@ function makeIndexSpec(indexSpec: IndexSpecification, options: any): IndexDescri
 }
 
 /** @internal */
-export class IndexesOperation extends OperationBase<IndexInformationOptions, Document> {
+export class IndexesOperation extends AbstractOperation<IndexInformationOptions, Document> {
   collection: Collection;
 
   constructor(collection: Collection, options: IndexInformationOptions) {
@@ -401,7 +401,7 @@ export class ListIndexesCursor extends AbstractCursor {
 }
 
 /** @internal */
-export class IndexExistsOperation extends OperationBase<IndexInformationOptions, boolean> {
+export class IndexExistsOperation extends AbstractOperation<IndexInformationOptions, boolean> {
   collection: Collection;
   indexes: string | string[];
 
@@ -440,7 +440,7 @@ export class IndexExistsOperation extends OperationBase<IndexInformationOptions,
 }
 
 /** @internal */
-export class IndexInformationOperation extends OperationBase<IndexInformationOptions, Document> {
+export class IndexInformationOperation extends AbstractOperation<IndexInformationOptions, Document> {
   db: Db;
   name: string;
 

src/operations/insert.ts

@@ -1,5 +1,5 @@
 import { MongoError } from '../error';
-import { defineAspects, Aspect, OperationBase } from './operation';
+import { defineAspects, Aspect, AbstractOperation } from './operation';
 import { CommandOperation } from './command';
 import { applyRetryableWrites, Callback, MongoDBNamespace } from '../utils';
 import { prepareDocs } from './common_functions';
@@ -12,7 +12,7 @@ import type { BulkWriteOptions } from '../bulk/common';
 import type { WriteConcernOptions } from '../write_concern';
 
 /** @internal */
-export class InsertOperation extends OperationBase<BulkWriteOptions, Document> {
+export class InsertOperation extends AbstractOperation<BulkWriteOptions, Document> {
   operations: Document[];
 
   constructor(ns: MongoDBNamespace, ops: Document[], options: BulkWriteOptions) {

src/operations/insert_many.ts

@@ -1,4 +1,4 @@
-import { Aspect, defineAspects, OperationBase } from './operation';
+import { Aspect, defineAspects, AbstractOperation } from './operation';
 import { BulkWriteOperation } from './bulk_write';
 import { MongoError } from '../error';
 import { prepareDocs } from './common_functions';
@@ -21,7 +21,7 @@ export interface InsertManyResult {
 }
 
 /** @internal */
-export class InsertManyOperation extends OperationBase<BulkWriteOptions, InsertManyResult> {
+export class InsertManyOperation extends AbstractOperation<BulkWriteOptions, InsertManyResult> {
   collection: Collection;
   docs: Document[];
 

src/operations/is_capped.ts

@@ -1,11 +1,11 @@
 import type { Callback } from '../utils';
 import type { Collection } from '../collection';
-import { OperationOptions, OperationBase } from './operation';
+import { OperationOptions, AbstractOperation } from './operation';
 import type { Server } from '../sdam/server';
 import { MongoError } from '..';
 
 /** @internal */
-export class IsCappedOperation extends OperationBase<OperationOptions, boolean> {
+export class IsCappedOperation extends AbstractOperation<OperationOptions, boolean> {
   collection: Collection;
 
   constructor(collection: Collection, options: OperationOptions) {

src/operations/operation.ts

@@ -35,7 +35,7 @@ export interface OperationOptions extends BSONSerializeOptions {
  * a specific aspect.
  * @internal
  */
-export abstract class OperationBase<
+export abstract class AbstractOperation<
   T extends OperationOptions = OperationOptions,
   TResult = Document
 > {

src/operations/options_operation.ts

@@ -1,12 +1,12 @@
-import { OperationBase, OperationOptions } from './operation';
+import { AbstractOperation, OperationOptions } from './operation';
 import { MongoError } from '../error';
 import type { Callback } from '../utils';
 import type { Document } from '../bson';
 import type { Collection } from '../collection';
 import type { Server } from '../sdam/server';
 
 /** @internal */
-export class OptionsOperation extends OperationBase<OperationOptions, Document> {
+export class OptionsOperation extends AbstractOperation<OperationOptions, Document> {
   collection: Collection;
 
   constructor(collection: Collection, options: OperationOptions) {

src/operations/update.ts

@@ -1,4 +1,4 @@
-import { defineAspects, Aspect, OperationBase } from './operation';
+import { defineAspects, Aspect, AbstractOperation } from './operation';
 import { updateDocuments } from './common_functions';
 import { hasAtomicOperators, MongoDBNamespace, Callback } from '../utils';
 import { CommandOperation, CommandOperationOptions } from './command';
@@ -41,7 +41,7 @@ export interface UpdateResult {
 }
 
 /** @internal */
-export class UpdateOperation extends OperationBase<UpdateOptions, Document> {
+export class UpdateOperation extends AbstractOperation<UpdateOptions, Document> {
   operations: Document[];
 
   constructor(ns: MongoDBNamespace, ops: Document[], options: UpdateOptions) {

src/utils.ts

@@ -8,7 +8,7 @@ import type { Topology } from './sdam/topology';
 import type { EventEmitter } from 'events';
 import type { Db } from './db';
 import type { Collection } from './collection';
-import type { OperationOptions, OperationBase, Hint } from './operations/operation';
+import type { OperationOptions, AbstractOperation, Hint } from './operations/operation';
 import type { ClientSession } from './sessions';
 import { ReadConcern } from './read_concern';
 import type { Connection } from './cmap/connection';
@@ -232,7 +232,7 @@ export function filterOptions(options: AnyOptions, names: string[]): AnyOptions
  * @param args - Arguments to apply the provided operation
  * @param options - Options that modify the behavior of the method
  */
-export function executeLegacyOperation<T extends OperationBase>(
+export function executeLegacyOperation<T extends AbstractOperation>(
   topology: Topology,
   operation: (...args: any[]) => void | Promise<Document>,
   args: any[],