Page MenuHomeDevCentral
Files F53428393

incidentController.js
No OneTemporary
Actions

incidentController.js
View Options

const incidentModel = require('../models/incidentModel.js');
const incidentUpdateModel = require('../models/incidentUpdateModel.js');
const { notifyAll } = require('../services/notificationService.js');
const incidentServiceModel = require('../models/incidentServiceModel.js');
const createIncident = async (req, res) => {
try {
const result = await incidentModel.createIncident(req.body);
const incident = result.rows[0];
if (req.body.service_ids && req.body.service_ids.length > 0) {
await incidentServiceModel.setServices(incident.id, req.body.service_ids);
}
res.status(201).json(incident);
notifyAll('Incident Created', { title: req.body.title, status: req.body.status || 'investigating', impact: req.body.impact || 'none' });
} catch (error) {
res.status(500).json({ message: 'Error creating incident', error: error.message });
}
};
const getIncidents = async (req, res) => {
try {
const result = await incidentModel.getIncidents();
res.status(200).json(result.rows);
} catch (error) {
res.status(500).json({ message: 'Error fetching incidents', error: error.message });
}
};
const getIncidentById = async (req, res) => {
try {
const incident = await incidentModel.getIncidentById(req.params.id);
if (incident.rows.length === 0) {
return res.status(404).json({ message: 'Incident not found' });
}
const updates = await incidentUpdateModel.getUpdatesByIncidentId(req.params.id);
const services = await incidentServiceModel.getServicesByIncident(req.params.id);
res.status(200).json({ ...incident.rows[0], updates: updates.rows, affected_services: services.rows });
} catch (error) {
res.status(500).json({ message: 'Error fetching incident', error: error.message });
}
};
const updateIncident = async (req, res) => {
try {
const result = await incidentModel.updateIncident(req.params.id, req.body);
if (result.rows.length === 0) {
return res.status(404).json({ message: 'Incident not found' });
}
if (req.body.message) {
await incidentUpdateModel.addUpdate({
incident_id: req.params.id,
status: req.body.status,
message: req.body.message
});
}
if (req.body.service_ids) {
await incidentServiceModel.setServices(req.params.id, req.body.service_ids);
}
res.status(200).json(result.rows[0]);
notifyAll('Incident Updated', { title: req.body.title, status: req.body.status, impact: req.body.impact, message: req.body.message });
} catch (error) {
res.status(500).json({ message: 'Error updating incident', error: error.message });
}
};
const resolveIncident = async (req, res) => {
try {
const result = await incidentModel.resolveIncident(req.params.id);
if (result.rows.length === 0) {
return res.status(404).json({ message: 'Incident not found' });
}
await incidentUpdateModel.addUpdate({
incident_id: req.params.id,
status: 'resolved',
message: req.body.message || 'Incident resolved'
});
res.status(200).json(result.rows[0]);
notifyAll('Incident Resolved', { id: req.params.id, message: req.body.message || 'Incident resolved' });
} catch (error) {
res.status(500).json({ message: 'Error resolving incident', error: error.message });
}
};
module.exports = { createIncident, getIncidents, getIncidentById, updateIncident, resolveIncident };

File Metadata

Mime Type
text/plain
Expires
Sun, Oct 11, 21:05 (4 h, 54 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
4171193
Default Alt Text
incidentController.js (3 KB)

Event Timeline

Nasqueron DevCentral · If it had been much bigger the moon would have had a core of ice. · Powered by Phabricator