Audit Summary

1'use strict';
2
3const fs = require('fs');
4
5function createBucket() {
6  return {
7    total: 0,
8    ok: 0,
9    created: 0,
10    updated: 0,
11    skipped: 0,
12    failed: 0,
13    retried: 0,
14    throttled: 0,
15  };
16}
17
18function statusOf(event) {
19  return event.status || event.resultStatus || event.result || 'unknown';
20}
21
22function entityOf(event) {
23  return event.entity || event.entityKey || event.sourceEntity || 'unknown';
24}
25
26function summarizeAuditEvents(events, { runId } = {}) {
27  if (!runId) {
28    throw new Error('summarizeAuditEvents requires runId; append-only audit logs may contain multiple attempts.');
29  }
30  const summary = {};
31  for (const event of events) {
32    if (!event || event.runId !== runId) continue;
33    const entity = entityOf(event);
34    const status = statusOf(event);
35    if (!summary[entity]) summary[entity] = createBucket();
36    summary[entity].total += 1;
37    if (Object.prototype.hasOwnProperty.call(summary[entity], status)) {
38      summary[entity][status] += 1;
39    }
40  }
41  return summary;
42}
43
44function readAuditNdjson(filePath) {
45  const text = fs.readFileSync(filePath, 'utf8').trim();
46  if (!text) return [];
47  return text.split('\n').filter(Boolean).map((line, index) => {
48    try {
49      return JSON.parse(line);
50    } catch (error) {
51      throw new Error(`Invalid audit JSON at line ${index + 1}: ${error.message}`);
52    }
53  });
54}
55
56function summarizeAuditFile(filePath, options) {
57  return summarizeAuditEvents(readAuditNdjson(filePath), options);
58}
59
60module.exports = {
61  summarizeAuditEvents,
62  summarizeAuditFile,
63  readAuditNdjson,
64};