add: support for flac

whisper_fastapi.py

@@ -1,10 +1,11 @@
 import wave
+import pydub
 import io
 import hashlib
 import argparse
 import uvicorn
-from typing import Any, Literal
-from fastapi import File, UploadFile, Form, FastAPI, Request, WebSocket, Response
+from typing import Annotated, Any, Literal
+from fastapi import File, Query, UploadFile, Form, FastAPI, Request, WebSocket, Response
 from fastapi.middleware.cors import CORSMiddleware
 from src.whisper_ctranslate2.whisper_ctranslate2 import Transcribe, TranscriptionOptions
 from src.whisper_ctranslate2.writers import format_timestamp
@@ -126,9 +127,15 @@ async def konele_ws(
     task: Literal["transcribe", "translate"] = "transcribe",
     lang: str = "und",
     initial_prompt: str = "",
+    content_type: Annotated[str, Query(alias="content-type")] = "audio/x-raw",
 ):
     await websocket.accept()
+
+    # convert lang code format (eg. en-US to en)
+    lang = lang.split("-")[0]
+
     print("WebSocket client connected, lang is", lang)
+    print("content-type is", content_type)
     data = b""
     while True:
         try:
@@ -145,11 +152,17 @@ async def konele_ws(
     # create fake file for wave.open
     file_obj = io.BytesIO()
 
-    buffer = wave.open(file_obj, "wb")
-    buffer.setnchannels(1)
-    buffer.setsampwidth(2)
-    buffer.setframerate(16000)
-    buffer.writeframes(data)
+    if content_type.startswith("audio/x-flac"):
+        pydub.AudioSegment.from_file(io.BytesIO(data), format="flac").export(
+            file_obj, format="wav"
+        )
+    else:
+        buffer = wave.open(file_obj, "wb")
+        buffer.setnchannels(1)
+        buffer.setsampwidth(2)
+        buffer.setframerate(16000)
+        buffer.writeframes(data)
+
     file_obj.seek(0)
 
     options = get_options(initial_prompt=initial_prompt)
@@ -187,6 +200,10 @@ async def translateapi(
 ):
     content_type = request.headers.get("Content-Type", "")
     print("downloading request file", content_type)
+
+    # convert lang code format (eg. en-US to en)
+    lang = lang.split("-")[0]
+
     splited = [i.strip() for i in content_type.split(",") if "=" in i]
     info = {k: v for k, v in (i.split("=") for i in splited)}
     print(info)
@@ -200,11 +217,17 @@ async def translateapi(
     # create fake file for wave.open
     file_obj = io.BytesIO()
 
-    buffer = wave.open(file_obj, "wb")
-    buffer.setnchannels(channels)
-    buffer.setsampwidth(2)
-    buffer.setframerate(rate)
-    buffer.writeframes(body)
+    if content_type.startswith("audio/x-flac"):
+        pydub.AudioSegment.from_file(io.BytesIO(body), format="flac").export(
+            file_obj, format="wav"
+        )
+    else:
+        buffer = wave.open(file_obj, "wb")
+        buffer.setnchannels(channels)
+        buffer.setsampwidth(2)
+        buffer.setframerate(rate)
+        buffer.writeframes(body)
+
     file_obj.seek(0)
 
     options = get_options(initial_prompt=initial_prompt)