use cloudflare turn server

main.py

@@ -15,6 +15,8 @@ from fastrtc import (
     AlgoOptions,
     SileroVadOptions,
     audio_to_bytes,
+    get_cloudflare_turn_credentials_async,
+    get_cloudflare_turn_credentials,
 )
 from transformers import (
     AutoModelForSpeechSeq2Seq,
@@ -99,6 +101,8 @@ async def transcribe(audio: tuple[int, np.ndarray]):
     )
     yield AdditionalOutputs(outputs["text"].strip())
 
+async def get_credentials():
+    return await get_cloudflare_turn_credentials_async(hf_token=os.getenv("HF_TOKEN"))
 
 logger.info("Initializing FastRTC stream")
 stream = Stream(
@@ -136,7 +140,8 @@ stream = Stream(
         gr.Textbox(label="Transcript"),
     ],
     additional_outputs_handler=lambda current, new: current + " " + new,
-    rtc_configuration=get_rtc_credentials(provider="hf") if APP_MODE == "deployed" else None,
+    rtc_configuration=get_credentials if APP_MODE == "deployed" else None,
+    server_rtc_configuration=get_cloudflare_turn_credentials(ttl=360_000) if APP_MODE == "deployed" else None,
     concurrency_limit=6
 )
 
@@ -148,10 +153,10 @@ stream.mount(app)
 async def index():
     if UI_TYPE == "base":
         html_content = open("static/index.html").read()
-    else:
+    elif UI_TYPE == "screen":
         html_content = open("static/index-screen.html").read()
     
-    rtc_config = get_rtc_credentials(provider="hf") if APP_MODE == "deployed" else None
+    rtc_config = get_credentials if APP_MODE == "deployed" else None
     return HTMLResponse(content=html_content.replace("__RTC_CONFIGURATION__", json.dumps(rtc_config)))
 
 @app.get("/transcript")