v8.1.1-rc.12 Testnet Prerelease

ot-node.js

@@ -74,7 +74,6 @@ class OTNode {
         await this.initializeProofing();
         await this.initializeClaimRewards();
         await this.initializeSyncService();
-        await this.initializeBlazegraphHealthService();
 
         this.logger.info('Node is up and running!');
     }
@@ -429,12 +428,6 @@ class OTNode {
         await syncService.initialize();
     }
 
-    async initializeBlazegraphHealthService() {
-        const blazegraphHealthService = this.container.resolve('blazegraphHealthService');
-        await blazegraphHealthService.initialize();
-        this.logger.info('Blazegraph Health Service initialized successfully');
-    }
-
     stop(code = 0) {
         this.logger.info('Stopping node...');
         process.exit(code);

package.json

@@ -1,6 +1,6 @@
 {
     "name": "origintrail_node",
-    "version": "8.1.1-rc.11",
+    "version": "8.1.1-rc.12",
     "description": "OTNode V8",
     "main": "index.js",
     "type": "module",

src/commands/protocols/get/receiver/v1.0.0/v1-0-0-handle-get-request-command.js

@@ -118,7 +118,6 @@ class HandleGetRequestCommand extends HandleProtocolMessageCommand {
                         blockchain,
                         contract,
                         knowledgeCollectionId,
-                        knowledgeAssetId,
                     );
                     promises.push(metadataPromise);
                 }
@@ -161,7 +160,6 @@ class HandleGetRequestCommand extends HandleProtocolMessageCommand {
                 blockchain,
                 contract,
                 knowledgeCollectionId,
-                knowledgeAssetId,
             );
             promises.push(metadataPromise);
         }

src/constants/constants.js

@@ -326,8 +326,8 @@ export const MIGRATION_FLAG_PATH = '.enrichment_migration_done_dkg';
 export const CONTRACT_FUNCTION_GAS_LIMIT_INCREASE_FACTORS = {};
 
 export const GNOSIS_DEFAULT_GAS_PRICE = {
-    TESTNET: 25,
-    MAINNET: 5,
+    TESTNET: 1,
+    MAINNET: 1,
 };
 
 export const NEURO_DEFAULT_GAS_PRICE = {
@@ -1096,7 +1096,7 @@ export const CHUNK_SIZE = 32;
 export const CLAIM_REWARDS_INTERVAL = 60 * 60 * 1000;
 export const CLAIM_REWARDS_BATCH_SIZE = 10;
 
-export const BATCH_GET_BATCH_SIZE = 5;
+export const BATCH_GET_BATCH_SIZE = 2;
 export const BATCH_GET_UAL_MAX_LIMIT = 1000;
 
 export const SYNC_INTERVAL = 12 * 1000;

src/modules/blockchain/implementation/gnosis/gnosis-service.js

@@ -36,15 +36,21 @@ class GnosisService extends Web3Service {
                 this.logger.warn(
                     `Gas price oracle: ${this.config.gasPriceOracleLink} returns gas price in unsupported format. Using default value: ${this.defaultGasPrice} Gwei.`,
                 );
+                return this.defaultGasPrice;
             }
         } catch (error) {
             this.logger.warn(
                 `Failed to fetch the gas price from the Gnosis: ${error}. Using default value: ${this.defaultGasPrice} Gwei.`,
             );
+            return this.defaultGasPrice;
         }
-        if (gasPrice) {
+        if (
+            gasPrice &&
+            ethers.utils.parseUnits(gasPrice.toString(), 'gwei').gt(this.defaultGasPrice)
+        ) {
             return gasPrice;
         }
+
         return this.defaultGasPrice;
     }
 

src/service/triple-store-service.js

@@ -653,29 +653,18 @@ class TripleStoreService {
         blockchain,
         contract,
         knowledgeCollectionId,
-        knowledgeAssetId,
         repository = TRIPLE_STORE_REPOSITORY.DKG,
     ) {
-        const ual = `did:dkg:${blockchain}/${contract}/${knowledgeCollectionId}${
-            Number.isInteger(knowledgeAssetId) ? `/${knowledgeAssetId}` : ''
-        }`;
+        const ual = `did:dkg:${blockchain}/${contract}/${knowledgeCollectionId}`;
         this.logger.debug(`Getting Assertion Metadata with the UAL: ${ual}.`);
-        let nquads;
-        if (Number.isInteger(knowledgeAssetId)) {
-            nquads = await this.tripleStoreModuleManager.getKnowledgeAssetMetadata(
-                this.repositoryImplementations[repository],
-                repository,
-                ual,
-                this.config.modules.tripleStore.timeout.get,
-            );
-        } else {
-            nquads = await this.tripleStoreModuleManager.getKnowledgeCollectionMetadata(
-                this.repositoryImplementations[repository],
-                repository,
-                ual,
-                this.config.modules.tripleStore.timeout.get,
-            );
-        }
+
+        let nquads = await this.tripleStoreModuleManager.getKnowledgeCollectionMetadata(
+            this.repositoryImplementations[repository],
+            repository,
+            ual,
+            this.config.modules.tripleStore.timeout.get,
+        );
+
         nquads = nquads.split('\n').filter((line) => line !== '');
 
         this.logger.debug(