refactor(api): reorganize STT providers into directory structure

apps/api/src/stt/batch-assemblyai.ts → apps/api/src/stt/assemblyai/batch.ts

@@ -1,12 +1,12 @@
-import { env } from "../env";
+import { env } from "../../env";
 import type {
   BatchAlternatives,
   BatchChannel,
   BatchParams,
   BatchResponse,
   BatchResults,
   BatchWord,
-} from "./batch-types";
+} from "../batch-types";
 
 const ASSEMBLYAI_API_URL = "https://api.assemblyai.com/v2";
 const POLL_INTERVAL_MS = 3000;

apps/api/src/stt/assemblyai/index.ts

@@ -0,0 +1,2 @@
+export { buildAssemblyAIUrl, createAssemblyAIProxy } from "./live";
+export { transcribeWithAssemblyAI } from "./batch";

apps/api/src/stt/assemblyai.ts → apps/api/src/stt/assemblyai/live.ts

@@ -1,5 +1,5 @@
-import { env } from "../env";
-import { WsProxyConnection } from "./connection";
+import { env } from "../../env";
+import { WsProxyConnection } from "../connection";
 
 const CONTROL_MESSAGE_TYPES = new Set(["Terminate"]);
 

apps/api/src/stt/batch-deepgram.ts → apps/api/src/stt/deepgram/batch.ts

@@ -1,5 +1,5 @@
-import { env } from "../env";
-import type { BatchParams, BatchResponse } from "./batch-types";
+import { env } from "../../env";
+import type { BatchParams, BatchResponse } from "../batch-types";
 
 const DEEPGRAM_BATCH_URL = "https://api.deepgram.com/v1/listen";
 

apps/api/src/stt/deepgram/index.ts

@@ -0,0 +1,2 @@
+export { buildDeepgramUrl, createDeepgramProxy } from "./live";
+export { transcribeWithDeepgram } from "./batch";

apps/api/src/stt/deepgram.ts → apps/api/src/stt/deepgram/live.ts

@@ -1,5 +1,5 @@
-import { env } from "../env";
-import { WsProxyConnection } from "./connection";
+import { env } from "../../env";
+import { WsProxyConnection } from "../connection";
 
 const CONTROL_MESSAGE_TYPES = new Set(["KeepAlive", "CloseStream", "Finalize"]);
 

apps/api/src/stt/index.ts

@@ -1,21 +1,27 @@
-import { createAssemblyAIProxy } from "./assemblyai";
-import { transcribeWithAssemblyAI } from "./batch-assemblyai";
-import { transcribeWithDeepgram } from "./batch-deepgram";
-import { transcribeWithSoniox } from "./batch-soniox";
+import { createAssemblyAIProxy, transcribeWithAssemblyAI } from "./assemblyai";
 import type { BatchParams, BatchProvider, BatchResponse } from "./batch-types";
 import { WsProxyConnection } from "./connection";
-import { createDeepgramProxy } from "./deepgram";
-import { createSonioxProxy } from "./soniox";
+import { createDeepgramProxy, transcribeWithDeepgram } from "./deepgram";
+import { createSonioxProxy, transcribeWithSoniox } from "./soniox";
 
 export { WsProxyConnection, type WsProxyOptions } from "./connection";
 export { normalizeWsData, type WsPayload } from "./utils";
-export { buildDeepgramUrl, createDeepgramProxy } from "./deepgram";
-export { buildAssemblyAIUrl, createAssemblyAIProxy } from "./assemblyai";
-export { buildSonioxUrl, createSonioxProxy } from "./soniox";
+export {
+  buildDeepgramUrl,
+  createDeepgramProxy,
+  transcribeWithDeepgram,
+} from "./deepgram";
+export {
+  buildAssemblyAIUrl,
+  createAssemblyAIProxy,
+  transcribeWithAssemblyAI,
+} from "./assemblyai";
+export {
+  buildSonioxUrl,
+  createSonioxProxy,
+  transcribeWithSoniox,
+} from "./soniox";
 export type { BatchParams, BatchProvider, BatchResponse } from "./batch-types";
-export { transcribeWithDeepgram } from "./batch-deepgram";
-export { transcribeWithAssemblyAI } from "./batch-assemblyai";
-export { transcribeWithSoniox } from "./batch-soniox";
 
 export const UPSTREAM_URL_HEADER = "x-owh-upstream-url";
 export const UPSTREAM_AUTH_HEADER = "x-owh-upstream-auth";

apps/api/src/stt/batch-soniox.ts → apps/api/src/stt/soniox/batch.ts

@@ -1,12 +1,12 @@
-import { env } from "../env";
+import { env } from "../../env";
 import type {
   BatchAlternatives,
   BatchChannel,
   BatchParams,
   BatchResponse,
   BatchResults,
   BatchWord,
-} from "./batch-types";
+} from "../batch-types";
 
 const SONIOX_API_HOST = "api.soniox.com";
 const POLL_INTERVAL_MS = 3000;

apps/api/src/stt/soniox/index.ts

@@ -0,0 +1,2 @@
+export { buildSonioxUrl, createSonioxProxy } from "./live";
+export { transcribeWithSoniox } from "./batch";

apps/api/src/stt/soniox.ts → apps/api/src/stt/soniox/live.ts

@@ -1,5 +1,5 @@
-import { env } from "../env";
-import { WsProxyConnection } from "./connection";
+import { env } from "../../env";
+import { WsProxyConnection } from "../connection";
 
 const CONTROL_MESSAGE_TYPES = new Set(["keepalive", "finalize"]);