This interface provides simplified views and API endpoints for AI agents to interact with Syngrisi.
${check.name}
Status: ${check.status[0]}
ID: ${check._id}
`;
if (baseline) {
html += `
Baseline
`;
}
if (actual) {
html += `
Actual
`;
}
if (diff) {
html += `
Diff
`;
}
html += `
Metadata
${JSON.stringify(check.meta || {}, null, 2)}
Actions
`;
res.send(htmlShell(`Check: ${check.name} `, html));
});
const getAnalysis = catchAsync(async (req: ExtRequest, res: Response) => {
const { id } = req.params;
const check: any = await Check.findById(id).populate('actualSnapshotId baselineId diffId');
if (!check) {
res.status(404).json({ error: 'Check not found' });
return;
}
const getBase64 = (filename: string) => {
try {
const filePath = path.join(config.defaultImagesPath, filename);
if (fs.existsSync(filePath)) {
return fs.readFileSync(filePath, { encoding: 'base64' });
}
} catch {
return null;
}
return null;
};
const actual = check.actualSnapshotId ? getBase64(check.actualSnapshotId.filename) : null;
const baseline = check.baselineId ? getBase64(check.baselineId.filename) : null;
const diff = check.diffId ? getBase64(check.diffId.filename) : null;
res.json({
id: check._id,
name: check.name,
status: check.status,
images: {
actual,
baseline,
diff
},
meta: check.meta,
context: {
// Placeholder for calculated context
failure_rate: 0, // To be implemented
last_passed: null
}
});
});
const batchUpdate = catchAsync(async (req: ExtRequest, res: Response) => {
const { ids, action } = req.body;
const idList = Array.isArray(ids) ? ids : [ids];
log.info(`Batch update: ${action} for ${idList.length} checks`, { scope: 'ai.controller' });
log.info(`User: ${req.user?.username} `, { scope: 'ai.controller' });
if (!ids || !Array.isArray(ids)) {
throw new ApiError(HttpStatus.BAD_REQUEST, 'ids array is required');
}
if (action === 'accept') {
for (const id of idList) {
// @ts-expect-error
await accept(id, null, req.user);
}
} else if (action === 'remove') {
for (const id of idList) {
// @ts-expect-error
await remove(id, req.user);
}
}
if (req.headers.accept?.includes('json')) {
res.json({ success: true, count: idList.length });
} else {
res.redirect('back');
}
});
const registerWebhook = catchAsync(async (req: ExtRequest, res: Response) => {
const { url, events, secret } = req.body;
const webhook = await Webhook.create({ url, events, secret });
res.status(201).json(webhook);
});
export const aiController = {
getIndex,
getChecks,
getCheckDetails,
getAnalysis,
batchUpdate,
registerWebhook
};