Merge pull request #122 from Cerebellum-Network/release/0.25.0

Release v0.25.0
Cerebellum-Network · Jan 25, 2023 · e03c7b5 · e03c7b5
2 parents 86f7ed6 + 7903e91
commit e03c7b5
Show file tree

Hide file tree

Showing 8 changed files with 18 additions and 6 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -3,6 +3,9 @@
 ## vNext
 - ...
 
+## v0.25.0
+- [BE] Fix crawlers status restore after fail
+
 ## v0.24.3
 - [BE] Add missing `next` functions to prevent Stats API crash
 

diff --git a/api/package.json b/api/package.json
@@ -1,6 +1,6 @@
 {
   "name": "api",
-  "version": "0.24.3",
+  "version": "0.25.0",
   "description": "PolkaStats API",
   "author": "Mario Pino Uceda",
   "license": "Apache-2.0",

diff --git a/backend/backend.config.js b/backend/backend.config.js
@@ -13,6 +13,7 @@ module.exports = {
     port: parseInt(process.env.POSTGRES_PORT, 10) || 5432,
   },
   logLevel: process.env.LOG_LEVEL || 'info', // Use 'debug' to see DEBUG level messages
+  spawnTimeoutMs: parseInt(process.env.SPAWN_TIMEOUT_MS, 10) || 5000,
   crawlers: [
     {
       name: 'blockListener',

diff --git a/backend/index.js b/backend/index.js
@@ -6,7 +6,7 @@ const { spawn } = require('child_process');
 const { StatusCodes } = require('http-status-codes');
 const { wait, getEnabledCrawlerNames, getEnabledCrawlers } = require('./lib/utils');
 const config = require('./backend.config');
-const Status = require('./lib/status');
+const { Status, statuses: appStatuses } = require('./lib/status');
 
 const app = express();
 const logger = pino();
@@ -27,6 +27,7 @@ const runCrawler = async ({ crawler, name }) => {
   child.on('exit', (exitCode, signal) => {
     logger.warn(`Crawler ${crawler} exit with code: ${exitCode} and signal: ${signal}`);
     status.set(name, `exit code ${exitCode}, signal ${signal}`);
+    setTimeout(() => runCrawler({ crawler, name }), config.spawnTimeoutMs);
   });
   child.on('uncaughtException', (error) => {
     logger.warn(`Crawler ${crawler} exit with uncaughtException: ${error}`);
@@ -40,6 +41,10 @@ const runCrawler = async ({ crawler, name }) => {
     logger.warn(`Crawler ${crawler} exit SIGUSR2`);
     status.set(name, 'exit SIGUSR2');
   });
+  child.on('spawn', () => {
+    logger.info('Process spawned');
+    status.set(name, appStatuses.HEALTHY);
+  });
 };
 
 const runCrawlers = async () => {

diff --git a/backend/lib/status.js b/backend/lib/status.js
@@ -26,4 +26,7 @@ class Status {
   }
 }
 
-module.exports = Status;
+module.exports = {
+  statuses,
+  Status,
+};
diff --git a/backend/package.json b/backend/package.json
@@ -1,6 +1,6 @@
 {
   "name": "backend",
-  "version": "0.24.3",
+  "version": "0.25.0",
   "description": "PolkaStats NG Backend",
   "author": "Mario Pino Uceda",
   "license": "Apache-2.0",

diff --git a/frontend/package.json b/frontend/package.json
@@ -1,6 +1,6 @@
 {
   "name": "frontend",
-  "version": "0.24.3",
+  "version": "0.25.0",
   "description": "PolkaStats NG frontend",
   "author": "Mario Pino Uceda",
   "license": "Apache-2.0",

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "private": true,
   "name": "cerestats",
-  "version": "0.24.3",
+  "version": "0.25.0",
   "description": "Cere Stats mono repo",
   "repository": {
     "type": "git",