TyleoDvDelaware3217/Kuma
1
0
Fork 0
mirror of https://github.com/louislam/uptime-kuma.git synced 2025-06-15 08:56:47 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

ESLint issues fixed

Browse source
This commit is contained in:
Claudius Orsmond 2021-12-25 22:20:05 +02:00
parent d893ebe650
commit ba33aea1a4
1 changed files with 153 additions and 153 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
server/routers/api-router.js
View file

@ -1,37 +1,37 @@
let express = require('express'); let express = require("express");
const { allowDevAllOrigin, getSettings, setting } = require('../util-server'); const { allowDevAllOrigin, getSettings, setting } = require("../util-server");
const { R } = require('redbean-node'); const { R } = require("redbean-node");
const server = require('../server'); const server = require("../server");
const apicache = require('../modules/apicache'); const apicache = require("../modules/apicache");
const Monitor = require('../model/monitor'); const Monitor = require("../model/monitor");
const dayjs = require('dayjs'); const dayjs = require("dayjs");
const { UP, flipStatus, debug, DOWN } = require('../../src/util'); const { UP, flipStatus, debug, DOWN } = require("../../src/util");
let router = express.Router(); let router = express.Router();
let cache = apicache.middleware; let cache = apicache.middleware;
let io = server.io; let io = server.io;
router.get('/api/entry-page', async (_, response) => { router.get("/api/entry-page", async (_, response) => {
allowDevAllOrigin(response); allowDevAllOrigin(response);
response.json(server.entryPage); response.json(server.entryPage);
}); });
router.get('/api/push/:pushToken', async (request, response) => { router.get("/api/push/:pushToken", async (request, response) => {
try { try {
let pushToken = request.params.pushToken; let pushToken = request.params.pushToken;
let msg = request.query.msg || 'OK'; let msg = request.query.msg || "OK";
let ping = request.query.ping || null; let ping = request.query.ping || null;
let health = request.query.health || 'UP'; // Backwards compatible, so if nothing was specified it will work as always let health = request.query.health || "UP"; // Backwards compatible, so if nothing was specified it will work as always
let monitor = await R.findOne('monitor', ' push_token = ? AND active = 1 ', [pushToken]); let monitor = await R.findOne("monitor", " push_token = ? AND active = 1 ", [pushToken]);
if (!monitor) { if (!monitor) {
throw new Error('Monitor not found or not active.'); throw new Error("Monitor not found or not active.");
} }
const previousHeartbeat = await Monitor.getPreviousHeartbeat(monitor.id); const previousHeartbeat = await Monitor.getPreviousHeartbeat(monitor.id);
let status = health === 'UP' ? UP : DOWN; let status = health === "UP" ? UP : DOWN;
if (monitor.isUpsideDown()) { if (monitor.isUpsideDown()) {
status = flipStatus(status); status = flipStatus(status);
} }
@ -40,17 +40,17 @@ router.get('/api/push/:pushToken', async (request, response) => {
let previousStatus = status; let previousStatus = status;
let duration = 0; let duration = 0;
let bean = R.dispense('heartbeat'); let bean = R.dispense("heartbeat");
bean.time = R.isoDateTime(dayjs.utc()); bean.time = R.isoDateTime(dayjs.utc());
if (previousHeartbeat) { if (previousHeartbeat) {
isFirstBeat = false; isFirstBeat = false;
previousStatus = previousHeartbeat.status; previousStatus = previousHeartbeat.status;
duration = dayjs(bean.time).diff(dayjs(previousHeartbeat.time), 'second'); duration = dayjs(bean.time).diff(dayjs(previousHeartbeat.time), "second");
} }
debug('PreviousStatus: ' + previousStatus); debug("PreviousStatus: " + previousStatus);
debug('Current Status: ' + status); debug("Current Status: " + status);
bean.important = Monitor.isImportantBeat(isFirstBeat, previousStatus, status); bean.important = Monitor.isImportantBeat(isFirstBeat, previousStatus, status);
bean.monitor_id = monitor.id; bean.monitor_id = monitor.id;
@ -61,7 +61,7 @@ router.get('/api/push/:pushToken', async (request, response) => {
await R.store(bean); await R.store(bean);
io.to(monitor.user_id).emit('heartbeat', bean.toJSON()); io.to(monitor.user_id).emit("heartbeat", bean.toJSON());
Monitor.sendStats(io, monitor.id, monitor.user_id); Monitor.sendStats(io, monitor.id, monitor.user_id);
response.json({ response.json({
@ -80,13 +80,13 @@ router.get('/api/push/:pushToken', async (request, response) => {
}); });
// Status Page Config // Status Page Config
router.get('/api/status-page/config', async (_request, response) => { router.get("/api/status-page/config", async (_request, response) => {
allowDevAllOrigin(response); allowDevAllOrigin(response);
let config = await getSettings('statusPage'); let config = await getSettings("statusPage");
if (!config.statusPageTheme) { if (!config.statusPageTheme) {
config.statusPageTheme = 'light'; config.statusPageTheme = "light";
} }
if (!config.statusPagePublished) { if (!config.statusPagePublished) {
@ -98,7 +98,7 @@ router.get('/api/status-page/config', async (_request, response) => {
} }
if (!config.title) { if (!config.title) {
config.title = 'Uptime Kuma'; config.title = "Uptime Kuma";
} }
response.json(config); response.json(config);
@ -106,13 +106,13 @@ router.get('/api/status-page/config', async (_request, response) => {
// Status Page - Get the current Incident // Status Page - Get the current Incident
// Can fetch only if published // Can fetch only if published
router.get('/api/status-page/incident', async (_, response) => { router.get("/api/status-page/incident", async (_, response) => {
allowDevAllOrigin(response); allowDevAllOrigin(response);
try { try {
await checkPublished(); await checkPublished();
let incident = await R.findOne('incident', ' pin = 1 AND active = 1'); let incident = await R.findOne("incident", " pin = 1 AND active = 1");
if (incident) { if (incident) {
incident = incident.toPublicJSON(); incident = incident.toPublicJSON();
@ -129,14 +129,14 @@ router.get('/api/status-page/incident', async (_, response) => {
// Status Page - Monitor List // Status Page - Monitor List
// Can fetch only if published // Can fetch only if published
router.get('/api/status-page/monitor-list', cache('5 minutes'), async (_request, response) => { router.get("/api/status-page/monitor-list", cache("5 minutes"), async (_request, response) => {
allowDevAllOrigin(response); allowDevAllOrigin(response);
try { try {
await checkPublished(); await checkPublished();
const publicGroupList = []; const publicGroupList = [];
const tagsVisible = (await getSettings('statusPage')).statusPageTags; const tagsVisible = (await getSettings("statusPage")).statusPageTags;
const list = await R.find('group', ' public = 1 ORDER BY weight '); const list = await R.find("group", " public = 1 ORDER BY weight ");
for (let groupBean of list) { for (let groupBean of list) {
let monitorGroup = await groupBean.toPublicJSON(); let monitorGroup = await groupBean.toPublicJSON();
if (tagsVisible) { if (tagsVisible) {
@ -170,7 +170,7 @@ router.get('/api/status-page/monitor-list', cache('5 minutes'), async (_request,
// Status Page Polling Data // Status Page Polling Data
// Can fetch only if published // Can fetch only if published
router.get('/api/status-page/heartbeat', cache('5 minutes'), async (_request, response) => { router.get("/api/status-page/heartbeat", cache("5 minutes"), async (_request, response) => {
allowDevAllOrigin(response); allowDevAllOrigin(response);
try { try {
@ -196,7 +196,7 @@ router.get('/api/status-page/heartbeat', cache('5 minutes'), async (_request, re
[monitorID] [monitorID]
); );
list = R.convertToBeans('heartbeat', list); list = R.convertToBeans("heartbeat", list);
heartbeatList[monitorID] = list.reverse().map((row) => row.toPublicJSON()); heartbeatList[monitorID] = list.reverse().map((row) => row.toPublicJSON());
const type = 24; const type = 24;
@ -214,7 +214,7 @@ router.get('/api/status-page/heartbeat', cache('5 minutes'), async (_request, re
async function checkPublished() { async function checkPublished() {
if (!(await isPublished())) { if (!(await isPublished())) {
throw new Error('The status page is not published'); throw new Error("The status page is not published");
} }
} }
@ -223,16 +223,16 @@ async function checkPublished() {
* @returns {Promise<boolean>} * @returns {Promise<boolean>}
*/ */
async function isPublished() { async function isPublished() {
const value = await setting('statusPagePublished'); const value = await setting("statusPagePublished");
if (value === null) { if (value === null) {
return true; return true;
} }
return value; return value;
} }
function send403(res, msg = '') { function send403(res, msg = "") {
res.status(403).json({ res.status(403).json({
status: 'fail', status: "fail",
msg: msg, msg: msg,
}); });
} }