feat: add /stats clear command to reset usage statistics

Users can now reset usage stats via:
- /stats clear (or /stats reset) in OpenClaw
- DELETE /stats HTTP endpoint on the proxy

Author: 1bcMax

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@blockrun/clawrouter",
-  "version": "0.12.9",
+  "version": "0.12.10",
   "description": "Smart LLM router — save 92% on inference costs. 41+ models, one wallet, x402 micropayments.",
   "type": "module",
   "main": "dist/index.js",

package.json

@@ -67,7 +67,7 @@ import { homedir } from "node:os";
 import { join } from "node:path";
 import { VERSION } from "./version.js";
 import { privateKeyToAccount } from "viem/accounts";
-import { getStats, formatStatsAscii } from "./stats.js";
+import { getStats, formatStatsAscii, clearStats } from "./stats.js";
 import { buildPartnerTools, PARTNER_SERVICES } from "./partners/index.js";
 
 /**
@@ -510,6 +510,21 @@ async function createStatsCommand(): Promise<OpenClawPluginCommandDefinition> {
     requireAuth: false,
     handler: async (ctx: PluginCommandContext) => {
       const arg = ctx.args?.trim().toLowerCase() || "7";
+
+      if (arg === "clear" || arg === "reset") {
+        try {
+          const { deletedFiles } = await clearStats();
+          return {
+            text: `Stats cleared — ${deletedFiles} log file(s) deleted. Fresh start!`,
+          };
+        } catch (err) {
+          return {
+            text: `Failed to clear stats: ${err instanceof Error ? err.message : String(err)}`,
+            isError: true,
+          };
+        }
+      }
+
       const days = parseInt(arg, 10) || 7;
 
       try {
@@ -1144,7 +1159,7 @@ export {
 } from "./errors.js";
 export { fetchWithRetry, isRetryable, DEFAULT_RETRY_CONFIG } from "./retry.js";
 export type { RetryConfig } from "./retry.js";
-export { getStats, formatStatsAscii } from "./stats.js";
+export { getStats, formatStatsAscii, clearStats } from "./stats.js";
 export type { DailyStats, AggregatedStats } from "./stats.js";
 export {
   SessionStore,

src/index.ts

@@ -54,7 +54,7 @@ import {
   supportsVision,
 } from "./models.js";
 import { logUsage, type UsageEntry } from "./logger.js";
-import { getStats } from "./stats.js";
+import { getStats, clearStats } from "./stats.js";
 import { RequestDeduplicator } from "./dedup.js";
 import { ResponseCache, type ResponseCacheConfig } from "./response-cache.js";
 import { BalanceMonitor } from "./balance.js";
@@ -1329,6 +1329,23 @@ export async function startProxy(options: ProxyOptions): Promise<ProxyHandle> {
       return;
     }
 
+    // Stats clear endpoint - delete all log files
+    if (req.url === "/stats" && req.method === "DELETE") {
+      try {
+        const result = await clearStats();
+        res.writeHead(200, { "Content-Type": "application/json" });
+        res.end(JSON.stringify({ cleared: true, deletedFiles: result.deletedFiles }));
+      } catch (err) {
+        res.writeHead(500, { "Content-Type": "application/json" });
+        res.end(
+          JSON.stringify({
+            error: `Failed to clear stats: ${err instanceof Error ? err.message : String(err)}`,
+          }),
+        );
+      }
+      return;
+    }
+
     // Stats API endpoint - returns JSON for programmatic access
     if (req.url === "/stats" || req.url?.startsWith("/stats?")) {
       try {

src/proxy.ts

@@ -5,7 +5,7 @@
  * Supports filtering by date range and provides multiple aggregation views.
  */
 
-import { readdir } from "node:fs/promises";
+import { readdir, unlink } from "node:fs/promises";
 import { readTextFile } from "./fs-read.js";
 import { join } from "node:path";
 import { homedir } from "node:os";
@@ -294,3 +294,19 @@ export function formatStatsAscii(stats: AggregatedStats): string {
 
   return lines.join("\n");
 }
+
+/**
+ * Delete all usage log files, resetting stats to zero.
+ */
+export async function clearStats(): Promise<{ deletedFiles: number }> {
+  try {
+    const files = await readdir(LOG_DIR);
+    const logFiles = files.filter((f) => f.startsWith("usage-") && f.endsWith(".jsonl"));
+
+    await Promise.all(logFiles.map((f) => unlink(join(LOG_DIR, f))));
+
+    return { deletedFiles: logFiles.length };
+  } catch {
+    return { deletedFiles: 0 };
+  }
+}