more cleaning

Author: nbbeeken

src/operations/get_more.ts

@@ -26,7 +26,7 @@ export interface GetMoreOptions extends OperationOptions {
  * @internal
  */
 export interface GetMoreCommand {
-  getMore: Long | bigint;
+  getMore: Long;
   collection: string;
   batchSize?: number;
   maxTimeMS?: number;
@@ -36,15 +36,10 @@ export interface GetMoreCommand {
 
 /** @internal */
 export class GetMoreOperation extends AbstractOperation {
-  cursorId: Long | bigint;
+  cursorId: Long;
   override options: GetMoreOptions;
 
-  constructor(
-    ns: MongoDBNamespace,
-    cursorId: Long | bigint,
-    server: Server,
-    options: GetMoreOptions
-  ) {
+  constructor(ns: MongoDBNamespace, cursorId: Long, server: Server, options: GetMoreOptions) {
     super(options);
 
     this.options = options;
@@ -68,11 +63,7 @@ export class GetMoreOperation extends AbstractOperation {
       );
     }
 
-    if (
-      this.cursorId == null ||
-      this.cursorId === 0n ||
-      (typeof this.cursorId === 'object' && this.cursorId.isZero())
-    ) {
+    if (this.cursorId == null || this.cursorId.isZero()) {
       return callback(new MongoRuntimeError('Unable to iterate cursor with no id'));
     }
 

src/operations/kill_cursors.ts

@@ -11,19 +11,14 @@ import { AbstractOperation, Aspect, defineAspects, OperationOptions } from './op
  */
 interface KillCursorsCommand {
   killCursors: string;
-  cursors: (Long | bigint)[];
+  cursors: Long[];
   comment?: unknown;
 }
 
 export class KillCursorsOperation extends AbstractOperation {
-  cursorId: Long | bigint;
-
-  constructor(
-    cursorId: Long | bigint,
-    ns: MongoDBNamespace,
-    server: Server,
-    options: OperationOptions
-  ) {
+  cursorId: Long;
+
+  constructor(cursorId: Long, ns: MongoDBNamespace, server: Server, options: OperationOptions) {
     super(options);
     this.ns = ns;
     this.cursorId = cursorId;

src/sessions.ts

@@ -6,7 +6,6 @@ import { ConnectionPoolMetrics } from './cmap/metrics';
 import { isSharded } from './cmap/wire_protocol/shared';
 import { PINNED, UNPINNED } from './constants';
 import type { AbstractCursor } from './cursor/abstract_cursor';
-import type { RunCommandCursor } from './cursor/run_command_cursor';
 import {
   AnyError,
   MongoAPIError,
@@ -54,7 +53,7 @@ export interface ClientSessionOptions {
   defaultTransactionOptions?: TransactionOptions;
 
   /** @internal */
-  owner?: symbol | AbstractCursor | RunCommandCursor;
+  owner?: symbol | AbstractCursor;
   /** @internal */
   explicit?: boolean;
   /** @internal */
@@ -109,7 +108,7 @@ export class ClientSession extends TypedEventEmitter<ClientSessionEvents> {
   operationTime?: Timestamp;
   explicit: boolean;
   /** @internal */
-  owner?: symbol | AbstractCursor | RunCommandCursor;
+  owner?: symbol | AbstractCursor;
   defaultTransactionOptions: TransactionOptions;
   transaction: Transaction;
   /** @internal */

test/integration/node-specific/examples/run_command.test.js

@@ -24,15 +24,21 @@ describe('examples.runCommand:', function () {
     db = undefined;
   });
 
-  it('supports runCommand 1', async function () {
-    // Start runCommand example 1
-    await db.command({ buildInfo: 1 });
-    // End runCommand example 1
+  it('supports runCommand 1', {
+    metadata: { requires: { topology: ['single'] } },
+    test: async function () {
+      // Start runCommand example 1
+      await db.command({ buildInfo: 1 });
+      // End runCommand example 1
+    }
   });
 
-  it('supports runCommand 2', async function () {
-    // Start runCommand example 2
-    await db.command({ collStats: 'restaurants' });
-    // End runCommand example 2
+  it('supports runCommand 2', {
+    metadata: { requires: { topology: ['single'] } },
+    test: async function () {
+      // Start runCommand example 2
+      await db.command({ collStats: 'restaurants' });
+      // End runCommand example 2
+    }
   });
 });

test/tools/unified-spec-runner/entities.ts

@@ -30,7 +30,6 @@ import {
   MongoCredentials,
   ReadConcern,
   ReadPreference,
-  RunCommandCursor,
   SENSITIVE_COMMANDS,
   ServerDescriptionChangedEvent,
   TopologyDescription,
@@ -442,9 +441,6 @@ export class EntitiesMap<E = Entity> extends Map<string, E> {
       throw new Error(`Unknown type ${type}`);
     }
     if (!(entity instanceof ctor)) {
-      if (type === 'cursor' && entity instanceof RunCommandCursor) {
-        return entity;
-      }
       throw new Error(`${key} is not an instance of ${type}`);
     }
     return entity;