Feature/remove get init

src/commands/local-store/local-store-command.js

@@ -1,4 +1,10 @@
-import { OPERATION_ID_STATUS, ERROR_TYPE, LOCAL_STORE_TYPES } from '../../constants/constants.js';
+import {
+    OPERATION_ID_STATUS,
+    ERROR_TYPE,
+    LOCAL_STORE_TYPES,
+    OPERATION_REQUEST_STATUS,
+    NETWORK_MESSAGE_TYPES,
+} from '../../constants/constants.js';
 import Command from '../command.js';
 
 class LocalStoreCommand extends Command {
@@ -8,6 +14,7 @@
         this.paranetService = ctx.paranetService;
         this.pendingStorageService = ctx.pendingStorageService;
         this.operationIdService = ctx.operationIdService;
+        this.operationService = ctx.publishService;
         this.dataService = ctx.dataService;
         this.ualService = ctx.ualService;
         this.serviceAgreementService = ctx.serviceAgreementService;
@@ -24,6 +31,7 @@
             blockchain,
             storeType = LOCAL_STORE_TYPES.TRIPLE,
             paranetId,
+            datasetRoot,
         } = command.data;
 
         try {
@@ -32,17 +40,16 @@
                 blockchain,
                 OPERATION_ID_STATUS.LOCAL_STORE.LOCAL_STORE_START,
             );
-
-            const cachedData = await this.operationIdService.getCachedOperationIdData(operationId);
+            const dataset = await this.operationIdService.getCachedOperationIdData(operationId);
 
             if (storeType === LOCAL_STORE_TYPES.TRIPLE) {
                 const storePromises = [];
                 if (cachedData.public.dataset && cachedData.public.datasetRoot) {
                     storePromises.push(
                         this.pendingStorageService.cacheDataset(
                             operationId,
                             cachedData.public.datasetRoot,
                             cachedData.public.dataset,
                         ),
                     );
                 }
@@ -71,33 +78,6 @@
                 await this.tripleStoreModuleManager.initializeParanetRepository(paranetRepository);
                 await this.paranetService.initializeParanetRecord(blockchain, paranetId);
 
-                if (cachedData.public.dataset && cachedData.public.datasetRoot) {
-                    // await this.tripleStoreService.localStoreAsset(
-                    //     paranetRepository,
-                    //     cachedData.public.assertionId,
-                    //     cachedData.public.assertion,
-                    //     blockchain,
-                    //     contract,
-                    //     tokenId,
-                    //     keyword,
-                    //     LOCAL_INSERT_FOR_CURATED_PARANET_MAX_ATTEMPTS,
-                    //     LOCAL_INSERT_FOR_CURATED_PARANET_RETRY_DELAY,
-                    // );
-                }
-                if (cachedData.private?.assertion && cachedData.private?.assertionId) {
-                    // await this.tripleStoreService.localStoreAsset(
-                    //     paranetRepository,
-                    //     cachedData.private.assertionId,
-                    //     cachedData.private.assertion,
-                    //     blockchain,
-                    //     contract,
-                    //     tokenId,
-                    //     keyword,
-                    //     LOCAL_INSERT_FOR_CURATED_PARANET_MAX_ATTEMPTS,
-                    //     LOCAL_INSERT_FOR_CURATED_PARANET_RETRY_DELAY,
-                    // );
-                }
-
                 await this.repositoryModuleManager.incrementParanetKaCount(paranetId, blockchain);
                 // await this.repositoryModuleManager.createParanetSyncedAssetRecord(
                 //     blockchain,

src/commands/protocols/common/find-shard-command.js

@@ -1,5 +1,5 @@
 import Command from '../../command.js';
-import { OPERATION_ID_STATUS } from '../../../constants/constants.js';
+import { OPERATION_ID_STATUS, ERROR_TYPE } from '../../../constants/constants.js';
 
 class FindShardCommand extends Command {
     constructor(ctx) {
@@ -14,28 +14,44 @@ class FindShardCommand extends Command {
      * @param command
      */
     async execute(command) {
-        const { operationId, blockchain, errorType, networkProtocols, minAckResponses } =
-            command.data;
-
-        this.errorType = errorType;
-        this.logger.debug(`Searching for shard for operationId: ${operationId}`);
-
+        const { operationId, blockchain, datasetRoot } = command.data;
+        this.errorType = ERROR_TYPE.FIND_SHARD.FIND_SHARD_ERROR;
+        this.logger.debug(
+            `Searching for shard for operationId: ${operationId}, dataset root: ${datasetRoot}`,
+        );
         await this.operationIdService.updateOperationIdStatus(
             operationId,
             blockchain,
             OPERATION_ID_STATUS.FIND_NODES_START,
         );
 
-        // TODO: protocol selection
+        this.minAckResponses = await this.operationService.getMinAckResponses(blockchain);
+
+        const networkProtocols = this.operationService.getNetworkProtocols();
+
         const shardNodes = [];
+        let nodePartOfShard = false;
+        const currentPeerId = this.networkModuleManager.getPeerId().toB58String();
+
         const foundNodes = await this.findShardNodes(blockchain);
         for (const node of foundNodes) {
-            if (node.id !== this.networkModuleManager.getPeerId().toB58String()) {
+            if (node.id === currentPeerId) {
+                nodePartOfShard = true;
+            } else {
                 shardNodes.push({ id: node.id, protocol: networkProtocols[0] });
             }
         }
 
-        this.logger.debug(`Found ${shardNodes.length} node(s) for operationId: ${operationId}`);
+        const commandSequence = this.getOperationCommandSequence(nodePartOfShard);
+
+        command.sequence.push(...commandSequence);
+
+        this.logger.debug(
+            `Found ${
+                shardNodes.length + nodePartOfShard ? 1 : 0
+            } node(s) for operationId: ${operationId}`,
+        );
+        // TODO: Log local node
         this.logger.trace(
             `Found shard: ${JSON.stringify(
                 shardNodes.map((node) => node.id),
@@ -44,11 +60,11 @@ class FindShardCommand extends Command {
             )}`,
         );
 
-        if (shardNodes.length < minAckResponses) {
+        if (shardNodes.length + (nodePartOfShard ? 1 : 0) < this.minAckResponses) {
             await this.handleError(
                 operationId,
                 blockchain,
-                `Unable to find enough nodes for operationId: ${operationId}. Minimum number of nodes required: ${minAckResponses}`,
+                `Unable to find enough nodes for operationId: ${operationId}. Minimum number of nodes required: ${this.minAckResponses}`,
                 this.errorType,
                 true,
             );
@@ -65,7 +81,7 @@ class FindShardCommand extends Command {
             {
                 ...command.data,
                 leftoverNodes: shardNodes,
-                numberOfShardNodes: shardNodes.length,
+                numberOfShardNodes: shardNodes.length + nodePartOfShard ? 1 : 0,
             },
             command.sequence,
         );
@@ -87,6 +103,10 @@ class FindShardCommand extends Command {
         return nodesFound;
     }
 
+    getOperationCommandSequence() {
+        throw Error('getOperationCommandSequence() is not defined');
+    }
+
     /**
      * Builds default findShardCommand
      * @param map