Do not pass writeOptions in database calls.

- Fix `findOneAndUpdate` options.

Author: dlongley

CHANGELOG.md

@@ -1,5 +1,11 @@
 # bedrock-tokenization ChangeLog
 
+## 22.1.2 - 2025-mm-dd
+
+### Fixed
+- Do not pass `writeOptions` in database calls.
+- Use proper `"returnDocument": "after"` option w/`findOneAndUpdate`.
+
 ## 22.1.1 - 2025-03-04
 
 ### Fixed

lib/batchVersions.js

@@ -236,7 +236,6 @@ export async function setOptions({options, explain = false} = {}) {
   };
   const query = {'batchVersionOptions.id': BATCH_OPTIONS_ID};
   const $set = {batchVersionOptions, 'meta.updated': now};
-  const upsertOptions = {...database.writeOptions, upsert: true};
 
   if(explain) {
     // 'find().limit(1)' is used here because 'updateOne()' doesn't return a
@@ -248,7 +247,7 @@ export async function setOptions({options, explain = false} = {}) {
   const result = await collection.updateOne(query, {
     $set,
     $setOnInsert: {'meta.created': now}
-  }, upsertOptions);
+  }, {upsert: true});
   if(result.modifiedCount > 0 || result.upsertedCount > 0) {
     // upserted or modified
     return true;

lib/documents.js

@@ -636,9 +636,8 @@ export async function _refresh({
   const result = await collection.findOneAndUpdate(
     query, update, {
       projection,
-      returnNewDocument: true,
-      promoteBuffers: true,
-      ...database.writeOptions
+      returnDocument: 'after',
+      promoteBuffers: true
     });
   // return whether update occurred and new record if it did
   return {updated: result.lastErrorObject.n !== 0, record: result.value};

lib/entities.js

@@ -463,7 +463,6 @@ export async function _upsert({
     $setOnInsert['entity.externalIdHash'] = externalIdHash;
   }
   const record = {entity, meta};
-  const upsertOptions = {...database.writeOptions, upsert: true};
 
   if(explain) {
     // 'find().limit(1)' is used here because 'updateOne()' doesn't return a
@@ -473,7 +472,7 @@ export async function _upsert({
   }
 
   // this upsert cannot trigger duplicate error; no try/catch needed
-  const result = await collection.updateOne(query, update, upsertOptions);
+  const result = await collection.updateOne(query, update, {upsert: true});
   if(result.upsertedCount > 0) {
     // return full record when upserted
     return {_id: result.upsertedId, ...record};