Execute first replication and after store locally (#127)

* Change order: first replicate if it succeeds, store locally * Bump version to 6.1.2
OriginTrail · Jan 12, 2024 · a9d150b · a9d150b
1 parent 5762027
commit a9d150b
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 19 deletions.
diff --git a/dist/dkg.min.js b/dist/dkg.min.js
diff --git a/managers/asset-operations-manager.js b/managers/asset-operations-manager.js
@@ -366,24 +366,31 @@ class AssetOperationsManager {
                 storeType: STORE_TYPES.TRIPLE,
             });
         }
-        let operationId = await this.nodeApiService.localStore(
+
+        const UAL = deriveUAL(blockchain.name, contentAssetStorageAddress, tokenId);
+
+        let operationId = await this.nodeApiService.publish(
             endpoint,
             port,
             authToken,
-            assertions,
+            publicAssertionId,
+            publicAssertion,
+            blockchain.name,
+            contentAssetStorageAddress,
+            tokenId,
+            hashFunctionId,
         );
+
         let operationResult = await this.nodeApiService.getOperationResult(
             endpoint,
             port,
             authToken,
-            OPERATIONS.LOCAL_STORE,
+            OPERATIONS.PUBLISH,
             maxNumberOfRetries,
-            DEFAULT_GET_LOCAL_STORE_RESULT_FREQUENCY,
+            frequency,
             operationId,
         );
 
-        const UAL = deriveUAL(blockchain.name, contentAssetStorageAddress, tokenId);
-
         if (operationResult.status === OPERATION_STATUSES.FAILED) {
             return {
                 UAL,
@@ -392,25 +399,20 @@ class AssetOperationsManager {
             };
         }
 
-        operationId = await this.nodeApiService.publish(
+        operationId = await this.nodeApiService.localStore(
             endpoint,
             port,
             authToken,
-            publicAssertionId,
-            publicAssertion,
-            blockchain.name,
-            contentAssetStorageAddress,
-            tokenId,
-            hashFunctionId,
+            assertions,
         );
 
         operationResult = await this.nodeApiService.getOperationResult(
             endpoint,
             port,
             authToken,
-            OPERATIONS.PUBLISH,
+            OPERATIONS.LOCAL_STORE,
             maxNumberOfRetries,
-            frequency,
+            DEFAULT_GET_LOCAL_STORE_RESULT_FREQUENCY,
             operationId,
         );
 

diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "dkg.js",
-    "version": "6.1.1",
+    "version": "6.1.2",
     "description": "Javascript library for interaction with the OriginTrail Decentralized Knowledge Graph",
     "main": "index.js",
     "scripts": {