LumeWeb
/
skynet-webportal
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #405 from NebulousLabs/healthcheck-cli-fix 

update db before reading it in api
This commit is contained in:
Karol Wypchło 2020-09-18 17:05:43 +02:00 committed by GitHub
parent 4d9a6d0cf3 745e9b0add
commit 97e312f75a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
packages/health-check/src/index.js
View File

@ -6,6 +6,7 @@ if (!process.env.PORTAL_URL) {
const express = require("express"); const express = require("express");
const bodyparser = require("body-parser"); const bodyparser = require("body-parser");
const db = require("./db");
require("./schedule"); require("./schedule");
@ -16,6 +17,10 @@ const server = express();
server.use(bodyparser.urlencoded({ extended: false })); server.use(bodyparser.urlencoded({ extended: false }));
server.use(bodyparser.json()); server.use(bodyparser.json());
server.use((req, res, next) => {
db.read();
next();
});
server.get("/health-check", require("./api/index")); server.get("/health-check", require("./api/index"));
server.get("/health-check/critical", require("./api/critical")); server.get("/health-check/critical", require("./api/critical"));

4
packages/health-check/src/schedule.js
View File

@ -10,7 +10,7 @@ const criticalJob = schedule.scheduleJob("*/5 * * * *", async () => {
checks: await Promise.all(criticalChecks.map((check) => new Promise(check))), checks: await Promise.all(criticalChecks.map((check) => new Promise(check))),
}; };
db.get("critical").push(entry).write(); db.read().get("critical").push(entry).write();
}); });
// execute the verbose health-check script once per hour // execute the verbose health-check script once per hour
@ -20,7 +20,7 @@ const verboseJob = schedule.scheduleJob("0 * * * *", async () => {
checks: await Promise.all(verboseChecks.map((check) => new Promise(check))), checks: await Promise.all(verboseChecks.map((check) => new Promise(check))),
}; };
db.get("verbose").push(entry).write(); db.read().get("verbose").push(entry).write();
}); });
// Launch Health check jobs // Launch Health check jobs