From 9d75e6dc9c083890c2b109cdf4ec11968b1151ac Mon Sep 17 00:00:00 2001 From: Apple Date: Wed, 28 Jan 2026 02:11:55 +0530 Subject: [PATCH] style: apply oxfmt formatting to new/modified files Co-Authored-By: Claude Opus 4.5 --- src/channels/accounts-base.ts | 5 +-- src/channels/pipeline.e2e.test.ts | 4 +-- src/channels/plugins/group-mentions.ts | 11 ++++++- src/memory/manager.ts | 44 ++++++++++++++++++-------- 4 files changed, 43 insertions(+), 21 deletions(-) diff --git a/src/channels/accounts-base.ts b/src/channels/accounts-base.ts index bb85677fd..9b40f063c 100644 --- a/src/channels/accounts-base.ts +++ b/src/channels/accounts-base.ts @@ -40,10 +40,7 @@ export function createAccountBase 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; diff --git a/src/channels/pipeline.e2e.test.ts b/src/channels/pipeline.e2e.test.ts index 49b4eae95..2d63a7b0f 100644 --- a/src/channels/pipeline.e2e.test.ts +++ b/src/channels/pipeline.e2e.test.ts @@ -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); diff --git a/src/channels/plugins/group-mentions.ts b/src/channels/plugins/group-mentions.ts index 1231e4c6e..0e9829724 100644 --- a/src/channels/plugins/group-mentions.ts +++ b/src/channels/plugins/group-mentions.ts @@ -181,7 +181,16 @@ function resolveDiscordGuildEntry(guilds: DiscordConfig["guilds"], groupSpace?: } function resolveDiscordChannelEntry( - channelEntries: Record | undefined, + channelEntries: + | Record< + string, + { + requireMention?: boolean; + tools?: GroupToolPolicyConfig; + toolsBySender?: GroupToolPolicyBySenderConfig; + } + > + | undefined, params: GroupMentionParams, ) { if (!channelEntries || Object.keys(channelEntries).length === 0) return undefined; diff --git a/src/memory/manager.ts b/src/memory/manager.ts index c4b732ca8..377814976 100644 --- a/src/memory/manager.ts +++ b/src/memory/manager.ts @@ -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));