test(voice): cover tts fallback

2026-02-25 11:21:49 -08:00
parent e3e98058b0
commit eec54ace9d
5 changed files with 84 additions and 1 deletions
@@ -2321,6 +2321,71 @@ describe('daemon tts routing integration', () => {
    const outbound = reply.mock.calls[0]?.[0] as OutboundMessage | undefined;
    expect(outbound?.attachments).toBeUndefined();
  });
+
+  it('falls back to text-only replies when tts synthesis fails', async () => {
+    vi.spyOn(AgentOrchestrator.prototype, 'process').mockResolvedValue('fallback response');
+    vi.spyOn(globalThis, 'fetch').mockRejectedValue(new Error('tts down'));
+
+    const session = {
+      id: 'telegram:tts-user-3',
+      addMessage: vi.fn(),
+      getHistory: vi.fn(() => []),
+      clear: vi.fn(),
+      replaceHistory: vi.fn(),
+      getConfig: vi.fn(() => undefined),
+      setConfig: vi.fn(),
+      deleteConfig: vi.fn(),
+    };
+
+    const router = createMessageRouter({
+      sessionManager: { getSession: vi.fn(() => session) } as unknown as MessageRouterDeps['sessionManager'],
+      modelRouter: {
+        getAvailableTiers: () => ['default'],
+        getAllLabels: () => ({ default: 'default' }),
+        getLabel: (tier: string) => tier,
+      } as unknown as MessageRouterDeps['modelRouter'],
+      systemPrompt: 'test prompt',
+      toolRegistry: { clone() { return this; }, register: vi.fn() } as unknown as MessageRouterDeps['toolRegistry'],
+      toolExecutor: {} as unknown as MessageRouterDeps['toolExecutor'],
+      config: {
+        agents: {
+          primary_tier: 'default',
+          delegation: {
+            compaction: 'default',
+            memory_extraction: 'default',
+            classification: 'default',
+            tool_summarisation: 'default',
+            complex_reasoning: 'default',
+          },
+          max_delegation_depth: 1,
+          max_iterations: 3,
+        },
+        compaction: { enabled: false },
+        models: { default: { provider: 'anthropic', model: 'claude' } },
+        tts: {
+          enabled: true,
+          enabled_channels: ['telegram'],
+          provider: {
+            type: 'custom',
+            endpoint: 'https://example.com/v1/audio/speech',
+          },
+        },
+      } as unknown as MessageRouterDeps['config'],
+    });
+
+    const reply = vi.fn(async (_message: OutboundMessage) => {});
+    await router.handler({
+      id: 'tts-3',
+      channel: 'telegram',
+      senderId: 'tts-user-3',
+      text: 'respond with fallback',
+      timestamp: Date.now(),
+    } as MessageRouterInput, reply);
+
+    const outbound = reply.mock.calls[0]?.[0] as OutboundMessage | undefined;
+    expect(outbound?.text).toBe('fallback response');
+    expect(outbound?.attachments).toBeUndefined();
+  });
 });

 describe('daemon reactions routing integration', () => {