Add mock fetchTokenIdsForParanet() and iterate over the tokens

OriginTrail · Apr 24, 2024 · 9004f0c · 9004f0c
1 parent c7971f1
commit 9004f0c
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 14 deletions.
diff --git a/src/commands/paranet/start-paranet-sync-commands.js b/src/commands/paranet/start-paranet-sync-commands.js
@@ -19,29 +19,31 @@ class StartParanetSyncCommands extends Command {
         );
 
         await this.commandExecutor.delete('paranetSyncCommand');
+
+        const promises = [];
+        this.config.assetSync?.syncParanets.forEach(async (paranetId) => {
+            if (!this.ualService.isUal(paranetId)) {
+                this.logger.info(`Paranet sync: paranetId ${paranetId} is not a valid UAL!`);
+                return Command.empty();
+            }
 
-        await Promise.all(
-            this.config.assetSync?.syncParanets.map(async (paranetId) => {
-                if (!this.ualService.isUal(paranetId)) {
-                    this.logger.info(
-                        `Paranet sync: paranetId ${paranetId} is not a valid UAL!`,
-                    );
-                    return Command.empty();
-                }
-
+            const tokenIds = this.blockchainModuleManager.fetchTokenIdsForParanet(paranetId);
+            tokenIds.forEach((tokenId) => {
                 const commandData = {
                     paranetId,
                     operationId,
-                    // TODO: Pass in token ID (for now, just a mock)
+                    tokenId,
                 };
 
-                return this.commandExecutor.add({
+                promises.append(this.commandExecutor.add({
                     name: 'paranetSyncCommand',
                     data: commandData,
                     period: PARANET_SYNC_FREQUENCY_MILLS,
-                });
-            }),
-        );
+                }));
+            });
+        });
+
+        await Promise.all(promises);
 
         return Command.empty();
     }

diff --git a/src/service/blockchain-event-listener-service.js b/src/service/blockchain-event-listener-service.js
@@ -140,6 +140,10 @@ class BlockchainEventListenerService {
         );
     }
 
+    fetchTokenIdsForParanet(paranetId) {
+        return ["test1", "test2"];
+    }
+
     listenOnBlockchainEvents(blockchainId) {
         const devEnvironment =
             process.env.NODE_ENV === NODE_ENVIRONMENTS.DEVELOPMENT ||