惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

C
Check Point Blog
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
L
LangChain Blog
云风的 BLOG
云风的 BLOG
M
MIT News - Artificial intelligence
A
About on SuperTechFans
J
Java Code Geeks
量子位
博客园 - 三生石上(FineUI控件)
博客园 - Franky
博客园_首页
H
Hackread – Cybersecurity News, Data Breaches, AI and More
IT之家
IT之家
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
Apple Machine Learning Research
Apple Machine Learning Research
Engineering at Meta
Engineering at Meta
雷峰网
雷峰网
D
DataBreaches.Net
人人都是产品经理
人人都是产品经理
Martin Fowler
Martin Fowler
有赞技术团队
有赞技术团队
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
fix(gateway): compute sessions.usage aggregate totals fro...
liuhao1024 · 2026-06-16 · via Recent Commits to openclaw:main

@@ -28,6 +28,7 @@ import {

2828

loadCostUsageSummaryFromCache,

2929

loadSessionLogs,

3030

loadSessionCostSummaryFromCache,

31+

loadSessionCostSummariesFromCache,

3132

loadSessionUsageTimeSeries,

3233

discoverAllSessions,

3334

resolveExistingUsageSessionFile,

@@ -1145,7 +1146,6 @@ export const usageHandlers: GatewayRequestHandlers = {

11451146

// Sort by most recent first

11461147

mergedEntries.sort((a, b) => b.updatedAt - a.updatedAt);

114711481148-

// Apply limit

11491149

const limitedEntries = mergedEntries.slice(0, limit);

1150115011511151

// Load usage for each session

@@ -1232,7 +1232,7 @@ export const usageHandlers: GatewayRequestHandlers = {

12321232

};

1233123312341234

const usageByEntryIndex: Array<SessionCostSummary | null> = Array.from(

1235-

{ length: limitedEntries.length },

1235+

{ length: mergedEntries.length },

12361236

() => null,

12371237

);

12381238

const usageLoadTasks: Array<

@@ -1289,15 +1289,61 @@ export const usageHandlers: GatewayRequestHandlers = {

12891289

if (!loaded.summary) {

12901290

continue;

12911291

}

1292-

const merged = limitedEntries[loaded.entryIndex];

1292+

const merged = mergedEntries[loaded.entryIndex];

12931293

const usage = usageByEntryIndex[loaded.entryIndex] ?? createEmptySessionCostSummary();

12941294

usage.sessionId = merged.sessionId;

12951295

usage.sessionFile = merged.sessionFile;

12961296

mergeSessionUsageInto(usage, loaded.summary);

12971297

usageByEntryIndex[loaded.entryIndex] = usage;

12981298

}

129912991300-

for (const [entryIndex, merged] of limitedEntries.entries()) {

1300+

const hiddenSessionsByAgent = new Map<

1301+

string | undefined,

1302+

Array<{ entryIndex: number; sessionId: string; sessionFile: string }>

1303+

>();

1304+

for (const [entryIndex, merged] of mergedEntries.entries()) {

1305+

if (entryIndex < limitedEntries.length) {

1306+

continue;

1307+

}

1308+

const hiddenSessions = hiddenSessionsByAgent.get(merged.agentId) ?? [];

1309+

for (const includedSessionId of merged.includedSessionIds ?? [merged.sessionId]) {

1310+

const sessionFile =

1311+

includedSessionId === merged.sessionId

1312+

? merged.sessionFile

1313+

: resolveExistingUsageSessionFile({

1314+

sessionId: includedSessionId,

1315+

agentId: merged.agentId,

1316+

});

1317+

if (sessionFile) {

1318+

hiddenSessions.push({ entryIndex, sessionId: includedSessionId, sessionFile });

1319+

}

1320+

}

1321+

hiddenSessionsByAgent.set(merged.agentId, hiddenSessions);

1322+

}

1323+

for (const [agentId, hiddenSessions] of hiddenSessionsByAgent) {

1324+

const hiddenUsage = await loadSessionCostSummariesFromCache({

1325+

sessions: hiddenSessions,

1326+

config,

1327+

agentId,

1328+

startMs,

1329+

endMs,

1330+

});

1331+

cacheStatus = mergeUsageCacheStatus(cacheStatus, hiddenUsage.cacheStatus);

1332+

for (const [hiddenIndex, summary] of hiddenUsage.summaries.entries()) {

1333+

if (!summary) {

1334+

continue;

1335+

}

1336+

const hiddenSession = hiddenSessions[hiddenIndex];

1337+

const merged = mergedEntries[hiddenSession.entryIndex];

1338+

const usage = usageByEntryIndex[hiddenSession.entryIndex] ?? createEmptySessionCostSummary();

1339+

usage.sessionId = merged.sessionId;

1340+

usage.sessionFile = merged.sessionFile;

1341+

mergeSessionUsageInto(usage, summary);

1342+

usageByEntryIndex[hiddenSession.entryIndex] = usage;

1343+

}

1344+

}

1345+1346+

for (const [entryIndex, merged] of mergedEntries.entries()) {

13011347

const agentId = merged.agentId;

13021348

const usage = usageByEntryIndex[entryIndex];

13031349

@@ -1433,29 +1479,31 @@ export const usageHandlers: GatewayRequestHandlers = {

14331479

}

14341480

}

143514811436-

sessions.push({

1437-

key: merged.key,

1438-

label: merged.label,

1439-

sessionId: merged.sessionId,

1440-

scope: merged.scope ?? "instance",

1441-

sessionFamilyKey: merged.sessionFamilyKey,

1442-

currentSessionId: merged.currentSessionId,

1443-

includedSessionIds: merged.includedSessionIds,

1444-

historicalInstanceCount: merged.includedSessionIds?.length,

1445-

updatedAt: merged.updatedAt,

1446-

agentId,

1447-

channel,

1448-

chatType,

1449-

origin: merged.storeEntry?.origin,

1450-

modelOverride: merged.storeEntry?.modelOverride,

1451-

providerOverride: merged.storeEntry?.providerOverride,

1452-

modelProvider: merged.storeEntry?.modelProvider,

1453-

model: merged.storeEntry?.model,

1454-

usage,

1455-

contextWeight: includeContextWeight

1456-

? (merged.storeEntry?.systemPromptReport ?? null)

1457-

: undefined,

1458-

});

1482+

if (entryIndex < limit) {

1483+

sessions.push({

1484+

key: merged.key,

1485+

label: merged.label,

1486+

sessionId: merged.sessionId,

1487+

scope: merged.scope ?? "instance",

1488+

sessionFamilyKey: merged.sessionFamilyKey,

1489+

currentSessionId: merged.currentSessionId,

1490+

includedSessionIds: merged.includedSessionIds,

1491+

historicalInstanceCount: merged.includedSessionIds?.length,

1492+

updatedAt: merged.updatedAt,

1493+

agentId,

1494+

channel,

1495+

chatType,

1496+

origin: merged.storeEntry?.origin,

1497+

modelOverride: merged.storeEntry?.modelOverride,

1498+

providerOverride: merged.storeEntry?.providerOverride,

1499+

modelProvider: merged.storeEntry?.modelProvider,

1500+

model: merged.storeEntry?.model,

1501+

usage,

1502+

contextWeight: includeContextWeight

1503+

? (merged.storeEntry?.systemPromptReport ?? null)

1504+

: undefined,

1505+

});

1506+

}

14591507

}

1460150814611509

// Format dates back to YYYY-MM-DD strings