fix: enable block streaming for all providers (#684)
This commit is contained in:
@@ -12,6 +12,7 @@
|
|||||||
- Gateway: add OpenAI-compatible `/v1/chat/completions` HTTP endpoint (auth, SSE streaming, per-agent routing). (#680) — thanks @steipete.
|
- Gateway: add OpenAI-compatible `/v1/chat/completions` HTTP endpoint (auth, SSE streaming, per-agent routing). (#680) — thanks @steipete.
|
||||||
|
|
||||||
### Fixes
|
### Fixes
|
||||||
|
- Block Streaming: enable for all providers, not just Telegram. (#684) — thanks @rubyrunsstuff.
|
||||||
- Agents/System: clarify sandboxed runtime in system prompt and surface elevated availability when sandboxed.
|
- Agents/System: clarify sandboxed runtime in system prompt and surface elevated availability when sandboxed.
|
||||||
- Agents/System: add reasoning visibility hint + /reasoning and /status guidance in system prompt.
|
- Agents/System: add reasoning visibility hint + /reasoning and /status guidance in system prompt.
|
||||||
- Auto-reply: prefer `RawBody` for command/directive parsing (WhatsApp + Discord) and prevent fallback runs from clobbering concurrent session updates. (#643) — thanks @mcinteerj.
|
- Auto-reply: prefer `RawBody` for command/directive parsing (WhatsApp + Discord) and prevent fallback runs from clobbering concurrent session updates. (#643) — thanks @mcinteerj.
|
||||||
|
|||||||
@@ -590,7 +590,6 @@ export async function getReplyFromConfig(
|
|||||||
"on")
|
"on")
|
||||||
: "off";
|
: "off";
|
||||||
const providerKey = sessionCtx.Provider?.trim().toLowerCase();
|
const providerKey = sessionCtx.Provider?.trim().toLowerCase();
|
||||||
const explicitBlockStreamingEnable = opts?.disableBlockStreaming === false;
|
|
||||||
const resolvedBlockStreaming =
|
const resolvedBlockStreaming =
|
||||||
opts?.disableBlockStreaming === true
|
opts?.disableBlockStreaming === true
|
||||||
? "off"
|
? "off"
|
||||||
@@ -603,12 +602,7 @@ export async function getReplyFromConfig(
|
|||||||
agentCfg?.blockStreamingBreak === "message_end"
|
agentCfg?.blockStreamingBreak === "message_end"
|
||||||
? "message_end"
|
? "message_end"
|
||||||
: "text_end";
|
: "text_end";
|
||||||
const allowBlockStreaming =
|
const blockStreamingEnabled = resolvedBlockStreaming === "on";
|
||||||
providerKey === "telegram" || explicitBlockStreamingEnable;
|
|
||||||
const blockStreamingEnabled =
|
|
||||||
resolvedBlockStreaming === "on" &&
|
|
||||||
opts?.disableBlockStreaming !== true &&
|
|
||||||
allowBlockStreaming;
|
|
||||||
const blockReplyChunking = blockStreamingEnabled
|
const blockReplyChunking = blockStreamingEnabled
|
||||||
? resolveBlockStreamingChunking(
|
? resolveBlockStreamingChunking(
|
||||||
cfg,
|
cfg,
|
||||||
|
|||||||
Reference in New Issue
Block a user