From 3c25c93e8b86393a1ef6479115402f3af90bb16b Mon Sep 17 00:00:00 2001
From: Richard R <me@richardr.dev>
Date: Thu, 21 May 2026 16:33:55 -0600
Subject: [PATCH] tts: remove redundant route-level alignment timeout wrappers

---
 src/app/api/tts/segments/ensure/route.ts | 40 +++++-------------------
 1 file changed, 8 insertions(+), 32 deletions(-)

diff --git a/src/app/api/tts/segments/ensure/route.ts b/src/app/api/tts/segments/ensure/route.ts
index cb0dc5d..ab6d408 100644
--- a/src/app/api/tts/segments/ensure/route.ts
+++ b/src/app/api/tts/segments/ensure/route.ts
@@ -35,7 +35,6 @@ import { getCompute } from '@/lib/server/compute';
 import { getResolvedRuntimeConfig } from '@/lib/server/runtime-config';
 import { resolveTtsModelForProvider } from '@/lib/shared/tts-provider-policy';
 import { resolveSegmentAudioUrls } from '@/lib/server/tts/segment-audio-urls';
-import { getComputeTimeoutConfig } from '@openreader/compute-core/runtime/timeout-config';
 import type {
   TTSSegmentInput,
   TTSSegmentManifestItem,
@@ -46,7 +45,6 @@ import type {
 export const runtime = 'nodejs';
 export const dynamic = 'force-dynamic';
 const GENERATING_STALE_MS = 360_000;
-const SHARED_ALIGNMENT_TIMEOUT_MS = getComputeTimeoutConfig().whisperTimeoutMs;
 
 function attachDeviceIdCookie(response: NextResponse, deviceId: string | null, didCreate: boolean) {
   if (didCreate && deviceId) {
@@ -131,20 +129,6 @@ function isAbortLikeError(error: unknown): boolean {
   return /abort/i.test(message);
 }
 
-async function withTimeout<T>(promise: Promise<T>, timeoutMs: number, label: string): Promise<T> {
-  let timer: NodeJS.Timeout | null = null;
-  try {
-    return await Promise.race([
-      promise,
-      new Promise<T>((_, reject) => {
-        timer = setTimeout(() => reject(new Error(`${label} timed out after ${timeoutMs}ms`)), timeoutMs);
-      }),
-    ]);
-  } finally {
-    if (timer) clearTimeout(timer);
-  }
-}
-
 async function deleteEntryIfUnused(userId: string, segmentEntryId: string): Promise<void> {
   const stillReferenced = await db
     .select({ segmentId: ttsSegmentVariants.segmentId })
@@ -402,14 +386,10 @@ export async function POST(request: NextRequest) {
           try {
             const alignStartedAt = Date.now();
             const computeBackend = await getComputeBackend();
-            const aligned = (await withTimeout(
-              computeBackend.alignWords({
-                audioObjectKey: existing.audioKey,
-                text: segment.text,
-              }),
-              SHARED_ALIGNMENT_TIMEOUT_MS,
-              `Whisper alignment (${computeBackend.mode})`,
-            )).alignments;
+            const aligned = (await computeBackend.alignWords({
+              audioObjectKey: existing.audioKey,
+              text: segment.text,
+            })).alignments;
             stageTimings.selfHealAlignMs = Date.now() - alignStartedAt;
             alignment = aligned[0] ? { ...aligned[0], sentenceIndex: segment.original.segmentIndex } : null;
 
@@ -656,14 +636,10 @@ export async function POST(request: NextRequest) {
           failedStage = 'whisper.align';
           const alignStartedAt = Date.now();
           const computeBackend = await getComputeBackend();
-          const aligned = (await withTimeout(
-            computeBackend.alignWords({
-              audioObjectKey: audioKey,
-              text: segment.text,
-            }),
-            SHARED_ALIGNMENT_TIMEOUT_MS,
-            `Whisper alignment (${computeBackend.mode})`,
-          )).alignments;
+          const aligned = (await computeBackend.alignWords({
+            audioObjectKey: audioKey,
+            text: segment.text,
+          })).alignments;
           stageTimings.whisperAlignMs = Date.now() - alignStartedAt;
           alignment = aligned[0] ? { ...aligned[0], sentenceIndex: segment.original.segmentIndex } : null;
         } catch (alignError) {