From ad3a5f3640b977f3955dd4bd6341578ede1154ee Mon Sep 17 00:00:00 2001
From: Waleed Latif <walif6@gmail.com>
Date: Mon, 3 Aug 2026 12:07:34 -0700
Subject: [PATCH] refactor(chat): drop code the voice removal left unreachable
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Full-file cleanup pass over the files voice mode was removed from.

- /api/speech/token: with the chatId branch gone, billingAttribution is
  always resolved, so four `billingAttribution ? ... : ...` guards and
  the checkActorUsageLimits fallback were unreachable. Removed, along
  with the now-unused imports and test mock.
- chat.tsx: the inputValue state had one remaining writer (`''`) and no
  reader — ChatInput has owned its own input value since it went
  uncontrolled, and removing the voice-transcript caller left
  handleSendMessage always receiving an explicit message.
- use-chat-streaming: messageIdMap was written in three frame handlers
  and never read, and setIsStreamingResponse was returned but never
  destructured by the only consumer.
- Comments: dropped JSX section labels that restate the element beneath
  them and TSDoc that restates the identifier; narrowed the speech
  contract's workspaceId doc, which existed to contrast with the
  removed chatId field.
---
 .../(interfaces)/chat/[identifier]/chat.tsx   | 11 +---------
 .../chat/components/input/input.tsx           |  7 -------
 .../chat/hooks/use-chat-streaming.ts          | 12 -----------
 apps/sim/app/api/speech/token/route.test.ts   |  7 -------
 apps/sim/app/api/speech/token/route.ts        | 20 ++++---------------
 apps/sim/lib/api/contracts/media/speech.ts    |  2 +-
 apps/sim/lib/core/config/env.ts               |  2 +-
 apps/sim/lib/speech/config.ts                 |  6 +-----
 8 files changed, 8 insertions(+), 59 deletions(-)

diff --git a/apps/sim/app/(interfaces)/chat/[identifier]/chat.tsx b/apps/sim/app/(interfaces)/chat/[identifier]/chat.tsx
index 2d896898f9d..0685f106822 100644
--- a/apps/sim/app/(interfaces)/chat/[identifier]/chat.tsx
+++ b/apps/sim/app/(interfaces)/chat/[identifier]/chat.tsx
@@ -39,9 +39,6 @@ interface ChatRequestPayload {
   files?: ChatRequestFile[]
 }
 
-/**
- * Converts a File object to a base64 data URL
- */
 function fileToBase64(file: File): Promise<string> {
   return new Promise((resolve, reject) => {
     const reader = new FileReader()
@@ -53,7 +50,6 @@ function fileToBase64(file: File): Promise<string> {
 
 export default function ChatClient({ identifier }: { identifier: string }) {
   const [messages, setMessages] = useState<ChatMessage[]>([])
-  const [inputValue, setInputValue] = useState('')
   const [isLoading, setIsLoading] = useState(false)
   const messagesEndRef = useRef<HTMLDivElement>(null)
   const messagesContainerRef = useRef<HTMLDivElement>(null)
@@ -164,7 +160,7 @@ export default function ChatClient({ identifier }: { identifier: string }) {
   }, [chatConfig, authRequired])
 
   const handleSendMessage = async (
-    messageParam?: string,
+    messageToSend: string,
     files?: Array<{
       id: string
       name: string
@@ -174,7 +170,6 @@ export default function ChatClient({ identifier }: { identifier: string }) {
       dataUrl?: string
     }>
   ) => {
-    const messageToSend = messageParam ?? inputValue
     if ((!messageToSend.trim() && (!files || files.length === 0)) || isLoading) return
 
     logger.info('Sending message:', {
@@ -201,7 +196,6 @@ export default function ChatClient({ identifier }: { identifier: string }) {
     }
 
     setMessages((prev) => [...prev, userMessage])
-    setInputValue('')
     setIsLoading(true)
 
     setTimeout(() => {
@@ -322,10 +316,8 @@ export default function ChatClient({ identifier }: { identifier: string }) {
   return (
     <div className='light desktop-title-bar-page fixed inset-0 z-[100] flex flex-col bg-[var(--bg)] text-[var(--text-primary)]'>
       <DesktopTitleBarLane />
-      {/* Header component */}
       <ChatHeader chatConfig={chatConfig} starCount={starCount} />
 
-      {/* Message Container component */}
       <ChatMessageContainer
         messages={displayMessages}
         isLoading={isLoading}
@@ -337,7 +329,6 @@ export default function ChatClient({ identifier }: { identifier: string }) {
         chatConfig={chatConfig}
       />
 
-      {/* Input area (free-standing at the bottom) */}
       <div className='relative p-3 pb-4 md:p-4 md:pb-6'>
         <div className='relative mx-auto max-w-3xl md:max-w-[748px]'>
           <ChatInput
diff --git a/apps/sim/app/(interfaces)/chat/components/input/input.tsx b/apps/sim/app/(interfaces)/chat/components/input/input.tsx
index 49d18f47fd2..43d4e9c6ba5 100644
--- a/apps/sim/app/(interfaces)/chat/components/input/input.tsx
+++ b/apps/sim/app/(interfaces)/chat/components/input/input.tsx
@@ -134,7 +134,6 @@ export const ChatInput: React.FC<{
     <Tooltip.Provider>
       <div className='fixed right-0 bottom-0 left-0 flex w-full items-center justify-center bg-gradient-to-t from-[var(--bg)] to-transparent px-4 pb-4 md:px-0 md:pb-4'>
         <div className='w-full max-w-3xl md:max-w-[748px]'>
-          {/* Error Messages */}
           {uploadErrors.length > 0 && (
             <div className='mb-3 flex flex-col gap-2'>
               {uploadErrors.map((error, idx) => (
@@ -145,7 +144,6 @@ export const ChatInput: React.FC<{
             </div>
           )}
 
-          {/* Input container */}
           <div
             role='group'
             aria-label='Chat message input'
@@ -180,7 +178,6 @@ export const ChatInput: React.FC<{
               if (!isStreaming) handleFileSelect(e.dataTransfer.files)
             }}
           >
-            {/* File thumbnails */}
             {attachedFiles.length > 0 && (
               <div className='mb-1.5 flex flex-wrap gap-1.5'>
                 {attachedFiles.map((file) => (
@@ -221,7 +218,6 @@ export const ChatInput: React.FC<{
               </div>
             )}
 
-            {/* Textarea */}
             <textarea
               ref={textareaRef}
               value={inputValue}
@@ -232,9 +228,7 @@ export const ChatInput: React.FC<{
               className='m-0 h-auto min-h-[24px] w-full resize-none overflow-y-auto overflow-x-hidden border-0 bg-transparent p-1 text-[15px] text-[var(--text-primary)] leading-[24px] caret-[var(--text-primary)] outline-none [-ms-overflow-style:none] [scrollbar-width:none] placeholder:text-[var(--text-muted)] focus-visible:ring-0 focus-visible:ring-offset-0 [&::-webkit-scrollbar]:hidden'
             />
 
-            {/* Bottom row */}
             <div className='flex items-center justify-between'>
-              {/* Left: attach */}
               <div>
                 <Tooltip.Root>
                   <Tooltip.Trigger asChild>
@@ -266,7 +260,6 @@ export const ChatInput: React.FC<{
                 />
               </div>
 
-              {/* Right: send */}
               <div className='flex items-center gap-1.5'>
                 {isStreaming ? (
                   <Button
diff --git a/apps/sim/app/(interfaces)/chat/hooks/use-chat-streaming.ts b/apps/sim/app/(interfaces)/chat/hooks/use-chat-streaming.ts
index 5a366b46a5f..d4e9b8d1f09 100644
--- a/apps/sim/app/(interfaces)/chat/hooks/use-chat-streaming.ts
+++ b/apps/sim/app/(interfaces)/chat/hooks/use-chat-streaming.ts
@@ -146,7 +146,6 @@ export function useChatStreaming() {
     logger.info('[useChatStreaming] handleStreamedResponse called')
     setIsStreamingResponse(true)
 
-    // Prefer a shared controller from the caller (fetch + reader). Otherwise create one.
     if (streamingOptions?.abortController) {
       abortControllerRef.current = streamingOptions.abortController
     } else if (!abortControllerRef.current) {
@@ -181,7 +180,6 @@ export function useChatStreaming() {
       accumulatedToolCallsRef.current = snapshotToolCalls(toolCallOrder, toolCallsMap) ?? []
     }
 
-    const messageIdMap = new Map<string, string>()
     const messageId = generateId()
 
     const UI_BATCH_MAX_MS = 50
@@ -328,9 +326,6 @@ export function useChatStreaming() {
           }
 
           if (isChatThinkingFrame(json)) {
-            if (!messageIdMap.has(json.blockId)) {
-              messageIdMap.set(json.blockId, messageId)
-            }
             accumulatedThinking += json.data
             accumulatedThinkingRef.current = accumulatedThinking
             isThinkingStreaming = true
@@ -341,9 +336,6 @@ export function useChatStreaming() {
 
           if (isChatToolFrame(json)) {
             const { blockId } = json
-            if (!messageIdMap.has(blockId)) {
-              messageIdMap.set(blockId, messageId)
-            }
             // Tools starting means the turn's thinking phase is over — settle
             // the thinking chrome (it re-opens if more thinking streams later).
             if (json.phase === 'start' && isThinkingStreaming) {
@@ -546,9 +538,6 @@ export function useChatStreaming() {
           // Answer text only — never append thinking/tool/unknown chunk frames blindly.
           if (isChatChunkFrame(json)) {
             const { blockId, chunk: contentChunk } = json
-            if (!messageIdMap.has(blockId)) {
-              messageIdMap.set(blockId, messageId)
-            }
 
             // First answer chunk settles thinking chrome (still visible, no longer “live”).
             if (isThinkingStreaming) {
@@ -652,7 +641,6 @@ export function useChatStreaming() {
 
   return {
     isStreamingResponse,
-    setIsStreamingResponse,
     abortControllerRef,
     stopStreaming,
     handleStreamedResponse,
diff --git a/apps/sim/app/api/speech/token/route.test.ts b/apps/sim/app/api/speech/token/route.test.ts
index 218af7fb1e4..2042c24ec22 100644
--- a/apps/sim/app/api/speech/token/route.test.ts
+++ b/apps/sim/app/api/speech/token/route.test.ts
@@ -12,7 +12,6 @@ import { afterAll, beforeEach, describe, expect, it, vi } from 'vitest'
 
 const {
   mockRecordUsage,
-  mockCheckActorUsageLimits,
   mockVerifyWorkspaceMembership,
   mockResolveBillingAttribution,
   mockCheckAttributedUsageLimits,
@@ -20,7 +19,6 @@ const {
   mockCheckAndBillPayerOverageThreshold,
 } = vi.hoisted(() => ({
   mockRecordUsage: vi.fn(),
-  mockCheckActorUsageLimits: vi.fn(),
   mockVerifyWorkspaceMembership: vi.fn(),
   mockResolveBillingAttribution: vi.fn(),
   mockCheckAttributedUsageLimits: vi.fn(),
@@ -36,10 +34,6 @@ vi.mock('@/lib/billing/core/billing-attribution', () => ({
   toBillingContext: mockToBillingContext,
 }))
 
-vi.mock('@/lib/billing/calculations/usage-monitor', () => ({
-  checkActorUsageLimits: mockCheckActorUsageLimits,
-}))
-
 vi.mock('@/lib/billing/threshold-billing', () => ({
   checkAndBillPayerOverageThreshold: mockCheckAndBillPayerOverageThreshold,
 }))
@@ -64,7 +58,6 @@ beforeEach(() => {
   setEnv({ ELEVENLABS_API_KEY: 'test-key' })
   mockGetSession.mockResolvedValue({ user: { id: 'member-1' } })
   mockRecordUsage.mockResolvedValue(undefined)
-  mockCheckActorUsageLimits.mockResolvedValue({ isExceeded: false })
   mockCheckAttributedUsageLimits.mockResolvedValue({ isExceeded: false })
   mockResolveBillingAttribution.mockImplementation(
     ({ actorUserId, workspaceId }: { actorUserId: string; workspaceId: string }) => ({
diff --git a/apps/sim/app/api/speech/token/route.ts b/apps/sim/app/api/speech/token/route.ts
index f659bf8fc49..2c77a71dbc7 100644
--- a/apps/sim/app/api/speech/token/route.ts
+++ b/apps/sim/app/api/speech/token/route.ts
@@ -5,9 +5,7 @@ import { type NextRequest, NextResponse } from 'next/server'
 import { speechTokenBodySchema } from '@/lib/api/contracts/media/speech'
 import { parseOptionalJsonBody } from '@/lib/api/server'
 import { getSession } from '@/lib/auth'
-import { checkActorUsageLimits } from '@/lib/billing/calculations/usage-monitor'
 import {
-  type BillingAttributionSnapshot,
   checkAttributedUsageLimits,
   resolveBillingAttribution,
   toBillingContext,
@@ -55,7 +53,6 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
     const body = speechTokenBodySchema.safeParse(parsedBody.data ?? {})
 
     let workspaceId: string | undefined
-    let billingAttribution: BillingAttributionSnapshot | undefined
 
     const session = await getSession()
     if (!session?.user?.id) {
@@ -80,12 +77,7 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
       return NextResponse.json({ error: 'Workspace context is required.' }, { status: 400 })
     }
 
-    if (!billingAttribution) {
-      billingAttribution = await resolveBillingAttribution({
-        actorUserId,
-        workspaceId,
-      })
-    }
+    const billingAttribution = await resolveBillingAttribution({ actorUserId, workspaceId })
 
     if (isBillingEnabled) {
       const rateCheck = await rateLimiter.checkRateLimitDirect(
@@ -115,9 +107,7 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
      * and rate limited per user, so the overshoot is a knowable ceiling against
      * an identified payer.
      */
-    const usageCheck = billingAttribution
-      ? await checkAttributedUsageLimits(billingAttribution)
-      : await checkActorUsageLimits(actorUserId)
+    const usageCheck = await checkAttributedUsageLimits(billingAttribution)
     if (usageCheck.isExceeded) {
       return NextResponse.json(
         {
@@ -158,7 +148,7 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
       await recordUsage({
         userId: actorUserId,
         workspaceId,
-        ...(billingAttribution ? toBillingContext(billingAttribution) : {}),
+        ...toBillingContext(billingAttribution),
         entries: [
           {
             category: 'fixed',
@@ -169,9 +159,7 @@ export const POST = withRouteHandler(async (request: NextRequest) => {
           },
         ],
       })
-      if (billingAttribution) {
-        await checkAndBillPayerOverageThreshold(billingAttribution.billingEntity)
-      }
+      await checkAndBillPayerOverageThreshold(billingAttribution.billingEntity)
     } catch (err) {
       logger.warn('Failed to record voice input usage, continuing:', err)
     }
diff --git a/apps/sim/lib/api/contracts/media/speech.ts b/apps/sim/lib/api/contracts/media/speech.ts
index 40461bc5470..79c2918ad6b 100644
--- a/apps/sim/lib/api/contracts/media/speech.ts
+++ b/apps/sim/lib/api/contracts/media/speech.ts
@@ -3,7 +3,7 @@ import { defineRouteContract } from '@/lib/api/contracts/types'
 
 export const speechTokenBodySchema = z
   .object({
-    /** Editor/workspace voice: the workspace the session user is recording in. */
+    /** Workspace the session user is recording in. */
     workspaceId: z.string().optional(),
   })
   .passthrough()
diff --git a/apps/sim/lib/core/config/env.ts b/apps/sim/lib/core/config/env.ts
index eb79f5fc0d4..a2decad9680 100644
--- a/apps/sim/lib/core/config/env.ts
+++ b/apps/sim/lib/core/config/env.ts
@@ -183,7 +183,7 @@ export const env = createEnv({
     COHERE_API_KEY_1:                      z.string().min(1).optional(),           // Primary Cohere API key for rotation
     COHERE_API_KEY_2:                      z.string().min(1).optional(),           // Additional Cohere API key for load balancing
     COHERE_API_KEY_3:                      z.string().min(1).optional(),           // Additional Cohere API key for load balancing
-    ELEVENLABS_API_KEY:                    z.string().min(1).optional(),           // ElevenLabs API key for workspace speech-to-text          
+    ELEVENLABS_API_KEY:                    z.string().min(1).optional(),           // ElevenLabs API key for workspace speech-to-text
     SERPER_API_KEY:                        z.string().min(1).optional(),           // Serper API key for online search
     EXA_API_KEY:                           z.string().min(1).optional(),           // Exa AI API key for enhanced online search
     BLACKLISTED_PROVIDERS:                 z.string().optional(),                  // Comma-separated provider IDs to hide (e.g., "openai,anthropic")
diff --git a/apps/sim/lib/speech/config.ts b/apps/sim/lib/speech/config.ts
index 4e7a831a63b..ec9372cc23d 100644
--- a/apps/sim/lib/speech/config.ts
+++ b/apps/sim/lib/speech/config.ts
@@ -5,11 +5,7 @@ export const SAMPLE_RATE = 16000
 export const CHUNK_SEND_INTERVAL_MS = 250
 export const MAX_SESSION_MS = 3 * 60 * 1000
 
-/**
- * Whether a speech-to-text provider is configured.
- * Currently checks for `ELEVENLABS_API_KEY`.
- * To add a new provider: add its env check here.
- */
+/** Whether a speech-to-text provider is configured. Add new providers' env checks here. */
 export function hasSTTService(): boolean {
   return !!env.ELEVENLABS_API_KEY?.trim()
 }