{
  "type": "message",
  "id": "664db70e",                    // 消息唯一 ID
  "parentId": "21d29a13",              // 父消息 ID（用于构建对话树）
  "timestamp": "2026-03-06T11:30:05.754Z",  // 时间戳
  
  "message": {
    "role": "assistant",                // 角色：user | assistant
    "content": [                       // 消息内容（多模态）
      {
        "type": "thinking",            // 思考内容
        "thinking": "..."
      },
      {
        "type": "toolCall",           // 工具调用
        "id": "call_xxx",
        "name": "web_search",
        "arguments": {"query": "search term", "count": 10}
      }
    ],
    "api": "anthropic-messages",       // API 类型
    "provider": "minimax-cn",         // 提供商
    "model": "MiniMax-M2.5",          // 模型名称
    "usage": {                         // Token 用量 ⭐ 核心
      "input": 36,                    // 输入 Token 数
      "output": 82,                   // 输出 Token 数
      "cacheRead": 0,                 // 缓存读取 Token
      "cacheWrite": 16646,            // 缓存写入 Token
      "totalTokens": 16764,           // 总 Token 数
      "cost": {                       // 费用详情（单位：美元）
        "input": 0.0000108,
        "output": 0.0000984,
        "cacheRead": 0,
        "cacheWrite": 0.0019975,
        "total": 0.0021067
      }
    },
    "stopReason": "toolUse",          // 停止原因
    "timestamp": 1772796600230        // 消息级时间戳（毫秒）
  }
}

// 兼容多种字段名的 Token 提取函数
function getTokenValue(usage, ...keys) {
  for (const key of keys) {
    if (usage[key] != null && usage[key] > 0) {
      return usage[key];
    }
  }
  return 0;
}

// 使用示例
const inputTokens = getTokenValue(usage, 
  'input',           // OpenClaw 标准
  'inputTokens',     // OpenAI 格式
  'promptTokens',    // Anthropic 格式
  'prompt_tokens'    // 小写下划线格式
);

const outputTokens = getTokenValue(usage,
  'output',              // OpenClaw 标准
  'outputTokens',        // OpenAI 格式
  'completionTokens',     // Anthropic 格式
  'completion_tokens'     // 小写下划线格式
);

node --version
# 输出示例：v20.11.0

# 克隆或下载脚本
git clone https://github.com/your-username/token-tracker.git
cd token-tracker

# 直接运行
node token-tracker.js

# 创建符号链接到全局路径
npm link

# 然后可以在任意目录运行
token-tracker

node token-tracker.js

node token-tracker.js --json

{
  "total": {
    "input": 10420000,
    "output": 114400,
    "cacheRead": 5570000,
    "cacheWrite": 1580000,
    "cost": 3.621138
  },
  "today": {
    "input": 9300000,
    "output": 80600,
    "cost": 3.182288
  },
  "week": { "input": 9950000, "output": 97100, "cost": 3.428856 },
  "month": { "input": 10420000, "output": 114400, "cost": 3.621138 },
  "byModel": {
    "MiniMax-M2.7": { "input": 10400000, "output": 110000, "cost": 3.589263 },
    "MiniMax-M2.5": { "input": 25600, "output": 4400, "cost": 0.031875 }
  },
  "byDay": {
    "2026-03-28": { "input": 9300000, "output": 80600, "cost": 3.182288 }
  }
}

# 编辑 crontab
crontab -e

# 每天早上 9 点运行统计，并保存日志
0 9 * * * /usr/bin/node /path/to/token-tracker.js >> ~/token-logs/$(date +\%Y-\%m-\%d).log 2>&1

cat ~/token-logs/2026-03-28.log

// parsers/base.js
export class BaseParser {
  /**
   * 返回解析器名称
   */
  get name() {
    return 'base';
  }
  
  /**
   * 返回支持的数据路径
   */
  getPaths() {
    throw new Error('Not implemented');
  }
  
  /**
   * 解析单个文件
   * @param {string} filePath - 文件路径
   * @returns {Array} 条目数组
   */
  parseFile(filePath) {
    throw new Error('Not implemented');
  }
  
  /**
   * 执行解析
   * @returns {Promise<Array>} 所有条目
   */
  async parse() {
    const entries = [];
    for (const path of this.getPaths()) {
      const files = await glob(path);
      for (const file of files) {
        entries.push(...this.parseFile(file));
      }
    }
    return entries;
  }
}

// parsers/kimi-code.js
import { readdirSync, readFileSync, existsSync } from 'node:fs';
import { join } from 'node:path';
import { homedir } from 'node:os';
import { aggregateToBuckets } from './index.js';

const KIMI_PATH = join(homedir(), '.kimi', 'sessions');

export async function parse() {
  const entries = [];
  const sessions = [];
  
  if (!existsSync(KIMI_PATH)) return { buckets: [], sessions: [] };
  
  const files = readdirSync(KIMI_PATH).filter(f => f.endsWith('.jsonl'));
  
  for (const file of files) {
    const content = readFileSync(join(KIMI_PATH, file), 'utf-8');
    
    for (const line of content.split('\n')) {
      if (!line.trim()) continue;
      try {
        const obj = JSON.parse(line);
        // Kimi Code 的格式解析逻辑
        // 此处需要根据实际日志格式进行调整
      } catch {
        continue;
      }
    }
  }
  
  return { buckets: aggregateToBuckets(entries), sessions: [] };
}

// parsers/index.js
export { parse as parseOpenClaw } from './openclaw.js';
export { parse as parseClaudeCode } from './claude-code.js';
export { parse as parseKimiCode } from './kimi-code.js';

// 主程序中添加
import { parseKimiCode } from './parsers/kimi-code.js';

const allEntries = [
  ...(await parseOpenClaw()),
  ...(await parseClaudeCode()),
  ...(await parseKimiCode()),
];

const DAILY_COST_LIMIT = 10; // 美元

if (stats.today.cost > DAILY_COST_LIMIT) {
  console.warn('⚠️ 今日费用超过阈值 $10，请检查是否异常');
}

import { Worker } from 'worker_threads';

async function parseParallel(files, workerCount = 4) {
  const chunks = splitArray(files, workerCount);
  const workers = chunks.map(chunk => new Worker('./parser-worker.js', {
    workerData: { files: chunk }
  }));
  return Promise.all(workers.map(w => new Promise(resolve => {
    w.on('message', resolve);
  })));
}

node token-tracker.js --json > stats.json
# 使用 jq 或其他工具转换格式