Use internal write txn if available

kriszyp · Nov 9, 2021 · 1ee22b7 · 1ee22b7
1 parent cb65a96
commit 1ee22b7
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/index.js b/index.js
@@ -107,7 +107,6 @@ export function open(path, options) {
 				this.db = env.openDbi(Object.assign({
 					name: dbName,
 					create: true,
-					txn: env.writeTxn,
 				}, dbOptions));
 				this.db.name = dbName || null;
 			};

diff --git a/src/dbi.cpp b/src/dbi.cpp
@@ -100,11 +100,9 @@ NAN_METHOD(DbiWrap::ctor) {
         Local<Value> hasVersionsLocal = options->Get(Nan::GetCurrentContext(), Nan::New<String>("useVersions").ToLocalChecked()).ToLocalChecked();
         hasVersions = hasVersionsLocal->IsTrue();
 
-        auto txnObj = options->Get(Nan::GetCurrentContext(), Nan::New<String>("txn").ToLocalChecked()).ToLocalChecked();
-        if (!txnObj->IsNull() && !txnObj->IsUndefined() && txnObj->IsObject()) {
-            TxnWrap *tw = Nan::ObjectWrap::Unwrap<TxnWrap>(Local<Object>::Cast(txnObj));
+        if (ew->writeTxn) {
             needsTransaction = false;
-            txn = tw->txn;
+            txn = ew->writeTxn->txn;
         }
     }
     else {