From 3737af3a7db66e26dfefc39ac7d96cb04031336e Mon Sep 17 00:00:00 2001
From: boufni95 <boufni95@gmail.com>
Date: Mon, 10 Mar 2025 19:13:25 +0000
Subject: [PATCH] fix tx start

---
 src/services/storage/storageProcessor.ts | 30 +++++++++++++-----------
 1 file changed, 16 insertions(+), 14 deletions(-)

diff --git a/src/services/storage/storageProcessor.ts b/src/services/storage/storageProcessor.ts
index 6ac844c7..d6e53dc8 100644
--- a/src/services/storage/storageProcessor.ts
+++ b/src/services/storage/storageProcessor.ts
@@ -217,21 +217,23 @@ class StorageProcessor {
         const res = await this.txQueue.PushToQueue({
             dbTx: false,
             description: operation.description || "startTx",
-            exec: tx => new Promise((resolve, reject) => {
-                this.activeTransaction = {
-                    txId: operation.opId,
-                    manager: tx,
-                    resolve,
-                    reject
-                }
-            })
+            exec: tx => {
+                this.sendResponse({
+                    success: true,
+                    type: 'startTx',
+                    data: operation.opId,
+                    opId: operation.opId
+                });
+                return new Promise((resolve, reject) => {
+                    this.activeTransaction = {
+                        txId: operation.opId,
+                        manager: tx,
+                        resolve,
+                        reject
+                    }
+                })
+            }
         })
-        this.sendResponse({
-            success: true,
-            type: 'startTx',
-            data: res,
-            opId: operation.opId
-        });
     }
 
     private async handleEndTx(operation: EndTxOperation<any>) {