let express = require ( "express" ) ;
const { allowDevAllOrigin , getSettings , setting } = require ( "../util-server" ) ;
const { R } = require ( "redbean-node" ) ;
const server = require ( "../server" ) ;
const apicache = require ( "../modules/apicache" ) ;
const Monitor = require ( "../model/monitor" ) ;
const dayjs = require ( "dayjs" ) ;
const { UP , MAINTENANCE , flipStatus , debug } = require ( "../../src/util" ) ;
let router = express . Router ( ) ;
let cache = apicache . middleware ;
let io = server . io ;
router . get ( "/api/entry-page" , async ( _ , response ) => {
allowDevAllOrigin ( response ) ;
response . json ( server . entryPage ) ;
} ) ;
router . get ( "/api/push/:pushToken" , async ( request , response ) => {
try {
let pushToken = request . params . pushToken ;
let msg = request . query . msg || "OK" ;
let ping = request . query . ping || null ;
let monitor = await R . findOne ( "monitor" , " push_token = ? AND active = 1 " , [
pushToken
] ) ;
if ( ! monitor ) {
throw new Error ( "Monitor not found or not active." ) ;
}
const previousHeartbeat = await Monitor . getPreviousHeartbeat ( monitor . id ) ;
let status = UP ;
if ( monitor . isUpsideDown ( ) ) {
status = flipStatus ( status ) ;
}
let isFirstBeat = true ;
let previousStatus = status ;
let duration = 0 ;
let bean = R . dispense ( "heartbeat" ) ;
bean . time = R . isoDateTime ( dayjs . utc ( ) ) ;
if ( previousHeartbeat ) {
isFirstBeat = false ;
previousStatus = previousHeartbeat . status ;
duration = dayjs ( bean . time ) . diff ( dayjs ( previousHeartbeat . time ) , "second" ) ;
}
const maintenance = await R . getAll ( "SELECT mm.*, maintenance.start_date, maintenance.end_date FROM monitor_maintenance mm JOIN maintenance ON mm.maintenance_id = maintenance.id WHERE mm.monitor_id = ? AND datetime(maintenance.start_date) <= datetime('now') AND datetime(maintenance.end_date) >= datetime('now')" , [ monitor . id ] ) ;
if ( maintenance . length !== 0 ) {
msg = "Monitor under maintenance" ;
status = MAINTENANCE ;
}
debug ( "PreviousStatus: " + previousStatus ) ;
debug ( "Current Status: " + status ) ;
bean . important = Monitor . isImportantBeat ( isFirstBeat , previousStatus , status ) ;
bean . monitor _id = monitor . id ;
bean . status = status ;
bean . msg = msg ;
bean . ping = ping ;
bean . duration = duration ;
await R . store ( bean ) ;
io . to ( monitor . user _id ) . emit ( "heartbeat" , bean . toJSON ( ) ) ;
Monitor . sendStats ( io , monitor . id , monitor . user _id ) ;
response . json ( {
ok : true ,
} ) ;
if ( Monitor . isImportantForNotification ( isFirstBeat , previousStatus , status ) ) {
await Monitor . sendNotification ( isFirstBeat , monitor , bean ) ;
}
} catch ( e ) {
response . json ( {
ok : false ,
msg : e . message
} ) ;
}
} ) ;
// Status Page Config
router . get ( "/api/status-page/config" , async ( _request , response ) => {
allowDevAllOrigin ( response ) ;
let config = await getSettings ( "statusPage" ) ;
if ( ! config . statusPageTheme ) {
config . statusPageTheme = "light" ;
}
if ( ! config . statusPagePublished ) {
config . statusPagePublished = true ;
}
if ( ! config . statusPageTags ) {
config . statusPageTags = false ;
}
if ( ! config . title ) {
config . title = "Uptime Kuma" ;
}
response . json ( config ) ;
} ) ;
// Status Page - Get the current Incident
// Can fetch only if published
router . get ( "/api/status-page/incident" , async ( _ , response ) => {
allowDevAllOrigin ( response ) ;
try {
await checkPublished ( ) ;
let incident = await R . findOne ( "incident" , " pin = 1 AND active = 1" ) ;
if ( incident ) {
incident = incident . toPublicJSON ( ) ;
}
response . json ( {
ok : true ,
incident ,
} ) ;
} catch ( error ) {
send403 ( response , error . message ) ;
}
} ) ;
// Status Page - Maintenance List
// Can fetch only if published
router . get ( "/api/status-page/maintenance-list" , async ( _request , response ) => {
allowDevAllOrigin ( response ) ;
try {
await checkPublished ( ) ;
const publicMaintenanceList = [ ] ;
let maintenanceBeanList = R . convertToBeans ( "maintenance" , await R . getAll ( `
SELECT maintenance . *
FROM maintenance
WHERE datetime ( maintenance . start _date ) <= datetime ( 'now' )
AND datetime ( maintenance . end _date ) >= datetime ( 'now' )
ORDER BY maintenance . end _date
` ));
for ( const bean of maintenanceBeanList ) {
publicMaintenanceList . push ( await bean . toPublicJSON ( ) ) ;
}
response . json ( publicMaintenanceList ) ;
} catch ( error ) {
send403 ( response , error . message ) ;
}
} ) ;
// Status Page - Monitor List
// Can fetch only if published
router . get ( "/api/status-page/monitor-list" , cache ( "5 minutes" ) , async ( _request , response ) => {
allowDevAllOrigin ( response ) ;
try {
await checkPublished ( ) ;
const publicGroupList = [ ] ;
const tagsVisible = ( await getSettings ( "statusPage" ) ) . statusPageTags ;
const list = await R . find ( "group" , " public = 1 ORDER BY weight " ) ;
for ( let groupBean of list ) {
let monitorGroup = await groupBean . toPublicJSON ( ) ;
if ( tagsVisible ) {
monitorGroup . monitorList = await Promise . all ( monitorGroup . monitorList . map ( async ( monitor ) => {
// Includes tags as an array in response, allows for tags to be displayed on public status page
const tags = await R . getAll (
` SELECT monitor_tag.monitor_id, monitor_tag.value, tag.name, tag.color
FROM monitor _tag
JOIN tag
ON monitor _tag . tag _id = tag . id
WHERE monitor _tag . monitor _id = ? ` , [monitor.id]
) ;
return {
... monitor ,
tags : tags
} ;
} ) ) ;
}
publicGroupList . push ( monitorGroup ) ;
}
response . json ( publicGroupList ) ;
} catch ( error ) {
send403 ( response , error . message ) ;
}
} ) ;
// Status Page Polling Data
// Can fetch only if published
router . get ( "/api/status-page/heartbeat" , cache ( "5 minutes" ) , async ( _request , response ) => {
allowDevAllOrigin ( response ) ;
try {
await checkPublished ( ) ;
let heartbeatList = { } ;
let uptimeList = { } ;
let monitorIDList = await R . getCol ( `
SELECT monitor _group . monitor _id FROM monitor _group , \ ` group \`
WHERE monitor _group . group _id = \ ` group \` .id
AND public = 1
` );
for ( let monitorID of monitorIDList ) {
let list = await R . getAll ( `
SELECT * FROM heartbeat
WHERE monitor _id = ?
ORDER BY time DESC
LIMIT 50
` , [
monitorID ,
] ) ;
list = R . convertToBeans ( "heartbeat" , list ) ;
heartbeatList [ monitorID ] = list . reverse ( ) . map ( row => row . toPublicJSON ( ) ) ;
const type = 24 ;
uptimeList [ ` ${ monitorID } _ ${ type } ` ] = await Monitor . calcUptime ( type , monitorID ) ;
}
response . json ( {
heartbeatList ,
uptimeList
} ) ;
} catch ( error ) {
send403 ( response , error . message ) ;
}
} ) ;
async function checkPublished ( ) {
if ( ! await isPublished ( ) ) {
throw new Error ( "The status page is not published" ) ;
}
}
/ * *
* Default is published
* @ returns { Promise < boolean > }
* /
async function isPublished ( ) {
const value = await setting ( "statusPagePublished" ) ;
if ( value === null ) {
return true ;
}
return value ;
}
function send403 ( res , msg = "" ) {
res . status ( 403 ) . json ( {
"status" : "fail" ,
"msg" : msg ,
} ) ;
}
module . exports = router ;