chore: debug retryability

Author: durran

src/collection.ts

@@ -551,18 +551,26 @@ export class Collection<TSchema extends Document = Document> {
     filter: Filter<TSchema> = {},
     options: Omit<FindOneOptions, ''> & Abortable = {}
   ): Promise<WithId<TSchema> | null> {
-    //const cursor = this.find(filter, options).limit(-1).batchSize(1);
-    //const res = await cursor.next();
+    const opts = { ...options };
+    opts.singleBatch = true;
+    if (opts.noCursorTimeout != null) {
+      delete opts.noCursorTimeout;
+    }
+    if (opts.batchSize != null) {
+      delete opts.batchSize;
+    }
+    const cursor = this.find(filter, opts).limit(1);
+    return await cursor.next();
     //await cursor.close();
-    return await executeOperation(
-      this.client,
-      new FindOneOperation(
-        this.s.db,
-        this.collectionName,
-        filter,
-        resolveOptions(this as TODO_NODE_3286, options)
-      )
-    );
+    //return await executeOperation(
+    //  this.client,
+    //  new FindOneOperation(
+    //    this.s.db,
+    //    this.collectionName,
+    //    filter,
+    //    resolveOptions(this as TODO_NODE_3286, options)
+    //  )
+    //);
   }
 
   /**

src/operations/execute_operation.ts

@@ -232,6 +232,7 @@ async function tryOperation<
   let previousServer: ServerDescription | undefined;
 
   for (let tries = 0; tries < maxTries; tries++) {
+    console.log('trying', tries, maxTries, willRetry, operation.commandName);
     if (previousOperationError) {
       if (hasWriteAspect && previousOperationError.code === MMAPv1_RETRY_WRITES_ERROR_CODE) {
         throw new MongoServerError({
@@ -248,8 +249,10 @@ async function tryOperation<
       if (hasWriteAspect && !isRetryableWriteError(previousOperationError))
         throw previousOperationError;
 
-      if (hasReadAspect && !isRetryableReadError(previousOperationError))
+      if (hasReadAspect && !isRetryableReadError(previousOperationError)) {
+        console.log(previousOperationError, isRetryableReadError(previousOperationError));
         throw previousOperationError;
+      }
 
       if (
         previousOperationError instanceof MongoNetworkError &&
@@ -280,8 +283,10 @@ async function tryOperation<
       if (tries > 0 && operation.hasAspect(Aspect.COMMAND_BATCHING)) {
         operation.resetBatch();
       }
+      console.log('executing', operation.commandName);
       return await operation.execute(server, session, timeoutContext);
     } catch (operationError) {
+      console.log('operationError', operationError);
       if (!(operationError instanceof MongoError)) throw operationError;
       if (
         previousOperationError != null &&

test/integration/retryable-reads/retryable_reads.spec.test.ts

@@ -14,7 +14,7 @@ const UNIMPLEMENTED_APIS = [
 
 const skippedTests = ['collection.listIndexes succeeds after retryable handshake network error'];
 
-describe('Retryable Reads (unified)', function () {
+describe.only('Retryable Reads (unified)', function () {
   runUnifiedSuite(loadSpecTests(path.join('retryable-reads', 'unified')), ({ description }) => {
     for (const apiName of UNIMPLEMENTED_APIS) {
       if (description.toLowerCase().includes(apiName.toLowerCase())) {