fix: also suppress typing indicators in agent-runner during heartbeats
This commit is contained in:
@@ -221,7 +221,9 @@ export async function runReplyAgent(params: {
|
|||||||
}
|
}
|
||||||
text = stripped.text;
|
text = stripped.text;
|
||||||
}
|
}
|
||||||
await typing.startTypingOnText(text);
|
if (!opts?.isHeartbeat) {
|
||||||
|
await typing.startTypingOnText(text);
|
||||||
|
}
|
||||||
await opts.onPartialReply?.({
|
await opts.onPartialReply?.({
|
||||||
text,
|
text,
|
||||||
mediaUrls: payload.mediaUrls,
|
mediaUrls: payload.mediaUrls,
|
||||||
@@ -270,7 +272,9 @@ export async function runReplyAgent(params: {
|
|||||||
}
|
}
|
||||||
pendingStreamedPayloadKeys.add(payloadKey);
|
pendingStreamedPayloadKeys.add(payloadKey);
|
||||||
const task = (async () => {
|
const task = (async () => {
|
||||||
await typing.startTypingOnText(cleaned);
|
if (!opts?.isHeartbeat) {
|
||||||
|
await typing.startTypingOnText(cleaned);
|
||||||
|
}
|
||||||
await opts.onBlockReply?.(blockPayload);
|
await opts.onBlockReply?.(blockPayload);
|
||||||
})()
|
})()
|
||||||
.then(() => {
|
.then(() => {
|
||||||
@@ -311,7 +315,9 @@ export async function runReplyAgent(params: {
|
|||||||
}
|
}
|
||||||
text = stripped.text;
|
text = stripped.text;
|
||||||
}
|
}
|
||||||
await typing.startTypingOnText(text);
|
if (!opts?.isHeartbeat) {
|
||||||
|
await typing.startTypingOnText(text);
|
||||||
|
}
|
||||||
await opts.onToolResult?.({
|
await opts.onToolResult?.({
|
||||||
text,
|
text,
|
||||||
mediaUrls: payload.mediaUrls,
|
mediaUrls: payload.mediaUrls,
|
||||||
@@ -410,7 +416,7 @@ export async function runReplyAgent(params: {
|
|||||||
if (payload.mediaUrls && payload.mediaUrls.length > 0) return true;
|
if (payload.mediaUrls && payload.mediaUrls.length > 0) return true;
|
||||||
return false;
|
return false;
|
||||||
});
|
});
|
||||||
if (shouldSignalTyping) {
|
if (shouldSignalTyping && !opts?.isHeartbeat) {
|
||||||
await typing.startTypingLoop();
|
await typing.startTypingLoop();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user