allow rescan multiple blocks in single notification

apps/crawler/src/subscribers/subscribers.service.ts

@@ -39,10 +39,22 @@ export class SubscribersService {
       this.logger.log(`Received notification on channel ${channel}`);
 
       if (channel === FORCE_RESCAN_BLOCK && payload) {
-        const blockNumber = parseInt(payload, 10);
+        const blockNumbers = payload
+          .split(',')
+          .map((n) => parseInt(n.trim(), 10))
+          .filter((n) => !isNaN(n));
 
-        this.logger.log(`Force rescan called for block ${blockNumber} started`);
-        await this.blocksSubscriberService.processBlockByNumber(blockNumber);
+        this.logger.log(
+          `Going to force rescan blocks: ${blockNumbers.join(', ')}`,
+        );
+
+        for (const blockNumber of blockNumbers) {
+          this.logger.log(`Rescan for block ${blockNumber}`);
+
+          await this.blocksSubscriberService.processBlockByNumber(blockNumber);
+
+          this.logger.log(`Rescan for block ${blockNumber} finished`);
+        }
       }
     });
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "polkastats-backend-uniquenetwork",
-  "version": "2.0.55",
+  "version": "2.0.56",
   "description": "",
   "author": "Unique Network Team",
   "private": true,