diff --git a/src/agents/pi-embedded-runner.ts b/src/agents/pi-embedded-runner.ts index 2deec7a144e..509d62c5618 100644 --- a/src/agents/pi-embedded-runner.ts +++ b/src/agents/pi-embedded-runner.ts @@ -43,8 +43,8 @@ import { sanitizeSessionMessagesImages, } from "./pi-embedded-helpers.js"; import { - subscribeEmbeddedPiSession, type BlockReplyChunking, + subscribeEmbeddedPiSession, } from "./pi-embedded-subscribe.js"; import { extractAssistantText } from "./pi-embedded-utils.js"; import { createClawdisCodingTools } from "./pi-tools.js"; diff --git a/src/agents/pi-embedded-subscribe.ts b/src/agents/pi-embedded-subscribe.ts index 268d5c9d12f..c5a3416222e 100644 --- a/src/agents/pi-embedded-subscribe.ts +++ b/src/agents/pi-embedded-subscribe.ts @@ -266,7 +266,10 @@ export function subscribeEmbeddedPiSession(params: { return; } if (blockBuffer.length < minChars && !force) return; - while (blockBuffer.length >= minChars || (force && blockBuffer.length > 0)) { + while ( + blockBuffer.length >= minChars || + (force && blockBuffer.length > 0) + ) { const breakIdx = pickBreakIndex(blockBuffer); if (breakIdx <= 0) { if (force) { diff --git a/src/auto-reply/reply.ts b/src/auto-reply/reply.ts index 6551322d145..c866dcc6e3e 100644 --- a/src/auto-reply/reply.ts +++ b/src/auto-reply/reply.ts @@ -58,6 +58,7 @@ import { defaultRuntime } from "../runtime.js"; import { normalizeE164 } from "../utils.js"; import { resolveHeartbeatSeconds } from "../web/reconnect.js"; import { getWebAuthAgeMs, webAuthExists } from "../web/session.js"; +import { resolveTextChunkLimit, type TextChunkSurface } from "./chunk.js"; import { normalizeGroupActivation, parseActivationCommand, @@ -74,7 +75,6 @@ import { } from "./thinking.js"; import { SILENT_REPLY_TOKEN } from "./tokens.js"; import { isAudio, transcribeInboundAudio } from "./transcription.js"; -import { resolveTextChunkLimit, type TextChunkSurface } from "./chunk.js"; import type { GetReplyOptions, ReplyPayload } from "./types.js"; export type { GetReplyOptions, ReplyPayload } from "./types.js"; @@ -1125,7 +1125,9 @@ export async function getReplyFromConfig( const resolvedBlockStreaming = agentCfg?.blockStreamingDefault === "off" ? "off" : "on"; const resolvedBlockStreamingBreak = - agentCfg?.blockStreamingBreak === "message_end" ? "message_end" : "text_end"; + agentCfg?.blockStreamingBreak === "message_end" + ? "message_end" + : "text_end"; const blockStreamingEnabled = resolvedBlockStreaming === "on"; const blockReplyChunking = blockStreamingEnabled ? resolveBlockStreamingChunking(cfg, sessionCtx.Surface) diff --git a/src/auto-reply/transcription.test.ts b/src/auto-reply/transcription.test.ts index e0802eb93de..6525900b356 100644 --- a/src/auto-reply/transcription.test.ts +++ b/src/auto-reply/transcription.test.ts @@ -6,7 +6,6 @@ import { afterEach, describe, expect, it, vi } from "vitest"; vi.mock("../globals.js", () => ({ isVerbose: () => false, - shouldLogVerbose: () => false, logVerbose: vi.fn(), shouldLogVerbose: () => false, })); diff --git a/src/web/auto-reply.ts b/src/web/auto-reply.ts index 814ee72fdc9..19797a978fb 100644 --- a/src/web/auto-reply.ts +++ b/src/web/auto-reply.ts @@ -822,7 +822,8 @@ export async function monitorWebProvider( }); const resolveGroupRequireMentionFor = (conversationId: string) => { - const groupId = resolveGroupResolution(conversationId)?.id ?? conversationId; + const groupId = + resolveGroupResolution(conversationId)?.id ?? conversationId; const groupConfig = cfg.whatsapp?.groups?.[groupId]; if (typeof groupConfig?.requireMention === "boolean") { return groupConfig.requireMention;