Skip to content

feat: implement incident history #6469

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
CommanderStorm merged 19 commits into from
Jan 20, 2026
Merged

feat: implement incident history #6469

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
19 commits
Select commit Hold shift + click to select a range
1a9748d
incident history foundation
aluminyoom Dec 8, 2025
11a9414
format translations
aluminyoom Dec 9, 2025
71f32ae
address review comments
aluminyoom Dec 9, 2025
c730f39
Merge branch 'master' into feature/incident-history
aluminyoom Dec 10, 2025
1057cc9
address self-review comments
aluminyoom Dec 10, 2025
9e000ae
Merge branch 'master' into feature/incident-history
CommanderStorm Jan 3, 2026
aced37d
Merge branch 'master' into feature/incident-history
aluminyoom Jan 4, 2026
db883c0
Merge branch 'master' into feature/incident-history
CommanderStorm Jan 9, 2026
6fee737
[autofix.ci] apply automated fixes
autofix-ci[bot] Jan 9, 2026
4bdea1e
Merge remote-tracking branch 'origin/master' into feature/incident-hi…
aluminyoom Jan 19, 2026
f9061eb
address review comments
aluminyoom Jan 19, 2026
72753d0
utils
aluminyoom Jan 19, 2026
8076275
Merge branch 'master' into feature/incident-history
CommanderStorm Jan 19, 2026
fea823d
[autofix.ci] apply automated fixes
autofix-ci[bot] Jan 19, 2026
22bc222
fix eslint disable comment
aluminyoom Jan 20, 2026
c0a5ea8
use existing i8n, change disable to multiline
aluminyoom Jan 20, 2026
ff084d6
fix e2e tests
aluminyoom Jan 20, 2026
79cc7e8
make stuff more consistent
aluminyoom Jan 20, 2026
5ed6804
make e2e more targeted
aluminyoom Jan 20, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 18 additions & 4 deletions server/model/incident.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,9 +1,21 @@
const { BeanModel } = require("redbean-node/dist/bean-model");
const { R } = require("redbean-node");
const dayjs = require("dayjs");

class Incident extends BeanModel {
/**
* Resolve the incident and mark it as inactive
* @returns {Promise<void>}
*/
async resolve() {
this.active = false;
this.pin = false;
this.last_updated_date = R.isoDateTime(dayjs.utc());
await R.store(this);
}

/**
* Return an object that ready to parse to JSON for public
* Only show necessary data to public
* @returns {object} Object ready to parse
*/
toPublicJSON() {
Expand All @@ -12,9 +24,11 @@ class Incident extends BeanModel {
style: this.style,
title: this.title,
content: this.content,
pin: this.pin,
createdDate: this.createdDate,
lastUpdatedDate: this.lastUpdatedDate,
pin: !!this.pin,
active: !!this.active,
createdDate: this.created_date,
lastUpdatedDate: this.last_updated_date,
status_page_id: this.status_page_id,
Copy link
Collaborator

@CommanderStorm CommanderStorm Dec 25, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I don't consider this quite internal, or am I missing something? 🤔
Can't this just be added to toPublicJSON?

Copy link
Contributor Author

@aluminyoom aluminyoom Jan 4, 2026 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

definitely trivial yea, reasoning behind this is to expose the only needed data for public endpoints. since status_page_id doesn't really get consumed on the public facing side.

we can add it to toPublicJSON but it would be unused for public endpoints.

edit: formatting

Copy link
Collaborator

@CommanderStorm CommanderStorm Jan 4, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lets simplify this then to just include it up in toPublicJSON.

};
}
}
Expand Down
66 changes: 58 additions & 8 deletions server/model/status_page.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,8 @@ const analytics = require("../analytics/analytics");
const { marked } = require("marked");
const { Feed } = require("feed");
const config = require("../config");
const { setting } = require("../util-server");

const { setting } = require("../util-server");
const {
STATUS_PAGE_ALL_DOWN,
STATUS_PAGE_ALL_UP,
Expand All @@ -17,6 +17,7 @@ const {
UP,
MAINTENANCE,
DOWN,
INCIDENT_PAGE_SIZE,
} = require("../../src/util");

class StatusPage extends BeanModel {
Expand Down Expand Up @@ -307,12 +308,13 @@ class StatusPage extends BeanModel {
static async getStatusPageData(statusPage) {
const config = await statusPage.toPublicJSON();

// Incident
let incident = await R.findOne("incident", " pin = 1 AND active = 1 AND status_page_id = ? ", [statusPage.id]);

if (incident) {
incident = incident.toPublicJSON();
}
// All active incidents
let incidents = await R.find(
"incident",
" pin = 1 AND active = 1 AND status_page_id = ? ORDER BY created_date DESC",
[statusPage.id]
);
incidents = incidents.map((i) => i.toPublicJSON());

let maintenanceList = await StatusPage.getMaintenanceList(statusPage.id);

Expand All @@ -330,7 +332,7 @@ class StatusPage extends BeanModel {
// Response
return {
config,
incident,
incidents,
publicGroupList,
maintenanceList,
};
Expand Down Expand Up @@ -499,6 +501,54 @@ class StatusPage extends BeanModel {
}
}

/**
* Get paginated incident history for a status page using cursor-based pagination
* @param {number} statusPageId ID of the status page
* @param {string|null} cursor ISO date string cursor (created_date of last item from previous page)
* @param {boolean} isPublic Whether to return public or admin data
* @returns {Promise<object>} Paginated incident data with cursor
*/
static async getIncidentHistory(statusPageId, cursor = null, isPublic = true) {
let incidents;

if (cursor) {
incidents = await R.find(
"incident",
" status_page_id = ? AND created_date < ? ORDER BY created_date DESC LIMIT ? ",
[statusPageId, cursor, INCIDENT_PAGE_SIZE]
);
} else {
incidents = await R.find("incident", " status_page_id = ? ORDER BY created_date DESC LIMIT ? ", [
statusPageId,
INCIDENT_PAGE_SIZE,
]);
}

const total = await R.count("incident", " status_page_id = ? ", [statusPageId]);

const lastIncident = incidents[incidents.length - 1];
let nextCursor = null;
let hasMore = false;

if (lastIncident) {
const moreCount = await R.count("incident", " status_page_id = ? AND created_date < ? ", [
statusPageId,
lastIncident.created_date,
]);
hasMore = moreCount > 0;
if (hasMore) {
nextCursor = lastIncident.created_date;
}
}

return {
incidents: incidents.map((i) => i.toPublicJSON()),
total,
nextCursor,
hasMore,
};
}

/**
* Get list of maintenances
* @param {number} statusPageId ID of status page to get maintenance for
Expand Down
24 changes: 24 additions & 0 deletions server/routers/status-page-router.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -142,6 +142,30 @@ router.get("/api/status-page/:slug/manifest.json", cache("1440 minutes"), async
}
});

router.get("/api/status-page/:slug/incident-history", cache("5 minutes"), async (request, response) => {
allowDevAllOrigin(response);

try {
let slug = request.params.slug;
slug = slug.toLowerCase();
let statusPageID = await StatusPage.slugToID(slug);

if (!statusPageID) {
sendHttpError(response, "Status Page Not Found");
return;
}

const cursor = request.query.cursor || null;
const result = await StatusPage.getIncidentHistory(statusPageID, cursor, true);
response.json({
ok: true,
...result,
});
} catch (error) {
sendHttpError(response, error.message);
}
});

// overall status-page status badge
router.get("/api/status-page/:slug/badge", cache("5 minutes"), async (request, response) => {
allowDevAllOrigin(response);
Expand Down
187 changes: 183 additions & 4 deletions server/socket-handlers/status-page-socket-handler.js
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,21 @@ const apicache = require("../modules/apicache");
const StatusPage = require("../model/status_page");
const { UptimeKumaServer } = require("../uptime-kuma-server");

/**
* Validates incident data
* @param {object} incident - The incident object
* @returns {void}
* @throws {Error} If validation fails
*/
function validateIncident(incident) {
if (!incident.title || incident.title.trim() === "") {
throw new Error("Please input title");
}
if (!incident.content || incident.content.trim() === "") {
throw new Error("Please input content");
}
}

/**
* Socket handlers for status page
* @param {Socket} socket Socket.io instance to add listeners on
Expand All @@ -25,8 +40,6 @@ module.exports.statusPageSocketHandler = (socket) => {
throw new Error("slug is not found");
}

await R.exec("UPDATE incident SET pin = 0 WHERE status_page_id = ? ", [statusPageID]);

let incidentBean;

if (incident.id) {
Expand All @@ -44,12 +57,13 @@ module.exports.statusPageSocketHandler = (socket) => {
incidentBean.content = incident.content;
incidentBean.style = incident.style;
incidentBean.pin = true;
incidentBean.active = true;
incidentBean.status_page_id = statusPageID;

if (incident.id) {
incidentBean.lastUpdatedDate = R.isoDateTime(dayjs.utc());
incidentBean.last_updated_date = R.isoDateTime(dayjs.utc());
} else {
incidentBean.createdDate = R.isoDateTime(dayjs.utc());
incidentBean.created_date = R.isoDateTime(dayjs.utc());
}

await R.store(incidentBean);
Expand Down Expand Up @@ -85,6 +99,171 @@ module.exports.statusPageSocketHandler = (socket) => {
}
});

socket.on("getIncidentHistory", async (slug, cursor, callback) => {
try {
let statusPageID = await StatusPage.slugToID(slug);
if (!statusPageID) {
throw new Error("slug is not found");
}

const isPublic = !socket.userID;
const result = await StatusPage.getIncidentHistory(statusPageID, cursor, isPublic);
callback({
ok: true,
...result,
});
} catch (error) {
callback({
ok: false,
msg: error.message,
});
}
});

socket.on("editIncident", async (slug, incidentID, incident, callback) => {
try {
checkLogin(socket);

let statusPageID = await StatusPage.slugToID(slug);
if (!statusPageID) {
callback({
ok: false,
msg: "slug is not found",
msgi18n: true,
});
return;
}

let bean = await R.findOne("incident", " id = ? AND status_page_id = ? ", [incidentID, statusPageID]);
if (!bean) {
callback({
ok: false,
msg: "Incident not found or access denied",
msgi18n: true,
});
return;
}

try {
validateIncident(incident);
} catch (e) {
callback({
ok: false,
msg: e.message,
msgi18n: true,
});
return;
}

const validStyles = ["info", "warning", "danger", "primary", "light", "dark"];
if (!validStyles.includes(incident.style)) {
incident.style = "warning";
}

bean.title = incident.title;
bean.content = incident.content;
bean.style = incident.style;
bean.pin = incident.pin !== false;
bean.lastUpdatedDate = R.isoDateTime(dayjs.utc());

await R.store(bean);

callback({
ok: true,
msg: "Saved.",
msgi18n: true,
incident: bean.toPublicJSON(),
});
} catch (error) {
callback({
ok: false,
msg: error.message,
msgi18n: true,
});
}
});

socket.on("deleteIncident", async (slug, incidentID, callback) => {
try {
checkLogin(socket);

let statusPageID = await StatusPage.slugToID(slug);
if (!statusPageID) {
callback({
ok: false,
msg: "slug is not found",
msgi18n: true,
});
return;
}

let bean = await R.findOne("incident", " id = ? AND status_page_id = ? ", [incidentID, statusPageID]);
if (!bean) {
callback({
ok: false,
msg: "Incident not found or access denied",
msgi18n: true,
});
return;
}

await R.trash(bean);

callback({
ok: true,
msg: "successDeleted",
msgi18n: true,
});
} catch (error) {
callback({
ok: false,
msg: error.message,
msgi18n: true,
});
}
});

socket.on("resolveIncident", async (slug, incidentID, callback) => {
try {
checkLogin(socket);

let statusPageID = await StatusPage.slugToID(slug);
if (!statusPageID) {
callback({
ok: false,
msg: "slug is not found",
msgi18n: true,
});
return;
}

let bean = await R.findOne("incident", " id = ? AND status_page_id = ? ", [incidentID, statusPageID]);
if (!bean) {
callback({
ok: false,
msg: "Incident not found or access denied",
msgi18n: true,
});
return;
}

await bean.resolve();

callback({
ok: true,
msg: "Resolved",
msgi18n: true,
incident: bean.toPublicJSON(),
});
} catch (error) {
callback({
ok: false,
msg: error.message,
msgi18n: true,
});
}
});

socket.on("getStatusPage", async (slug, callback) => {
try {
checkLogin(socket);
Expand Down
Loading
Loading