restart balances url

p2p-org · Dec 4, 2023 · 4ac9f3c · 4ac9f3c
1 parent 737fa42
commit 4ac9f3c
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 9 deletions.
diff --git a/.helm/templates/streamer.deploy.yaml b/.helm/templates/streamer.deploy.yaml
@@ -64,9 +64,10 @@ spec:
         {{- with .Values.env }}
         env:
 
-        - { name: RESTART_BLOCKS_URI, value: {{ quote .restart_blocks_uri }} }
-        - { name: RESTART_ERAS_URI,   value: {{ quote .restart_eras_uri }} }
-        - { name: RESTART_ROUNDS_URI, value: {{ quote .restart_rounds_uri }} }
+        - { name: RESTART_BLOCKS_URI,   value: {{ quote .restart_blocks_uri }} }
+        - { name: RESTART_ERAS_URI,     value: {{ quote .restart_eras_uri }} }
+        - { name: RESTART_ROUNDS_URI,   value: {{ quote .restart_rounds_uri }} }
+        - { name: RESTART_BALANCES_URI, value: {{ quote .restart_balances_uri }} }
         - { name: SUBSTRATE_URI, value: {{ quote .substrate_uri }} }
         - { name: LOG_LEVEL,     value: {{ quote .log_level }} }
         - { name: NETWORK_ID,    value: {{ quote .network_id }} }

diff --git a/main/src/modules/MoonbeamStakingProcessor/service.ts b/main/src/modules/MoonbeamStakingProcessor/service.ts
@@ -13,6 +13,13 @@ import { SliMetrics } from '@/loaders/sli_metrics'
 import { Init } from '@polkadot/api/base/Init'
 import { ENTITY, ProcessingTaskModel, PROCESSING_STATUS } from '@/models/processing_task.model'
 
+/**
+ * Please check this repo
+ * https://github.com/PureStake/moonbeam.git
+ * 
+ * and test scripts like:
+ * test/suites/smoke/test-staking-round-cleanup.ts
+ */
 @Service()
 export class MoonbeamStakingProcessorService {
   constructor(
@@ -125,9 +132,8 @@ export class MoonbeamStakingProcessorService {
       }
 
       logger.info({
-        event: `Round ${round.id.toString(10)} staking processing finished in ${
-          (Date.now() - startProcessingTime) / 1000
-        } seconds.`,
+        event: `Round ${round.id.toString(10)} staking processing finished in ${(Date.now() - startProcessingTime) / 1000
+          } seconds.`,
       })
 
       await this.sliMetrics.add({
@@ -273,9 +279,8 @@ export class MoonbeamStakingProcessorService {
       }
 
       logger.info({
-        event: `Round ${round.id.toString(10)} staking processing finished in ${
-          (Date.now() - startProcessingTime) / 1000
-        } seconds.`,
+        event: `Round ${round.id.toString(10)} staking processing finished in ${(Date.now() - startProcessingTime) / 1000
+          } seconds.`,
       })
 
       await this.sliMetrics.add({