LLM/moltbot
1
0
Fork 0
mirror of https://github.com/moltbot/moltbot.git synced 2026-05-16 18:34:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: mark acp event ledger path legacy

Browse Source
This commit is contained in:
Peter Steinberger
2026-05-08 20:43:53 +01:00
parent d6ede36e4e
commit 7bef339e03
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/acp/event-ledger.test.ts
View File

@@ -7,7 +7,7 @@ import {
createInMemoryAcpEventLedger,
createSqliteAcpEventLedger,
importLegacyAcpEventLedgerFileToSqlite,
resolveDefaultAcpEventLedgerPath,
resolveLegacyAcpEventLedgerPath,
} from "./event-ledger.js";
describe("ACP event ledger", () => {
@@ -327,7 +327,7 @@ describe("ACP event ledger", () => {
it("imports legacy file-backed ledger state into SQLite", async () => {
await withTempDir({ prefix: "openclaw-acp-ledger-" }, async (dir) => {
const env = { ...process.env, OPENCLAW_STATE_DIR: dir };
const filePath = resolveDefaultAcpEventLedgerPath(env);
const filePath = resolveLegacyAcpEventLedgerPath(env);
await fs.mkdir(path.dirname(filePath), { recursive: true });
await fs.writeFile(
filePath,

6
src/acp/event-ledger.ts
View File

@@ -434,7 +434,7 @@ export function createInMemoryAcpEventLedger(options: LedgerOptions = {}): AcpEv
});
}
export function resolveDefaultAcpEventLedgerPath(env: NodeJS.ProcessEnv = process.env): string {
export function resolveLegacyAcpEventLedgerPath(env: NodeJS.ProcessEnv = process.env): string {
return path.join(resolveStateDir(env), "acp", "event-ledger.json");
}
@@ -535,7 +535,7 @@ function writeStoreToSqlite(
export function legacyAcpEventLedgerFileExists(env: NodeJS.ProcessEnv = process.env): boolean {
try {
return statSync(resolveDefaultAcpEventLedgerPath(env)).isFile();
return statSync(resolveLegacyAcpEventLedgerPath(env)).isFile();
} catch (error) {
if ((error as NodeJS.ErrnoException)?.code === "ENOENT") {
return false;
@@ -547,7 +547,7 @@ export function legacyAcpEventLedgerFileExists(env: NodeJS.ProcessEnv = process.
export async function importLegacyAcpEventLedgerFileToSqlite(
env: NodeJS.ProcessEnv = process.env,
): Promise<{ imported: boolean; sessions: number; events: number }> {
const filePath = resolveDefaultAcpEventLedgerPath(env);
const filePath = resolveLegacyAcpEventLedgerPath(env);
let parsed: unknown;
try {
parsed = JSON.parse(await fs.readFile(filePath, "utf8")) as unknown;