diff --git a/package-lock.json b/package-lock.json index a7d04fd0f..e04efa4c2 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "origintrail_node", - "version": "8.1.3+beta.2", + "version": "8.1.3+beta.4", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "origintrail_node", - "version": "8.1.3+beta.2", + "version": "8.1.3+beta.4", "license": "ISC", "dependencies": { "@comunica/query-sparql": "^2.4.3", diff --git a/package.json b/package.json index 9458964aa..ffa0e59e1 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "origintrail_node", - "version": "8.1.3+beta.2", + "version": "8.1.3+beta.4", "description": "OTNode V8", "main": "index.js", "type": "module", diff --git a/src/commands/paranet/paranet-sync-command.js b/src/commands/paranet/paranet-sync-command.js index 3164f968d..f2cf51c17 100644 --- a/src/commands/paranet/paranet-sync-command.js +++ b/src/commands/paranet/paranet-sync-command.js @@ -217,6 +217,8 @@ class ParanetSyncCommand extends Command { state: assertionId, hashFunctionId: CONTENT_ASSET_HASH_FUNCTION_ID, assertionId, + paranetId, + paranetUAL, }, transactional: false, }); @@ -234,6 +236,8 @@ class ParanetSyncCommand extends Command { state: assertionId, hashFunctionId: CONTENT_ASSET_HASH_FUNCTION_ID, assertionId, + paranetId, + paranetUAL, }, transactional: false, }); @@ -274,9 +278,8 @@ class ParanetSyncCommand extends Command { } const data = await this.operationIdService.getCachedOperationIdData(getOperationId); - this.logger.debug( - `Paranet sync: ${data.nquads.length} nquads found for asset with ual: ${ual}, state index: ${stateIndex}, assertionId: ${assertionId}`, + `Paranet sync: ${data.assertion.length} nquads found for asset with ual: ${ual}, state index: ${stateIndex}, assertionId: ${assertionId}`, ); let repository; @@ -293,7 +296,7 @@ class ParanetSyncCommand extends Command { await this.tripleStoreService.localStoreAsset( repository, assertionId, - data.nquads, + data.assertion, blockchain, contract, tokenId, @@ -301,11 +304,11 @@ class ParanetSyncCommand extends Command { LOCAL_INSERT_FOR_CURATED_PARANET_MAX_ATTEMPTS, LOCAL_INSERT_FOR_CURATED_PARANET_RETRY_DELAY, ); - if (paranetNodesAccessPolicy === 'CURATED' && data.privateNquads) { + if (paranetNodesAccessPolicy === 'CURATED' && data.privateAssertion) { await this.tripleStoreService.localStoreAsset( repository, data.syncedAssetRecord.privateAssertionId, - data.privateNquads, + data.privateAssertion, blockchain, contract, tokenId, diff --git a/src/constants/constants.js b/src/constants/constants.js index 2b0bfe769..00c643fe8 100644 --- a/src/constants/constants.js +++ b/src/constants/constants.js @@ -231,7 +231,7 @@ export const SIMPLE_ASSET_SYNC_PARAMETERS = { export const PARANET_SYNC_PARAMETERS = { GET_RESULT_POLLING_INTERVAL_MILLIS: 1 * 1000, - GET_RESULT_POLLING_MAX_ATTEMPTS: 30, + GET_RESULT_POLLING_MAX_ATTEMPTS: 300, }; export const COMMAND_TX_GAS_INCREASE_FACTORS = { diff --git a/src/service/get-service.js b/src/service/get-service.js index 4cf4ce52e..7114c91fb 100644 --- a/src/service/get-service.js +++ b/src/service/get-service.js @@ -76,7 +76,7 @@ class GetService extends OperationService { await this.markOperationAsCompleted( operationId, blockchain, - { assertion: responseData.nquads }, + { assertion: responseData.nquads, privateAssertion: responseData.privateNquads }, [...this.completedStatuses], ); this.logResponsesSummary(completedNumber, failedNumber);