vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-08-02 03:51:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(discord): replay only unheard exact speech

Browse Source
This commit is contained in:
Vincent Koc
2026-08-02 01:33:40 +08:00
parent ab3109a598
commit 5b7fcce1bb
2 changed files with 40 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
extensions/discord/src/voice/manager.e2e.test.ts
View File

@@ -3590,7 +3590,7 @@ describe("DiscordVoiceManager", () => {
);
});
it("does not replay partially spoken exact speech after provider continuity reset", async () => {
it("replays exact speech buffered below playback preroll after continuity reset", async () => {
agentCommandMock
.mockResolvedValueOnce({ payloads: [{ text: "first answer" }] })
.mockResolvedValueOnce({ payloads: [{ text: "second answer" }] });
@@ -3598,12 +3598,50 @@ describe("DiscordVoiceManager", () => {
await manager.join({ guildId: "g1", channelId: "1001" });
const entry = getSessionEntry(manager);
const player = getLastAudioPlayer();
const bridgeParams = lastRealtimeBridgeParams();
beginSpeakerTurn(entry);
await emitFinalRealtimeUserTranscript(bridgeParams, "first question");
await vi.waitFor(() => expectUserMessageIncludes("first answer"));
bridgeParams?.audioSink?.sendAudio(Buffer.alloc(480));
expect(player.play).not.toHaveBeenCalled();
beginSpeakerTurn(entry);
await emitFinalRealtimeUserTranscript(bridgeParams, "second question");
expectUserMessageNotIncludes("second answer");
bridgeParams?.onEvent?.({ direction: "client", type: "session.continuity.reset" });
bridgeParams?.onEvent?.({ direction: "client", type: "session.continuity.reset" });
bridgeParams?.onReady?.();
expect(sentUserMessages().filter((message) => message.includes("first answer"))).toHaveLength(
2,
);
expectUserMessageNotIncludes("second answer");
bridgeParams?.onEvent?.({ direction: "server", type: "response.done" });
expect(sentUserMessages().filter((message) => message.includes("second answer"))).toHaveLength(
1,
);
});
it("does not replay exact speech after Discord playback starts", async () => {
agentCommandMock
.mockResolvedValueOnce({ payloads: [{ text: "first answer" }] })
.mockResolvedValueOnce({ payloads: [{ text: "second answer" }] });
const manager = createAgentProxyManager();
await manager.join({ guildId: "g1", channelId: "1001" });
const entry = getSessionEntry(manager);
const player = getLastAudioPlayer();
const bridgeParams = lastRealtimeBridgeParams();
beginSpeakerTurn(entry);
await emitFinalRealtimeUserTranscript(bridgeParams, "first question");
await vi.waitFor(() => expectUserMessageIncludes("first answer"));
for (let index = 0; index < 50; index += 1) {
bridgeParams?.audioSink?.sendAudio(Buffer.alloc(480));
}
expect(player.play).toHaveBeenCalledOnce();
beginSpeakerTurn(entry);
await emitFinalRealtimeUserTranscript(bridgeParams, "second question");
expectUserMessageNotIncludes("second answer");

2
extensions/discord/src/voice/realtime.ts
View File

@@ -1463,7 +1463,7 @@ export class DiscordRealtimeVoiceSession implements VoiceRealtimeSession {
this.lastControlSpeech = undefined;
this.clearProviderConsultState();
const replayExactSpeech =
this.exactSpeechResponseActive && !this.exactSpeechAudioStarted
this.exactSpeechResponseActive && !this.harness.outputActivity.snapshot().playbackStarted
? this.activeExactSpeechMessage
: undefined;
this.exactSpeechResponseActive = false;