+ ${card(score + '%', 'Compliance', scoreCls)}
+ ${card(t, 'Total Repos', '')}
+ ${card(s.withProtection, 'Protected', s.withProtection === t ? 'card-ok' : 'card-warn')}
+ ${card(s.ciPassing + '/' + s.withCI, 'CI Pass/Total', s.ciPassing === t ? 'card-ok' : s.withCI > 0 ? 'card-warn' : 'card-err')}
+ ${card(s.withSigned, 'Signed', s.withSigned === t ? 'card-ok' : 'card-warn')}
+ ${card(s.correctMerge, 'Correct Merge', s.correctMerge === t ? 'card-ok' : 'card-warn')}
+ ${card(s.withAutoMerge, 'Auto-Merge', s.withAutoMerge === t ? 'card-ok' : 'card-warn')}
+ ${card(s.withAllLabels, 'Labels OK', s.withAllLabels === t ? 'card-ok' : 'card-warn')}
+
`;
+}
+
+function renderPolicyPartial(data) {
+ const config = data.config || {};
+ const merge = config?.settings?.merge || {};
+ const bp = config?.branch_protection?.default || {};
+ const am = config?.auto_merge || {};
+ const checks = bp?.required_status_checks?.contexts || [];
+ const labels = (config?.issue_labels || []).map(l => l.name);
+
+ function row(label, value, detail) {
+ return `${badge('badge-ok', 'All repos compliant')} No issues detected.
`;
+ }
+
+ // Group by repo
+ const byRepo = {};
+ issues.forEach(i => {
+ if (!byRepo[i.repo]) byRepo[i.repo] = [];
+ byRepo[i.repo].push(i);
+ });
+
+ const typeIcon = { protection: 'shield', merge: 'git-merge', signed: 'key', 'auto-merge': 'zap', labels: 'tag' };
+ const rows = Object.entries(byRepo).map(([repo, items]) => {
+ const badges = items.map(i => {
+ const cls = i.type === 'protection' ? 'badge-err' : 'badge-warn';
+ return badge(cls, i.msg);
+ }).join(' ');
+ return `
-
Actions
-
-
-
-
-
+
+
+
+
+
-
-
Repositories
+
+
+
+
+
+
+
+
+
+
+
+
+
+
`;
}
-// ── Handler for Probot's addHandler pattern ──────────────────────────
-// Returns async (req, res) => boolean, matching Probot v14's handler chain
-
+// ── Request handler ──────────────────────────────────────────────────
function sendHtml(res, status, html) {
res.writeHead(status, { 'Content-Type': 'text/html; charset=utf-8' });
res.end(html);
}
-
function sendJson(res, status, obj) {
res.writeHead(status, { 'Content-Type': 'application/json' });
res.end(JSON.stringify(obj));
}
+function redirect(res, location) {
+ res.writeHead(302, { 'Location': location });
+ res.end();
+}
export function createDashboardHandler() {
return async (req, res) => {
const url = new URL(req.url, `http://${req.headers.host || 'localhost'}`);
const path = url.pathname;
- // GET /dashboard — main page
+ // Root redirect
+ if (req.method === 'GET' && (path === '/' || path === '')) {
+ redirect(res, '/dashboard');
+ return true;
+ }
+
if (req.method === 'GET' && path === '/dashboard') {
sendHtml(res, 200, renderDashboardPage());
return true;
}
- // GET /dashboard/partials/summary
if (req.method === 'GET' && path === '/dashboard/partials/summary') {
- try {
- const data = await fetchOrgData();
- sendHtml(res, 200, renderSummaryPartial(data));
- } catch (err) {
- getLogger().error({ err }, 'Dashboard summary error');
- sendHtml(res, 500, '
Error loading summary
');
- }
+ try { const data = await fetchOrgData(); sendHtml(res, 200, renderSummaryPartial(data)); }
+ catch (err) { getLogger().error({ err }, 'Dashboard summary error'); sendHtml(res, 500, '
Error loading
'); }
return true;
}
- // GET /dashboard/partials/repos
if (req.method === 'GET' && path === '/dashboard/partials/repos') {
- try {
- const data = await fetchOrgData();
- sendHtml(res, 200, renderReposPartial(data));
- } catch (err) {
- getLogger().error({ err }, 'Dashboard repos error');
- sendHtml(res, 500, '
Error loading repos
');
- }
+ try { const data = await fetchOrgData(); sendHtml(res, 200, renderReposPartial(data)); }
+ catch (err) { getLogger().error({ err }, 'Dashboard repos error'); sendHtml(res, 500, '
Error loading
'); }
+ return true;
+ }
+
+ if (req.method === 'GET' && path === '/dashboard/partials/policy') {
+ try { const data = await fetchOrgData(); sendHtml(res, 200, renderPolicyPartial(data)); }
+ catch (err) { getLogger().error({ err }, 'Dashboard policy error'); sendHtml(res, 500, '
Error loading
'); }
+ return true;
+ }
+
+ if (req.method === 'GET' && path === '/dashboard/partials/issues') {
+ try { const data = await fetchOrgData(); sendHtml(res, 200, renderIssuesPartial(data)); }
+ catch (err) { getLogger().error({ err }, 'Dashboard issues error'); sendHtml(res, 500, '
Error loading
'); }
return true;
}
- // GET /api/org/health — JSON summary
if (req.method === 'GET' && path === '/api/org/health') {
- try {
- const data = await fetchOrgData();
- sendJson(res, 200, { success: true, ...data.summary, timestamp: data.timestamp });
- } catch (err) {
- sendJson(res, 500, { success: false, error: err.message });
- }
+ try { const data = await fetchOrgData(); sendJson(res, 200, { success: true, ...data.summary, timestamp: data.timestamp }); }
+ catch (err) { sendJson(res, 500, { success: false, error: err.message }); }
return true;
}
- // GET /api/org/repos — JSON repo list
if (req.method === 'GET' && path === '/api/org/repos') {
- try {
- const data = await fetchOrgData();
- sendJson(res, 200, { success: true, repos: data.repos });
- } catch (err) {
- sendJson(res, 500, { success: false, error: err.message });
- }
+ try { const data = await fetchOrgData(); sendJson(res, 200, { success: true, repos: data.repos }); }
+ catch (err) { sendJson(res, 500, { success: false, error: err.message }); }
return true;
}
- // POST /dashboard/actions/refresh
if (req.method === 'POST' && path === '/dashboard/actions/refresh') {
invalidateCache();
- try {
- await fetchOrgData();
- sendJson(res, 200, { success: true, message: 'Cache refreshed' });
- } catch (err) {
- sendJson(res, 500, { success: false, message: err.message });
- }
+ try { await fetchOrgData(); sendJson(res, 200, { success: true, message: 'Cache refreshed' }); }
+ catch (err) { sendJson(res, 500, { success: false, message: err.message }); }
return true;
}
- // POST /dashboard/actions/sync
if (req.method === 'POST' && path === '/dashboard/actions/sync') {
try {
const octokit = await getOctokit();
const org = getConfig()?.organization || 'pulseengine';
const result = await synchronizeAllRepositories(octokit, org);
invalidateCache();
- sendJson(res, 200, {
- success: result.success,
- message: result.success
- ? `Synchronized ${result.repositoriesProcessed} repositories`
- : result.error
- });
- } catch (err) {
- sendJson(res, 500, { success: false, message: err.message });
- }
+ sendJson(res, 200, { success: result.success, message: result.success ? `Synchronized ${result.repositoriesProcessed} repositories` : result.error });
+ } catch (err) { sendJson(res, 500, { success: false, message: err.message }); }
return true;
}