chore(NODE-5073): remove dead code (mongodb#3588)

Co-authored-by: Durran Jordan <durran@gmail.com>

Author: baileympearson

src/cmap/connection.ts

@@ -74,7 +74,6 @@ const INVALID_QUEUE_SIZE = 'Connection internal queue contains more than 1 opera
 
 /** @internal */
 export interface CommandOptions extends BSONSerializeOptions {
- command?: boolean;
  secondaryOk?: boolean;
  /** Specify read preference if command supports it */
  readPreference?: ReadPreferenceLike;
@@ -401,22 +400,14 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
  this.emit(Connection.CLUSTER_TIME_RECEIVED, document.$clusterTime);
  }
 
- if (operationDescription.command) {
- if (document.writeConcernError) {
- callback(new MongoWriteConcernError(document.writeConcernError, document), document);
- return;
- }
+ if (document.writeConcernError) {
+ callback(new MongoWriteConcernError(document.writeConcernError, document), document);
+ return;
+ }
 
- if (document.ok === 0 || document.$err || document.errmsg || document.code) {
- callback(new MongoServerError(document));
- return;
- }
- } else {
- // Pre 3.2 support
- if (document.ok === 0 || document.$err || document.errmsg) {
- callback(new MongoServerError(document));
- return;
- }
+ if (document.ok === 0 || document.$err || document.errmsg || document.code) {
+ callback(new MongoServerError(document));
+ return;
  }
  }
 
@@ -538,7 +529,6 @@ export class Connection extends TypedEventEmitter<ConnectionEvents> {
 
  const commandOptions: Document = Object.assign(
  {
- command: true,
  numberToSkip: 0,
  numberToReturn: -1,
  checkKeys: false,
@@ -678,7 +668,6 @@ function write(
  session: options.session,
  noResponse: typeof options.noResponse === 'boolean' ? options.noResponse : false,
  documentsReturnedIn: options.documentsReturnedIn,
- command: !!options.command,
 
  // for BSON parsing
  useBigInt64: typeof options.useBigInt64 === 'boolean' ? options.useBigInt64 : false,

src/cmap/message_stream.ts

@@ -30,7 +30,6 @@ export interface MessageStreamOptions extends DuplexOptions {
 export interface OperationDescription extends BSONSerializeOptions {
  started: number;
  cb: Callback<Document>;
- command: boolean;
  documentsReturnedIn?: string;
  noResponse: boolean;
  raw: boolean;

src/cmap/wire_protocol/shared.ts

@@ -7,8 +7,7 @@ import type { Server } from '../../sdam/server';
 import type { ServerDescription } from '../../sdam/server_description';
 import type { Topology } from '../../sdam/topology';
 import { TopologyDescription } from '../../sdam/topology_description';
-import type { OpQueryOptions } from '../commands';
-import type { CommandOptions, Connection } from '../connection';
+import type { Connection } from '../connection';
 
 export interface ReadPreferenceOption {
  readPreference?: ReadPreferenceLike;
@@ -35,27 +34,6 @@ export function getReadPreference(cmd: Document, options?: ReadPreferenceOption)
  return readPreference;
 }
 
-export function applyCommonQueryOptions(
- queryOptions: OpQueryOptions,
- options: CommandOptions
-): CommandOptions {
- Object.assign(queryOptions, {
- raw: typeof options.raw === 'boolean' ? options.raw : false,
- promoteLongs: typeof options.promoteLongs === 'boolean' ? options.promoteLongs : true,
- promoteValues: typeof options.promoteValues === 'boolean' ? options.promoteValues : true,
- promoteBuffers: typeof options.promoteBuffers === 'boolean' ? options.promoteBuffers : false,
- bsonRegExp: typeof options.bsonRegExp === 'boolean' ? options.bsonRegExp : false,
- enableUtf8Validation:
- typeof options.enableUtf8Validation === 'boolean' ? options.enableUtf8Validation : true
- });
-
- if (options.session) {
- queryOptions.session = options.session;
- }
-
- return queryOptions;
-}
-
 export function isSharded(topologyOrServer?: Topology | Server | Connection): boolean {
  if (topologyOrServer == null) {
  return false;

src/utils.ts

@@ -29,7 +29,7 @@ import { ServerType } from './sdam/common';
 import type { Server } from './sdam/server';
 import type { Topology } from './sdam/topology';
 import type { ClientSession } from './sessions';
-import { W, WriteConcern, WriteConcernOptions } from './write_concern';
+import { WriteConcern } from './write_concern';
 
 /**
  * MongoDB Driver style callback
@@ -167,9 +167,6 @@ export function applyRetryableWrites<T extends HasRetryableWrites>(target: T, db
  return target;
 }
 
-interface HasWriteConcern {
- writeConcern?: WriteConcernOptions | WriteConcern | W;
-}
 /**
  * Applies a write concern to a command based on well defined inheritance rules, optionally
  * detecting support for the write concern in the first place.
@@ -179,39 +176,6 @@ interface HasWriteConcern {
  * @param sources - sources where we can inherit default write concerns from
  * @param options - optional settings passed into a command for write concern overrides
  */
-export function applyWriteConcern<T extends HasWriteConcern>(
- target: T,
- sources: { db?: Db; collection?: Collection },
- options?: OperationOptions & WriteConcernOptions
-): T {
- options = options ?? {};
- const db = sources.db;
- const coll = sources.collection;
-
- if (options.session && options.session.inTransaction()) {
- // writeConcern is not allowed within a multi-statement transaction
- if (target.writeConcern) {
- delete target.writeConcern;
- }
-
- return target;
- }
-
- const writeConcern = WriteConcern.fromOptions(options);
- if (writeConcern) {
- return Object.assign(target, { writeConcern });
- }
-
- if (coll && coll.writeConcern) {
- return Object.assign(target, { writeConcern: Object.assign({}, coll.writeConcern) });
- }
-
- if (db && db.writeConcern) {
- return Object.assign(target, { writeConcern: Object.assign({}, db.writeConcern) });
- }
-
- return target;
-}
 
 /**
  * Checks if a given value is a Promise
@@ -483,40 +447,6 @@ export function eachAsync<T = Document>(
  }
 }
 
-/** @internal */
-export function eachAsyncSeries<T = any>(
- arr: T[],
- eachFn: (item: T, callback: (err?: AnyError) => void) => void,
- callback: Callback
-): void {
- arr = arr || [];
-
- let idx = 0;
- let awaiting = arr.length;
- if (awaiting === 0) {
- callback();
- return;
- }
-
- function eachCallback(err?: AnyError) {
- idx++;
- awaiting--;
- if (err) {
- callback(err);
- return;
- }
-
- if (idx === arr.length && awaiting <= 0) {
- callback();
- return;
- }
-
- eachFn(arr[idx], eachCallback);
- }
-
- eachFn(arr[idx], eachCallback);
-}
-
 /** @internal */
 export function arrayStrictEqual(arr: unknown[], arr2: unknown[]): boolean {
  if (!Array.isArray(arr) || !Array.isArray(arr2)) {