refactor(sessions): dedupe generated transcript parsing · openclaw/openclaw@2052a3b

Recent Commits to openclaw:main

vincentkoc · 2026-06-18 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,29 @@`
	`1`	`+import path from "node:path";`
	`2`	`+`
	`3`	`+export function extractGeneratedTranscriptSessionId(sessionFile?: string): string \| undefined {`
	`4`	`+const trimmed = sessionFile?.trim();`
	`5`	`+if (!trimmed) {`
	`6`	`+return undefined;`
	`7`	`+}`
	`8`	`+const base = path.basename(trimmed);`
	`9`	`+if (!base.endsWith(".jsonl")) {`
	`10`	`+return undefined;`
	`11`	`+}`
	`12`	`+const withoutExt = base.slice(0, -".jsonl".length);`
	`13`	`+const topicIndex = withoutExt.indexOf("-topic-");`
	`14`	`+if (topicIndex > 0) {`
	`15`	`+const topicSessionId = withoutExt.slice(0, topicIndex);`
	`16`	`+return looksLikeGeneratedSessionId(topicSessionId) ? topicSessionId : undefined;`
	`17`	`+}`
	`18`	`+const forkMatch = withoutExt.match(`
	`19`	`+/^(\d{4}-\d{2}-\d{2}T[\w-]+(?:Z\|[+-]\d{2}(?:-\d{2})?)?)_(.+)$/,`
	`20`	`+);`
	`21`	`+if (forkMatch?.[2]) {`
	`22`	`+return looksLikeGeneratedSessionId(forkMatch[2]) ? forkMatch[2] : undefined;`
	`23`	`+}`
	`24`	`+return looksLikeGeneratedSessionId(withoutExt) ? withoutExt : undefined;`
	`25`	`+}`
	`26`	`+`
	`27`	`+function looksLikeGeneratedSessionId(value: string): boolean {`
	`28`	`+return /^[0-9a-f]{8}-[0-9a-f]{4}-[1-8][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(value);`
	`29`	`+}`

Original file line number	Diff line number	Diff line change
`@@ -14,6 +14,7 @@ import type { SessionTranscriptUpdate } from "../../sessions/transcript-events.j`
`14`	`14`	`import { getRuntimeConfig } from "../io.js";`
`15`	`15`	`import type { OpenClawConfig } from "../types.openclaw.js";`
`16`	`16`	`import { formatSessionArchiveTimestamp } from "./artifacts.js";`
	`17`	`+import { extractGeneratedTranscriptSessionId } from "./generated-transcript-session-id.js";`
`17`	`18`	`import {`
`18`	`19`	`resolveSessionFilePath,`
`19`	`20`	`resolveSessionFilePathOptions,`
`@@ -915,34 +916,6 @@ function classifyGeneratedTranscriptCandidate(`
`915`	`916`	`return transcriptSessionId === sessionId ? "current" : "stale";`
`916`	`917`	`}`
`917`	`918`
`918`		`-function extractGeneratedTranscriptSessionId(sessionFile?: string): string \| undefined {`
`919`		`-const trimmed = sessionFile?.trim();`
`920`		`-if (!trimmed) {`
`921`		`-return undefined;`
`922`		`-}`
`923`		`-const base = path.basename(trimmed);`
`924`		`-if (!base.endsWith(".jsonl")) {`
`925`		`-return undefined;`
`926`		`-}`
`927`		`-const withoutExt = base.slice(0, -".jsonl".length);`
`928`		`-const topicIndex = withoutExt.indexOf("-topic-");`
`929`		`-if (topicIndex > 0) {`
`930`		`-const topicSessionId = withoutExt.slice(0, topicIndex);`
`931`		`-return looksLikeGeneratedSessionId(topicSessionId) ? topicSessionId : undefined;`
`932`		`-}`
`933`		`-const forkMatch = withoutExt.match(`
`934`		`-/^(\d{4}-\d{2}-\d{2}T[\w-]+(?:Z\|[+-]\d{2}(?:-\d{2})?)?)_(.+)$/,`
`935`		`-);`
`936`		`-if (forkMatch?.[2]) {`
`937`		`-return looksLikeGeneratedSessionId(forkMatch[2]) ? forkMatch[2] : undefined;`
`938`		`-}`
`939`		`-return looksLikeGeneratedSessionId(withoutExt) ? withoutExt : undefined;`
`940`		`-}`
`941`		`-`
`942`		`-function looksLikeGeneratedSessionId(value: string): boolean {`
`943`		`-return /^[0-9a-f]{8}-[0-9a-f]{4}-[1-8][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(value);`
`944`		`-}`
`945`		`-`
`946`	`919`	`/**`
`947`	`920`	`* Persists one logical transcript turn through the current file-backed writer.`
`948`	`921`	`* The file implementation resolves/rebinds the transcript file, holds one`

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import {`
`9`	`9`	`parseSessionArchiveTimestamp,`
`10`	`10`	`type SessionArchiveReason,`
`11`	`11`	`} from "../config/sessions/artifacts.js";`
	`12`	`+import { extractGeneratedTranscriptSessionId } from "../config/sessions/generated-transcript-session-id.js";`
`12`	`13`	`import {`
`13`	`14`	`resolveSessionFilePath,`
`14`	`15`	`resolveSessionTranscriptPath,`
`@@ -106,33 +107,7 @@ function classifySessionTranscriptCandidate(`
`106`	`107`	`return transcriptSessionId === sessionId ? "current" : "stale";`
`107`	`108`	`}`
`108`	`109`
`109`		`-export function extractGeneratedTranscriptSessionId(sessionFile?: string): string \| undefined {`
`110`		`-const trimmed = sessionFile?.trim();`
`111`		`-if (!trimmed) {`
`112`		`-return undefined;`
`113`		`-}`
`114`		`-const base = path.basename(trimmed);`
`115`		`-if (!base.endsWith(".jsonl")) {`
`116`		`-return undefined;`
`117`		`-}`
`118`		`-const withoutExt = base.slice(0, -".jsonl".length);`
`119`		`-const topicIndex = withoutExt.indexOf("-topic-");`
`120`		`-if (topicIndex > 0) {`
`121`		`-const topicSessionId = withoutExt.slice(0, topicIndex);`
`122`		`-return looksLikeGeneratedSessionId(topicSessionId) ? topicSessionId : undefined;`
`123`		`-}`
`124`		`-const forkMatch = withoutExt.match(`
`125`		`-/^(\d{4}-\d{2}-\d{2}T[\w-]+(?:Z\|[+-]\d{2}(?:-\d{2})?)?)_(.+)$/,`
`126`		`-);`
`127`		`-if (forkMatch?.[2]) {`
`128`		`-return looksLikeGeneratedSessionId(forkMatch[2]) ? forkMatch[2] : undefined;`
`129`		`-}`
`130`		`-return looksLikeGeneratedSessionId(withoutExt) ? withoutExt : undefined;`
`131`		`-}`
`132`		`-`
`133`		`-function looksLikeGeneratedSessionId(value: string): boolean {`
`134`		`-return /^[0-9a-f]{8}-[0-9a-f]{4}-[1-8][0-9a-f]{3}-[89ab][0-9a-f]{3}-[0-9a-f]{12}$/i.test(value);`
`135`		`-}`
	`110`	`+export { extractGeneratedTranscriptSessionId };`
`136`	`111`
`137`	`112`	`function canonicalizePathForComparison(filePath: string): string {`
`138`	`113`	`const resolved = path.resolve(filePath);`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main