Add mising await

OriginTrail · Dec 11, 2024 · e431c10 · e431c10
1 parent a103f3b
commit e431c10
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 13 deletions.
diff --git a/src/commands/local-store/local-store-command.js b/src/commands/local-store/local-store-command.js
@@ -55,7 +55,7 @@ class LocalStoreCommand extends Command {
             );
 
             if (storeType === LOCAL_STORE_TYPES.TRIPLE) {
-                const storePromises = [];
+                // const storePromises = [];
 
                 // if (cachedData.dataset && cachedData.datasetRoot) {
                 //     storePromises.push(
@@ -71,7 +71,7 @@ class LocalStoreCommand extends Command {
                 //         this.pendingStorageService.cacheDataset(operationId, datasetRoot, dataset),
                 //     );
                 // }
-                await Promise.all(storePromises);
+                // await Promise.all(storePromises);
 
                 const identityId = await this.blockchainModuleManager.getIdentityId(blockchain);
                 const signature = await this.blsService.sign(datasetRoot);
@@ -81,6 +81,7 @@ class LocalStoreCommand extends Command {
                     operationId,
                     blockchain,
                 );
+
                 await this.operationService.processResponse(
                     command,
                     OPERATION_REQUEST_STATUS.COMPLETED,

diff --git a/src/commands/protocols/common/protocol-request-command.js b/src/commands/protocols/common/protocol-request-command.js
@@ -15,20 +15,12 @@ class ProtocolRequestCommand extends ProtocolMessageCommand {
 
     async execute(command) {
         const { operationId, blockchain } = command.data;
-        await this.operationIdService.emitChangeEvent(
-            this.operationStartEvent,
-            operationId,
-            blockchain,
-        );
-        const result = this.executeProtocolMessageCommand(
+        this.operationIdService.emitChangeEvent(this.operationStartEvent, operationId, blockchain);
+        const result = await this.executeProtocolMessageCommand(
             command,
             NETWORK_MESSAGE_TYPES.REQUESTS.PROTOCOL_REQUEST,
         );
-        await this.operationIdService.emitChangeEvent(
-            this.operationEndEvent,
-            operationId,
-            blockchain,
-        );
+        this.operationIdService.emitChangeEvent(this.operationEndEvent, operationId, blockchain);
 
         return result;
     }