romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: apply oxfmt formatting to new/modified files

Browse Source 
Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Apple 2026-01-28 02:11:55 +05:30
parent e9babf40aa
commit 9d75e6dc9c
4 changed files with 43 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/channels/accounts-base.ts
View File

@ -40,10 +40,7 @@ export function createAccountBase<TAccountConfig extends Record<string, unknown>
return ids[0] ?? DEFAULT_ACCOUNT_ID;
}
function resolveAccountConfig(
cfg: MoltbotConfig,
accountId: string,
): TAccountConfig | undefined {
function resolveAccountConfig(cfg: MoltbotConfig, accountId: string): TAccountConfig | undefined {
const accounts = getChannelSection(cfg)?.accounts;
if (!accounts || typeof accounts !== "object") return undefined;
return accounts[accountId] as TAccountConfig | undefined;

4
src/channels/pipeline.e2e.test.ts
View File

@ -156,9 +156,7 @@ describe("full pipeline: inbound -> routing -> agent -> reply", () => {
it("returns an error reply when the agent throws", async () => {
await withTempHome(async (home) => {
vi.mocked(runEmbeddedPiAgent).mockRejectedValue(
new Error("model rate limit exceeded"),
);
vi.mocked(runEmbeddedPiAgent).mockRejectedValue(new Error("model rate limit exceeded"));
const cfg = makeCfg(home);

11
src/channels/plugins/group-mentions.ts
View File

@ -181,7 +181,16 @@ function resolveDiscordGuildEntry(guilds: DiscordConfig["guilds"], groupSpace?:
}
function resolveDiscordChannelEntry(
channelEntries: Record<string, { requireMention?: boolean; tools?: GroupToolPolicyConfig; toolsBySender?: GroupToolPolicyBySenderConfig }> | undefined,
channelEntries:
| Record<
string,
{
requireMention?: boolean;
tools?: GroupToolPolicyConfig;
toolsBySender?: GroupToolPolicyBySenderConfig;
}
>
| undefined,
params: GroupMentionParams,
) {
if (!channelEntries || Object.keys(channelEntries).length === 0) return undefined;

44
src/memory/manager.ts
View File

@ -730,7 +730,9 @@ export class MemoryIndexManager {
} catch (err) {
try {
this.db.exec("ROLLBACK");
} catch { /* expected: db may already be closed */ }
} catch {
/* expected: db may already be closed */
}
throw err;
}
}
@ -1046,14 +1048,18 @@ export class MemoryIndexManager {
`DELETE FROM ${VECTOR_TABLE} WHERE id IN (SELECT id FROM chunks WHERE path = ? AND source = ?)`,
)
.run(stale.path, "memory");
} catch (err) { logSwallowed("memory:syncMemory:vector", err); }
} catch (err) {
logSwallowed("memory:syncMemory:vector", err);
}
this.db.prepare(`DELETE FROM chunks WHERE path = ? AND source = ?`).run(stale.path, "memory");
if (this.fts.enabled && this.fts.available) {
try {
this.db
.prepare(`DELETE FROM ${FTS_TABLE} WHERE path = ? AND source = ? AND model = ?`)
.run(stale.path, "memory", this.provider.model);
} catch (err) { logSwallowed("memory:syncMemory:fts", err); }
} catch (err) {
logSwallowed("memory:syncMemory:fts", err);
}
}
}
}
@ -1143,7 +1149,9 @@ export class MemoryIndexManager {
`DELETE FROM ${VECTOR_TABLE} WHERE id IN (SELECT id FROM chunks WHERE path = ? AND source = ?)`,
)
.run(stale.path, "sessions");
} catch (err) { logSwallowed("memory:syncSessions:vector", err); }
} catch (err) {
logSwallowed("memory:syncSessions:vector", err);
}
this.db
.prepare(`DELETE FROM chunks WHERE path = ? AND source = ?`)
.run(stale.path, "sessions");
@ -1152,7 +1160,9 @@ export class MemoryIndexManager {
this.db
.prepare(`DELETE FROM ${FTS_TABLE} WHERE path = ? AND source = ? AND model = ?`)
.run(stale.path, "sessions", this.provider.model);
} catch (err) { logSwallowed("memory:syncSessions:fts", err); }
} catch (err) {
logSwallowed("memory:syncSessions:fts", err);
}
}
}
this.pruneSessionMaps(activePaths);
@ -1406,7 +1416,9 @@ export class MemoryIndexManager {
} catch (err) {
try {
this.db.close();
} catch { /* expected: db may already be closed */ }
} catch {
/* expected: db may already be closed */
}
await this.removeIndexFiles(tempDbPath);
restoreOriginalState();
throw err;
@ -1419,7 +1431,9 @@ export class MemoryIndexManager {
if (this.fts.enabled && this.fts.available) {
try {
this.db.exec(`DELETE FROM ${FTS_TABLE}`);
} catch (err) { logSwallowed("memory:resetIndex:fts", err); }
} catch (err) {
logSwallowed("memory:resetIndex:fts", err);
}
}
this.dropVectorTable();
this.vector.dims = undefined;
@ -1631,9 +1645,7 @@ export class MemoryIndexManager {
private pruneExpiredCacheEntries(): void {
if (!this.cache.enabled) return;
const cutoffMs = Date.now() - EMBEDDING_CACHE_TTL_MS;
this.db
.prepare(`DELETE FROM ${EMBEDDING_CACHE_TABLE} WHERE updated_at < ?`)
.run(cutoffMs);
this.db.prepare(`DELETE FROM ${EMBEDDING_CACHE_TABLE} WHERE updated_at < ?`).run(cutoffMs);
}
private pruneEmbeddingCacheIfNeeded(): void {
@ -2123,14 +2135,18 @@ export class MemoryIndexManager {
`DELETE FROM ${VECTOR_TABLE} WHERE id IN (SELECT id FROM chunks WHERE path = ? AND source = ?)`,
)
.run(entry.path, options.source);
} catch (err) { logSwallowed("memory:indexFile:vector", err); }
} catch (err) {
logSwallowed("memory:indexFile:vector", err);
}
}
if (this.fts.enabled && this.fts.available) {
try {
this.db
.prepare(`DELETE FROM ${FTS_TABLE} WHERE path = ? AND source = ? AND model = ?`)
.run(entry.path, options.source, this.provider.model);
} catch (err) { logSwallowed("memory:indexFile:fts", err); }
} catch (err) {
logSwallowed("memory:indexFile:fts", err);
}
}
this.db
.prepare(`DELETE FROM chunks WHERE path = ? AND source = ?`)
@ -2167,7 +2183,9 @@ export class MemoryIndexManager {
if (vectorReady && embedding.length > 0) {
try {
this.db.prepare(`DELETE FROM ${VECTOR_TABLE} WHERE id = ?`).run(id);
} catch (err) { logSwallowed("memory:indexFile:vectorRow", err); }
} catch (err) {
logSwallowed("memory:indexFile:vectorRow", err);
}
this.db
.prepare(`INSERT INTO ${VECTOR_TABLE} (id, embedding) VALUES (?, ?)`)
.run(id, vectorToBlob(embedding));