Prevent block info spam on errors

Author: felixbrucker

lib/services/round-populator.js

@@ -1,14 +1,31 @@
+const moment = require('moment');
+
 const cache = require('./cache');
 const database = require('../../models');
 const eventBus = require('./event-bus');
 
 class RoundPopulator {
+    constructor() {
+        this.blockInfoUnavailable = new Map();
+    }
+
     async populateRound(upstream, height) {
+        const lastUnavailable = this.blockInfoUnavailable.get(upstream.fullUpstreamName);
+        if (lastUnavailable && moment().diff(lastUnavailable, 'minutes') < 5) {
+            return;
+        }
+
         eventBus.publish('log/debug', `Round-Populator | ${upstream.fullUpstreamNameLogs} | Populating round ${height}`);
         const blockInfo = await upstream.getBlockInfo(height);
+        if (!blockInfo) {
+            this.blockInfoUnavailable.set(upstream.fullUpstreamName, new Date());
+        }
         if (!blockInfo || !blockInfo.hash || !blockInfo.plotterId) {
             return;
         }
+        if (this.blockInfoUnavailable.has(upstream.fullUpstreamName)) {
+            this.blockInfoUnavailable.delete(upstream.fullUpstreamName);
+        }
         const round = await cache.ensureRoundIsCached(upstream, height);
         round.blockHash = blockInfo.hash;
         const activePlotter = await upstream.getActivePlotter(round.blockHeight);
@@ -18,6 +35,11 @@ class RoundPopulator {
     }
 
     async populateUnpopulatedRounds(upstream, maxHeight) {
+        const lastUnavailable = this.blockInfoUnavailable.get(upstream.fullUpstreamName);
+        if (lastUnavailable && moment().diff(lastUnavailable, 'minutes') < 5) {
+            return;
+        }
+
         const unpopulatedRounds = await database().round.findAll({
             where: {
                 upstream: upstream.fullUpstreamName,