Fix Request Logs clean history purge

docs/getting-started/TROUBLESHOOTING.md

@@ -259,6 +259,9 @@ curl http://localhost:20128/api/monitoring/health
 - Application logs: `<repo>/logs/...` (when `APP_LOG_TO_FILE=true`)
 - Call log artifacts: `${DATA_DIR}/call_logs/YYYY-MM-DD/...` when the call log pipeline is enabled
 
+The Request Logs page's **Clean history** action clears `call_logs`, legacy
+`request_detail_logs`, and the local `${DATA_DIR}/call_logs/` artifact directory.
+
 ---
 
 ## Circuit Breaker Issues

docs/guides/TROUBLESHOOTING.md

@@ -263,6 +263,9 @@ curl http://localhost:20128/api/monitoring/health
 - Application logs: `<repo>/logs/...` (when `APP_LOG_TO_FILE=true`)
 - Call log artifacts: `${DATA_DIR}/call_logs/YYYY-MM-DD/...` when the call log pipeline is enabled
 
+The Request Logs page's **Clean history** action clears `call_logs`, legacy
+`request_detail_logs`, and the local `${DATA_DIR}/call_logs/` artifact directory.
+
 ---
 
 ## Circuit Breaker Issues

docs/reference/API_REFERENCE.md

@@ -404,15 +404,16 @@ Response example:
 
 ### Settings
 
-| Endpoint                        | Method        | Description               |
-| ------------------------------- | ------------- | ------------------------- |
-| `/api/settings`                 | GET/PUT/PATCH | General settings          |
-| `/api/settings/proxy`           | GET/PUT       | Network proxy config      |
-| `/api/settings/proxy/test`      | POST          | Test proxy connection     |
-| `/api/settings/ip-filter`       | GET/PUT       | IP allowlist/blocklist    |
-| `/api/settings/thinking-budget` | GET/PUT       | Reasoning token budget    |
-| `/api/settings/system-prompt`   | GET/PUT       | Global system prompt      |
-| `/api/settings/compression`     | GET/PUT       | Global compression config |
+| Endpoint                              | Method        | Description                                         |
+| ------------------------------------- | ------------- | --------------------------------------------------- |
+| `/api/settings`                       | GET/PUT/PATCH | General settings                                    |
+| `/api/settings/proxy`                 | GET/PUT       | Network proxy config                                |
+| `/api/settings/proxy/test`            | POST          | Test proxy connection                               |
+| `/api/settings/ip-filter`             | GET/PUT       | IP allowlist/blocklist                              |
+| `/api/settings/thinking-budget`       | GET/PUT       | Reasoning token budget                              |
+| `/api/settings/system-prompt`         | GET/PUT       | Global system prompt                                |
+| `/api/settings/compression`           | GET/PUT       | Global compression config                           |
+| `/api/settings/purge-request-history` | POST          | Clear request log rows and local call-log artifacts |
 
 ### Context & Compression
 

docs/reference/openapi.yaml

@@ -1803,6 +1803,49 @@ paths:
         "200":
           description: Updated settings
 
+  /api/settings/purge-request-history:
+    post:
+      tags: [Settings]
+      summary: Clear request log history
+      description: Deletes `call_logs`, legacy `request_detail_logs`, and local request artifact files under `DATA_DIR/call_logs`.
+      security:
+        - ManagementSessionAuth: []
+      responses:
+        "200":
+          description: Request history cleared
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  deleted:
+                    type: integer
+                  deletedArtifacts:
+                    type: integer
+                  deletedDetailedLogs:
+                    type: integer
+                  errors:
+                    type: integer
+        "401":
+          description: Unauthorized
+        "500":
+          description: Cleanup failed or reported errors
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  deleted:
+                    type: integer
+                  deletedArtifacts:
+                    type: integer
+                  deletedDetailedLogs:
+                    type: integer
+                  errors:
+                    type: integer
+                  error:
+                    type: object
+
   /api/settings/compression:
     get:
       tags: [Compression]

docs/security/COMPLIANCE.md

@@ -118,6 +118,11 @@ from `src/server-init.ts` and `src/instrumentation-node.ts`. Each run logs a
 `compliance.cleanup` audit event with the per-table delete counts. Proxy/call
 log trimming is batched (`BATCH_SIZE = 5000`) to avoid long write locks.
 
+Manual request-history cleanup is separate from retention. The Request Logs
+page calls `POST /api/settings/purge-request-history`, which deletes `call_logs`,
+legacy `request_detail_logs`, and local request artifacts under
+`${DATA_DIR}/call_logs/`.
+
 Defaults are defined in `src/lib/logEnv.ts`
 (`DEFAULT_APP_LOG_RETENTION_DAYS = 7`, `DEFAULT_CALL_LOG_RETENTION_DAYS = 7`).
 

src/app/(dashboard)/dashboard/logs/page.tsx

@@ -12,6 +12,20 @@ const TIME_RANGES = [
   { label: "24h", hours: 24 },
 ];
 
+type LogsTranslator = ((key: string, values?: Record<string, unknown>) => string) & {
+  has?: (key: string) => boolean;
+};
+
+function logsText(
+  t: LogsTranslator,
+  key: string,
+  fallback: string,
+  values?: Record<string, unknown>
+) {
+  if (typeof t.has !== "function" || !t.has(key)) return fallback;
+  return values ? t(key, values) : t(key);
+}
+
 export default function LogsPage() {
   const [showExport, setShowExport] = useState(false);
   const [exporting, setExporting] = useState(false);
@@ -21,7 +35,7 @@ export default function LogsPage() {
   const [requestLogKey, setRequestLogKey] = useState(0);
   const dropdownRef = useRef<HTMLDivElement>(null);
   const requestLoggerRef = useRef<any>(null);
-  const t = useTranslations("logs");
+  const t = useTranslations("logs") as LogsTranslator;
 
   useEffect(() => {
     function handleClickOutside(e: MouseEvent) {
@@ -34,7 +48,8 @@ export default function LogsPage() {
   }, []);
 
   // initial id from URL (synchronously on client) so child can open on mount
-  const initialId = typeof window !== "undefined" ? new URL(window.location.href).searchParams.get("id") : null;
+  const initialId =
+    typeof window !== "undefined" ? new URL(window.location.href).searchParams.get("id") : null;
 
   async function handleExport(hours: number) {
     setExporting(true);
@@ -64,26 +79,40 @@ export default function LogsPage() {
     setShowCleanHistory(false);
     setCleanHistoryStatus(null);
     try {
-      const res = await fetch("/api/settings/purge-logs", { method: "POST" });
+      const res = await fetch("/api/settings/purge-request-history", { method: "POST" });
       const data = await res.json().catch(() => null);
 
       if (!res.ok) {
-        throw new Error(data?.error || "Failed to clean log history.");
+        throw new Error(
+          data?.error || logsText(t, "cleanHistoryFailed", "Failed to clean log history.")
+        );
       }
 
       const deleted = typeof data?.deleted === "number" ? data.deleted : 0;
-      const deletedArtifacts = typeof data?.deletedArtifacts === "number" ? data.deletedArtifacts : 0;
+      const deletedArtifacts =
+        typeof data?.deletedArtifacts === "number" ? data.deletedArtifacts : 0;
+      const deletedDetailedLogs =
+        typeof data?.deletedDetailedLogs === "number" ? data.deletedDetailedLogs : 0;
+      const successFallback = `Cleaned ${deleted} log entr${deleted === 1 ? "y" : "ies"}, ${deletedArtifacts} artifact${
+        deletedArtifacts === 1 ? "" : "s"
+      }, and ${deletedDetailedLogs} legacy detail row${deletedDetailedLogs === 1 ? "" : "s"}.`;
       setRequestLogKey((key) => key + 1);
       setCleanHistoryStatus(
-        deleted || deletedArtifacts
-          ? `Cleaned ${deleted} log entr${deleted === 1 ? "y" : "ies"} and ${deletedArtifacts} artifact${
-              deletedArtifacts === 1 ? "" : "s"
-            }.`
-          : "No expired log history needed cleanup."
+        deleted || deletedArtifacts || deletedDetailedLogs
+          ? logsText(t, "cleanHistorySuccess", successFallback, {
+              deleted,
+              deletedArtifacts,
+              deletedDetailedLogs,
+            })
+          : logsText(t, "cleanHistoryEmpty", "No request log history was found.")
       );
     } catch (err) {
-      console.error("Failed to clean log history", err);
-      setCleanHistoryStatus(err instanceof Error ? err.message : "Failed to clean log history.");
+      console.error(logsText(t, "cleanHistoryFailed", "Failed to clean log history."), err);
+      setCleanHistoryStatus(
+        err instanceof Error
+          ? err.message
+          : logsText(t, "cleanHistoryFailed", "Failed to clean log history.")
+      );
     } finally {
       setCleaningHistory(false);
     }
@@ -120,7 +149,7 @@ export default function LogsPage() {
                 strokeLinejoin="round"
               />
             </svg>
-            Clean history
+            {logsText(t, "cleanHistoryButton", "Clean history")}
           </button>
 
           <div className="relative" ref={dropdownRef}>
@@ -195,10 +224,14 @@ export default function LogsPage() {
         isOpen={showCleanHistory}
         onClose={() => setShowCleanHistory(false)}
         onConfirm={handleCleanHistory}
-        title="Clean log history?"
-        message="This clears expired log history and prunes related artifacts using the current retention policy. The live page will refresh after cleanup."
-        confirmText="Clean history"
-        cancelText="Cancel"
+        title={logsText(t, "cleanHistoryTitle", "Clean log history?")}
+        message={logsText(
+          t,
+          "cleanHistoryMessage",
+          "This permanently clears all request log rows, legacy detail rows, and local artifact files under DATA_DIR/call_logs. The live page will refresh after cleanup."
+        )}
+        confirmText={logsText(t, "cleanHistoryConfirm", "Clean history")}
+        cancelText={logsText(t, "cleanHistoryCancel", "Cancel")}
         loading={cleaningHistory}
       />
     </div>

src/app/api/settings/purge-call-logs/route.ts

@@ -1,7 +1,10 @@
 import { NextResponse } from "next/server";
+import { buildErrorBody } from "@omniroute/open-sse/utils/error";
 import { purgeCallLogs } from "@/lib/db/cleanup";
 import { isAuthenticated } from "@/shared/utils/apiAuth";
 
+export const runtime = "nodejs";
+
 export async function POST(request: Request) {
   if (!(await isAuthenticated(request))) {
     return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
@@ -10,10 +13,12 @@ export async function POST(request: Request) {
     const result = await purgeCallLogs();
     return NextResponse.json({
       deleted: result.deleted,
+      deletedArtifacts: result.deletedArtifacts ?? 0,
       errors: result.errors,
     });
-  } catch (err: unknown) {
-    const error = err instanceof Error ? err.message : String(err);
-    return NextResponse.json({ error }, { status: 500 });
+  } catch {
+    return NextResponse.json(buildErrorBody(500, "Failed to purge call logs"), {
+      status: 500,
+    });
   }
 }

src/app/api/settings/purge-request-history/route.ts

@@ -0,0 +1,32 @@
+import { NextResponse } from "next/server";
+import { buildErrorBody } from "@omniroute/open-sse/utils/error";
+import { purgeCallLogs, purgeDetailedLogs } from "@/lib/db/cleanup";
+import { isAuthenticated } from "@/shared/utils/apiAuth";
+
+export const runtime = "nodejs";
+
+export async function POST(request: Request) {
+  if (!(await isAuthenticated(request))) {
+    return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+  }
+
+  try {
+    const callLogs = await purgeCallLogs();
+    const detailedLogs = await purgeDetailedLogs();
+    const errors = callLogs.errors + detailedLogs.errors;
+
+    return NextResponse.json(
+      {
+        deleted: callLogs.deleted,
+        deletedArtifacts: callLogs.deletedArtifacts ?? 0,
+        deletedDetailedLogs: detailedLogs.deleted,
+        errors,
+      },
+      { status: errors > 0 ? 500 : 200 }
+    );
+  } catch {
+    return NextResponse.json(buildErrorBody(500, "Failed to purge request history"), {
+      status: 500,
+    });
+  }
+}

src/i18n/messages/en.json

@@ -3771,6 +3771,14 @@
     "export": "Export",
     "exporting": "Exporting...",
     "exportFailed": "Export failed",
+    "cleanHistoryButton": "Clean history",
+    "cleanHistoryTitle": "Clean log history?",
+    "cleanHistoryMessage": "This permanently clears all request log rows, legacy detail rows, and local artifact files under DATA_DIR/call_logs. The live page will refresh after cleanup.",
+    "cleanHistoryConfirm": "Clean history",
+    "cleanHistoryCancel": "Cancel",
+    "cleanHistorySuccess": "Cleaned {deleted} log entries, {deletedArtifacts} artifacts, and {deletedDetailedLogs} legacy detail rows.",
+    "cleanHistoryEmpty": "No request log history was found.",
+    "cleanHistoryFailed": "Failed to clean log history.",
     "timeRange": "Time Range",
     "lastNHours": "Last {hours}",
     "defaultRange": "default",

src/lib/db/cleanup.ts

@@ -7,9 +7,11 @@
 import { getDbInstance } from "./core";
 import { getUserDatabaseSettings } from "./databaseSettings";
 import { rollupUsageHistoryBeforeDate } from "@/lib/usage/aggregateHistory";
+import { purgeCallLogArtifactDirectory } from "@/lib/usage/callLogArtifacts";
 
 interface CleanupResult {
   deleted: number;
+  deletedArtifacts?: number;
   errors: number;
 }
 
@@ -304,11 +306,10 @@ export async function purgeQuotaSnapshots(): Promise<CleanupResult> {
  */
 export async function purgeCallLogs(): Promise<CleanupResult> {
   const db = getDbInstance();
-  const result: CleanupResult = { deleted: 0, errors: 0 };
+  const result: CleanupResult = { deleted: 0, deletedArtifacts: 0, errors: 0 };
 
   try {
-    const stmt = db.prepare("DELETE FROM call_logs");
-    const runResult = stmt.run();
+    const runResult = db.prepare("DELETE FROM call_logs").run();
     result.deleted = runResult.changes;
 
     console.log(`[Cleanup] Purged ${result.deleted} call_logs`);
@@ -317,6 +318,14 @@ export async function purgeCallLogs(): Promise<CleanupResult> {
     result.errors++;
   }
 
+  const artifactResult = purgeCallLogArtifactDirectory();
+  result.deletedArtifacts = artifactResult.deletedArtifacts;
+  result.errors += artifactResult.errors;
+
+  if (artifactResult.errors === 0) {
+    console.log(`[Cleanup] Purged ${result.deletedArtifacts} call log artifact(s)`);
+  }
+
   return result;
 }
 

src/lib/usage/callLogArtifacts.ts

@@ -61,6 +61,11 @@ export type CallLogArtifactWriteResult = {
   sha256: string;
 };
 
+export type PurgeCallLogArtifactDirectoryResult = {
+  deletedArtifacts: number;
+  errors: number;
+};
+
 export function buildArtifactRelativePath(timestamp: string, id: string) {
   const parsed = new Date(timestamp);
   const safeTimestamp = (
@@ -307,3 +312,26 @@ export function listCallLogArtifactFiles(baseDir = CALL_LOGS_DIR) {
     })
     .sort((a, b) => b.mtimeMs - a.mtimeMs);
 }
+
+export function purgeCallLogArtifactDirectory(
+  baseDir = CALL_LOGS_DIR
+): PurgeCallLogArtifactDirectoryResult {
+  const result = { deletedArtifacts: 0, errors: 0 };
+  if (!baseDir || !fs.existsSync(baseDir)) return result;
+
+  try {
+    result.deletedArtifacts = listCallLogArtifactFiles(baseDir).length;
+  } catch {
+    result.deletedArtifacts = 0;
+  }
+
+  try {
+    fs.rmSync(baseDir, { recursive: true, force: true });
+  } catch (error) {
+    console.error("[callLogArtifacts] Failed to purge call log artifacts:", error);
+    result.deletedArtifacts = 0;
+    result.errors++;
+  }
+
+  return result;
+}