From 3f3b090caac7e982c375ebdab2fa021e46d707d2 Mon Sep 17 00:00:00 2001
From: yiekheng <yiekheng@04080616.xyz>
Date: Sat, 9 May 2026 16:12:53 +0800
Subject: [PATCH] feat(bot): add audit log writer

---
 apps/bot/src/audit.test.ts | 32 ++++++++++++++++++++++++++++++++
 apps/bot/src/audit.ts      | 22 ++++++++++++++++++++++
 2 files changed, 54 insertions(+)
 create mode 100644 apps/bot/src/audit.test.ts
 create mode 100644 apps/bot/src/audit.ts

diff --git a/apps/bot/src/audit.test.ts b/apps/bot/src/audit.test.ts
new file mode 100644
index 0000000..22835b6
--- /dev/null
+++ b/apps/bot/src/audit.test.ts
@@ -0,0 +1,32 @@
+import { describe, expect, it } from "vitest";
+import type { DB } from "./db.js";
+import { writeAuditLog } from "./audit.js";
+
+describe("writeAuditLog", () => {
+  it("inserts a row with normalized fields", async () => {
+    const inserted: unknown[] = [];
+    const fakeDb = {
+      insert: () => ({
+        values: (v: unknown) => {
+          inserted.push(v);
+          return Promise.resolve();
+        },
+      }),
+    } as unknown as DB;
+
+    await writeAuditLog(fakeDb, {
+      operatorId: null,
+      source: "telegram",
+      action: "test.event",
+      payload: { foo: "bar" },
+    });
+
+    expect(inserted).toHaveLength(1);
+    expect(inserted[0]).toMatchObject({
+      operatorId: null,
+      source: "telegram",
+      action: "test.event",
+      payload: { foo: "bar" },
+    });
+  });
+});
diff --git a/apps/bot/src/audit.ts b/apps/bot/src/audit.ts
new file mode 100644
index 0000000..fd3e8a8
--- /dev/null
+++ b/apps/bot/src/audit.ts
@@ -0,0 +1,22 @@
+import { auditLog, type DB, type NewAuditLogEntry } from "@cmbot/db";
+
+export type AuditInput = {
+  operatorId: string | null;
+  source: "web" | "telegram" | "system";
+  action: string;
+  targetType?: string | null;
+  targetId?: string | null;
+  payload?: Record<string, unknown>;
+};
+
+export async function writeAuditLog(db: DB, input: AuditInput): Promise<void> {
+  const row: NewAuditLogEntry = {
+    operatorId: input.operatorId,
+    source: input.source,
+    action: input.action,
+    targetType: input.targetType ?? null,
+    targetId: input.targetId ?? null,
+    payload: input.payload ?? {},
+  };
+  await db.insert(auditLog).values(row);
+}