vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-26 16:41:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: trim state persistence runtime seams

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-28 06:07:22 +00:00
parent 7206ddea6f
commit 1db1c75a98
3 changed files with 6 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
extensions/telegram/src/thread-bindings.ts
View File

@@ -11,7 +11,7 @@ import {
type SessionBindingAdapter,
type SessionBindingRecord,
} from "openclaw/plugin-sdk/conversation-runtime";
import { writeJsonAtomic } from "openclaw/plugin-sdk/infra-runtime";
import { writeJsonFileAtomically } from "openclaw/plugin-sdk/json-store";
import { normalizeAccountId } from "openclaw/plugin-sdk/routing";
import { logVerbose } from "openclaw/plugin-sdk/runtime-env";
import { resolveStateDir } from "openclaw/plugin-sdk/state-paths";
@@ -318,11 +318,7 @@ async function persistBindingsToDisk(params: {
(entry) => entry.accountId === params.accountId,
),
};
await writeJsonAtomic(resolveBindingsPath(params.accountId), payload, {
mode: 0o600,
trailingNewline: true,
ensureDirMode: 0o700,
});
await writeJsonFileAtomically(resolveBindingsPath(params.accountId), payload);
}
function listBindingsForAccount(accountId: string): TelegramThreadBindingRecord[] {

8
extensions/telegram/src/update-offset-store.ts
View File

@@ -1,7 +1,7 @@
import fs from "node:fs/promises";
import os from "node:os";
import path from "node:path";
import { writeJsonAtomic } from "openclaw/plugin-sdk/infra-runtime";
import { writeJsonFileAtomically } from "openclaw/plugin-sdk/json-store";
import { resolveStateDir } from "openclaw/plugin-sdk/state-paths";
const STORE_VERSION = 2;
@@ -116,11 +116,7 @@ export async function writeTelegramUpdateOffset(params: {
lastUpdateId: params.updateId,
botId: extractBotIdFromToken(params.botToken),
};
await writeJsonAtomic(filePath, payload, {
mode: 0o600,
trailingNewline: true,
ensureDirMode: 0o700,
});
await writeJsonFileAtomically(filePath, payload);
}
export async function deleteTelegramUpdateOffset(params: {