"""Stage Whisper — Interactive AI Theater"""
try:
from dotenv import load_dotenv; load_dotenv()
except ImportError:
pass
import gradio as gr
import os, json, time, threading, base64, re
from pathlib import Path
from PIL import Image
ELEVENLABS_API_KEY = os.environ.get("ELEVENLABS_API_KEY", "")
OPENROUTER_API_KEY = os.environ.get("OPENROUTER_API_KEY", "")
BASE = Path(__file__).parent
from core.voice_pool import VOICE_POOL
from core.tts_engine import TTSEngine
from core.image_generator import ImageGenerator
from core.character_pipeline import CharacterPipeline
import core.playwright as pw
tts = TTSEngine(api_key=ELEVENLABS_API_KEY)
img_gen = ImageGenerator(api_key=OPENROUTER_API_KEY)
char_pipe = CharacterPipeline(api_key=OPENROUTER_API_KEY, image_generator=img_gen, base_dir=BASE)
def _load_preset(name):
with open(BASE / "presets" / f"{name}.json", encoding="utf-8") as f:
return json.load(f)
PRESETS = {
"british_comedy": _load_preset("british_comedy"),
"victorian_drama": _load_preset("victorian_drama"),
"infidelity": _load_preset("infidelity"),
}
CHAR_COLORS = ["#c9a227","#7eb8c9","#c97b7e","#7ec994","#c99a7e","#a87ec9"]
def _char_color(characters, name):
for i, c in enumerate(characters):
if c["name"] == name:
return CHAR_COLORS[i % len(CHAR_COLORS)]
return CHAR_COLORS[0]
_stop_flag = threading.Event()
_client_audio_done = threading.Event()
def handle_audio_ended():
print(f"[DEBUG] handle_audio_ended triggered at {time.time()}!")
_client_audio_done.set()
_img_cache = {}
_img_lock = threading.Lock()
_audio_cache = {}
_audio_fetching = set()
_audio_lock = threading.Lock()
_is_rewriting_active = False
_active_script = None
_current_run_id = 0.0
# ── Helpers ─────────────────────────────────────────────────────
def _placeholder_path():
p = BASE / "preset_images" / "_black.png"
if not p.exists():
p.parent.mkdir(parents=True, exist_ok=True)
Image.new("RGB", (1280, 720), (0,0,0)).save(str(p))
return str(p)
ON_SPACES = os.environ.get("SPACE_ID") is not None
def _file_url(path):
if not path: return ""
# Convert path to absolute Path object to resolve relative/absolute mismatch
p_obj = Path(path)
if not p_obj.is_absolute():
abs_path = Path(BASE) / str(path).lstrip("/")
else:
abs_path = p_obj
if not abs_path.exists():
print(f"[FILE_URL] Path not found: {path} (Resolved to: {abs_path})")
return ""
ext = abs_path.suffix.lower().lstrip(".")
# Use resolve/main only for static files committed to git (sources, preset_images, presets)
is_static = any(folder in str(abs_path) for folder in ["sources", "preset_images", "presets"])
if ON_SPACES and is_static:
try:
rel_path = abs_path.relative_to(Path(BASE))
return f"https://huggingface.co/spaces/{os.environ.get('SPACE_ID')}/resolve/main/{rel_path}"
except Exception as e:
print(f"[FILE_URL] Error converting relative path for static asset: {e}")
pass
try:
with open(abs_path, "rb") as f:
data = base64.b64encode(f.read()).decode()
if ext == "mp4":
mime = "video/mp4"
elif ext == "mp3":
mime = "audio/mpeg"
else:
mime = f"image/{'png' if ext=='png' else 'jpeg'}"
return f"data:{mime};base64,{data}"
except Exception as e:
print(f"[FILE_URL] Error encoding file {abs_path}: {e}")
return ""
def _video_html():
vid_path = BASE / "sources/curtain-opening-animation.mp4"
if not vid_path.exists(): return ""
return f'
Painting scene background...
'''
src = _file_url(path) if path and Path(path).exists() else _file_url(_placeholder_path())
return f''''''
def _ensure_image_nonblocking(scene):
rel = scene.get("image_path", "")
path = str(BASE / rel.lstrip("/")) if rel else ""
with _img_lock:
if path in _img_cache: return _img_cache[path]
if path and Path(path).exists():
with _img_lock: _img_cache[path] = path
return path
if not path: return _placeholder_path()
_prefetch(scene)
return "LOADING"
def _puppet_placeholder_path():
p = BASE / "preset_images" / "_puppet_placeholder.png"
if not p.exists():
p.parent.mkdir(parents=True, exist_ok=True)
img = Image.new("RGBA", (210, 300), (0, 0, 0, 0))
from PIL import ImageDraw
draw = ImageDraw.Draw(img)
# Draw a stylized simple gold/grey puppet silhouette matching the theater theme
# Head
draw.ellipse([75, 40, 135, 100], fill=(201, 162, 39, 100), outline=(201, 162, 39, 200), width=2)
# Body/Shoulders
draw.chord([40, 110, 170, 280], 180, 360, fill=(201, 162, 39, 60), outline=(201, 162, 39, 150), width=2)
img.save(str(p))
return str(p)
def _get_puppet_html(char_name, is_left, is_active, scene_idx, dial_idx, ex_char_name=None, is_new=False, ex_dial_idx=0):
slot_name = "left" if is_left else "right"
current_html = ""
if char_name and char_name != "Director":
path = char_pipe.get_asset(char_name, scene_idx, dial_idx)
if not path:
current_html = '
'
else:
url = _file_url(path)
active_class = "active" if is_active else "inactive"
if is_new:
classes = f"{active_class} new-puppet"
onload_attr = 'onload="var self=this; setTimeout(function(){ self.classList.add(\'loaded\'); }, 50);"'
else:
classes = f"{active_class} loaded"
onload_attr = ""
current_html = f''''''
ex_html = ""
if ex_char_name and ex_char_name != "Director":
path = char_pipe.get_asset(ex_char_name, scene_idx, ex_dial_idx)
if path:
url = _file_url(path)
ex_html = f''''''
return f'''
{ex_html}
{current_html}
'''
def _dial_html(char, action, text, color, left_char=None, right_char=None, active_slot=None, scene_idx=0, dial_idx=0, typewriter_duration=None, left_ex_char=None, right_ex_char=None, left_is_new=False, right_is_new=False, left_dial_idx=0, right_dial_idx=0, left_ex_dial_idx=0, right_ex_dial_idx=0):
act = f'— {action} —
' if action else ""
unique_id = f"{scene_idx}_{dial_idx}_{int(time.time() * 1000)}"
if typewriter_duration and typewriter_duration > 0:
import html
escaped_attr = html.escape(text, quote=True)
dial_text_html = f'''
{text}
'
if not left_char and not right_char:
return f'{act}
{char}
{dial_text_html}
{left_html}
{act}
{char}
{dial_text_html}
{right_html}
{i.get("character", i.get("name", "Director"))} '
f'"{i.get("line", i.get("text", ""))}"
'
for i in history
)
return f'{rows}
'
def _ensure_image(scene):
rel = scene.get("image_path", "")
path = str(BASE / rel.lstrip("/")) if rel else ""
with _img_lock:
if path in _img_cache: return _img_cache[path]
if path and Path(path).exists():
with _img_lock: _img_cache[path] = path
return path
if not path: return _placeholder_path()
try:
Path(path).parent.mkdir(parents=True, exist_ok=True)
img_gen.generate(scene["image_prompt"], path, aspect_ratio="21:9")
with _img_lock: _img_cache[path] = path
return path
except Exception as e:
print(f"[IMG] {e}"); return _placeholder_path()
def _prefetch(scene):
rel = scene.get("image_path", "")
if not rel: return
path = str(BASE / rel.lstrip("/"))
with _img_lock:
if path in _img_cache: return
threading.Thread(target=_ensure_image, args=(scene,), daemon=True).start()
def _prefetch_single_audio(script, si, di, use_flash=False):
key = (si, di)
with _audio_lock:
if key in _audio_cache or key in _audio_fetching:
return
_audio_fetching.add(key)
def fetch():
try:
ab = _get_audio_direct(script, si, di, use_flash)
if ab:
with _audio_lock:
_audio_cache[key] = ab
except Exception as e:
print(f"[Prefetch Error] {e}")
finally:
with _audio_lock:
_audio_fetching.discard(key)
threading.Thread(target=fetch, daemon=True).start()
def _prefetch_audio(script, si, di, use_flash=False):
scenes = script.get("scenes", [])
if si >= len(scenes): return
dialogues = scenes[si].get("dialogues", [])
if isinstance(dialogues, str): dialogues = [dialogues]
# Prefetch the next 3 lines in the current scene
for offset in range(3):
curr_di = di + offset
if curr_di >= len(dialogues):
# Try to prefetch the first line of the next scene
next_si = si + 1
if next_si < len(scenes):
next_dialogues = scenes[next_si].get("dialogues", [])
if isinstance(next_dialogues, str): next_dialogues = [next_dialogues]
if next_dialogues:
_prefetch_single_audio(script, next_si, 0, use_flash)
break
_prefetch_single_audio(script, si, curr_di, use_flash)
def _get_audio_direct(script, si, di, use_flash=False):
dialogues = script["scenes"][si].get("dialogues", [])
if isinstance(dialogues, str): dialogues = [{"character": "Director", "line": dialogues}]
dl = dialogues[di]
if isinstance(dl, str): dl = {"character": "Director", "line": dl}
vid = None
char_name = dl.get("character", dl.get("name", "Unknown"))
for c in script.get("characters", []):
if c["name"] == char_name:
lbl = c.get("voice_label", "")
vid = VOICE_POOL.get(lbl)
if not vid:
fb = {"warm_british_male": "charming_rogue", "sharp_british_female": "sharp_socialite", "comedic_male": "flustered_husband", "aristocratic_female": "iron_matriarch", "nervous_male": "nervous_suitor", "gruff_male": "weary_colonel", "young_female": "mischievous_maid", "elderly_male": "eccentric_solicitor"}
vid = VOICE_POOL.get(fb.get(lbl, ""))
break
if not vid:
import hashlib
keys = list(VOICE_POOL.keys())
hash_val = int(hashlib.md5(char_name.encode()).hexdigest(), 16)
lbl = keys[hash_val % len(keys)]
vid = VOICE_POOL.get(lbl)
script.setdefault("characters", []).append({
"name": char_name,
"personality": "A newly introduced character.",
"voice_label": lbl
})
if not vid: return None
v_id = vid["id"] if isinstance(vid, dict) else vid
if not v_id or "PLACEHOLDER" in v_id: return None
line_text = dl.get("line", dl.get("text", ""))
if not line_text.strip(): return None
try:
model_id = "eleven_flash_v2_5" if use_flash else None
raw_ab = tts.speak(line_text, v_id, model_id=model_id)
if not raw_ab: return None
try:
from pydub import AudioSegment
from pydub.silence import detect_nonsilent
import io
seg = AudioSegment.from_file(io.BytesIO(raw_ab), format="mp3")
ranges = detect_nonsilent(seg, min_silence_len=250, silence_thresh=-45)
if ranges:
end_ms = min(len(seg), ranges[-1][1] + 150)
if end_ms < len(seg) - 200:
seg = seg[:end_ms]
out_io = io.BytesIO()
seg.export(out_io, format="mp3", bitrate="128k")
raw_ab = out_io.getvalue()
except Exception as e:
print(f"[Silence Trim Error] {e}")
return raw_ab
except Exception as e:
print(f"[TTS] {e}")
return None
def _get_audio(script, si, di, use_flash=False):
key = (si, di)
while True:
with _audio_lock:
if key not in _audio_fetching:
break
time.sleep(0.05)
if _stop_flag.is_set(): return None
with _audio_lock:
if key in _audio_cache: return _audio_cache[key]
ab = _get_audio_direct(script, si, di, use_flash)
with _audio_lock:
_audio_cache[key] = ab
return ab
def _audio_tmp(ab):
import hashlib
h = hashlib.md5(ab).hexdigest()
cdir = BASE / "audio_cache"
cdir.mkdir(exist_ok=True)
path = cdir / f"{h}.mp3"
if not path.exists():
with open(path, "wb") as f:
f.write(ab)
return str(path)
# ── Playback ─────────────────────────────────────────────────────
# ── Playback ─────────────────────────────────────────────────────
def _run_script(script, start_scene=0, start_dial=0, delay_start=0, use_flash=False, skip_pipeline=False):
global _current_run_id
run_id = time.time()
_current_run_id = run_id
_stop_flag.clear(); _audio_cache.clear(); _audio_fetching.clear()
if not skip_pipeline:
char_pipe.start_pipeline(script)
if delay_start > 0:
time.sleep(delay_start)
chars = script.get("characters", [])
history = []
si = start_scene
while True:
if _current_run_id != run_id or _stop_flag.is_set(): return
scenes = script.get("scenes", [])
if si >= len(scenes):
if _is_rewriting_active:
time.sleep(0.1)
continue
else:
break
scene = scenes[si]
left_char = None
right_char = None
left_ex_char = None
right_ex_char = None
last_active_slot = None
# Track last spoken dial_idx per slot
left_char_dial_idx = 0
right_char_dial_idx = 0
left_ex_dial_idx = 0
right_ex_dial_idx = 0
if _current_run_id != run_id or _stop_flag.is_set(): return
# Block until this scene's background is ready, then show it
bg_path = _ensure_image(scene)
yield (_img_html(bg_path), _dial_html("","","🎨 Setting the scene…","#7a6a4e"), _hist_html(history,chars), None, "")
if si == start_scene and delay_start > 0:
time.sleep(1.0)
else:
time.sleep(0.8)
start_d = start_dial if si == start_scene else 0
_prefetch_audio(script, si, start_d, use_flash)
di = start_d
while True:
dialogues = scene.get("dialogues", [])
if isinstance(dialogues, str):
dialogues = [{"character": "Director", "line": dialogues}]
if di >= len(dialogues):
if _is_rewriting_active:
time.sleep(0.1)
continue
else:
break
dl = dialogues[di]
if isinstance(dl, str): dl = {"character": "Director", "line": dl}
char = dl.get("character", dl.get("name", "Director"))
action = dl.get("action", "")
line = dl.get("line", dl.get("text", ""))
color = _char_color(chars, char)
# Manage Stage Slots
left_ex_char = None
right_ex_char = None
left_ex_dial_idx = 0
right_ex_dial_idx = 0
left_is_new = False
right_is_new = False
active_slot = None
if char != "Director":
if char == left_char:
active_slot = "left"
left_char_dial_idx = di
elif char == right_char:
active_slot = "right"
right_char_dial_idx = di
else:
if not left_char:
left_char = char
active_slot = "left"
left_is_new = True
left_char_dial_idx = di
elif not right_char:
right_char = char
active_slot = "right"
right_is_new = True
right_char_dial_idx = di
else:
if last_active_slot == "left":
right_ex_char = right_char
right_ex_dial_idx = right_char_dial_idx
right_char = char
active_slot = "right"
right_is_new = True
right_char_dial_idx = di
else:
left_ex_char = left_char
left_ex_dial_idx = left_char_dial_idx
left_char = char
active_slot = "left"
left_is_new = True
left_char_dial_idx = di
if active_slot:
last_active_slot = active_slot
start_time = time.time()
ab = _get_audio(script, si, di, use_flash)
if ab:
_client_audio_done.clear()
atmp = _audio_tmp(ab) if ab else None
audio_html = ""
if atmp:
audio_src = _file_url(atmp)
audio_html = f'
${messages[0]}
`;
const container = document.querySelector('.gradio-container') || document.body;
container.appendChild(div);
let idx = 0;
window.theaterLoadingInterval = setInterval(() => {
const el = document.getElementById("theater-loading-msg");
if(!el) { clearInterval(window.theaterLoadingInterval); return; }
idx = (idx + 1) % messages.length;
el.style.opacity = '0';
setTimeout(() => { el.textContent = messages[idx]; el.style.opacity = '1'; }, 400);
}, 3000);
};
window.hideTheaterLoading = () => {
if(window.theaterLoadingInterval) { clearInterval(window.theaterLoadingInterval); window.theaterLoadingInterval = null; }
const el = document.getElementById("theater-loading-overlay");
if(el) { el.style.opacity = '0'; setTimeout(() => { if(el.parentNode) el.remove(); }, 800); }
};
window.injectTitle = (titleText, noDelay = false) => {
let old = document.getElementById("native-title-overlay");
if(old) old.remove();
const div = document.createElement("div");
div.id = "native-title-overlay";
const h = window.innerHeight;
div.style.cssText = `position:absolute;top:0;left:0;width:100%;height:${h}px;z-index:99999;pointer-events:none;overflow:hidden;`;
const bgAnim = noDelay ? "nb-in 0.8s ease forwards, nb-out 0.8s ease forwards 4.0s" : "nb-in 0.8s ease forwards 2.4s, nb-out 0.8s ease forwards 6.5s";
const txtAnim = noDelay ? "nt-in 1.5s ease-out forwards 0.5s, nt-out 1.5s ease-in forwards 2.5s" : "nt-in 1.5s ease-out forwards 3.0s, nt-out 1.5s ease-in forwards 5.5s";
div.innerHTML = `
${titleText} `;
const container = document.querySelector('.gradio-container') || document.body;
container.appendChild(div);
setTimeout(() => { if(div.parentNode) div.remove(); }, noDelay ? 5500 : 7500);
};
window.injectRewriting = (...args) => {
let old = document.getElementById("native-rewriting-overlay");
if(old) old.remove();
const div = document.createElement("div");
div.id = "native-rewriting-overlay";
const h = window.innerHeight;
div.style.cssText = `position:absolute;top:0;left:0;width:100%;height:${h}px;z-index:99999;background:rgba(10,5,8,0.92);display:flex;align-items:center;justify-content:center;flex-direction:column;gap:16px;overflow:hidden;`;
div.innerHTML = `
Rewriting…
`;
const container = document.querySelector('.gradio-container') || document.body;
container.appendChild(div);
return args;
};
window.removeRewriting = (...args) => {
let old = document.getElementById("native-rewriting-overlay");
if(old) old.remove();
return args;
};
// Force Gradio's internal wrappers inside .th-wrap to not stretch
setInterval(() => {
const imgWrap = document.querySelector('.scene-img-wrap');
const lower = document.querySelector('.th-lower');
const thWrap = document.querySelector('.th-wrap');
const collapseUpToThWrap = (el) => {
let curr = el;
while (curr && curr !== thWrap && curr !== document.body) {
curr.style.setProperty('flex', 'none', 'important');
curr.style.setProperty('height', 'auto', 'important');
curr.style.setProperty('min-height', '0', 'important');
curr = curr.parentElement;
}
};
if (imgWrap) collapseUpToThWrap(imgWrap);
if (lower) {
collapseUpToThWrap(lower);
lower.style.setProperty('flex', 'none', 'important');
lower.style.setProperty('height', 'auto', 'important');
lower.style.setProperty('min-height', '0', 'important');
for (const child of lower.children) {
child.style.setProperty('flex', 'none', 'important');
child.style.setProperty('height', 'auto', 'important');
child.style.setProperty('min-height', '0', 'important');
}
}
}, 150);
setInterval(() => {
['btn-comedy', 'btn-drama', 'btn-infidelity'].forEach(id => {
const btn = document.getElementById(id);
if(btn && !btn.hasAttribute('data-vid-bound')) {
btn.setAttribute('data-vid-bound', 'true');
btn.addEventListener('click', () => {
const vid = document.getElementById('curtain-video');
if(vid) { try { vid.playbackRate = 2.5; vid.play(); } catch(e) {} }
}, true);
}
});
const tb = document.getElementById('custom-topic');
if(tb) {
const inner = tb.querySelector('textarea') || tb.querySelector('input');
if(inner && !inner.hasAttribute('data-vid-bound')) {
inner.setAttribute('data-vid-bound', 'true');
inner.addEventListener('keydown', (e) => {
if(e.key === 'Enter') {
e.preventDefault();
e.stopPropagation();
}
}, true);
}
}
}, 500);
}
"""
# ── Event handlers ───────────────────────────────────────────────
def open_theater(cur_state, preset_key, topic=""):
print(f"[DBG] open_theater: {preset_key!r}")
s = dict(cur_state)
title = topic
if preset_key:
s["script"] = PRESETS.get(preset_key)
if s["script"]:
title = s["script"].get("title", preset_key.replace('_', ' ').title())
s["current_scene"] = 0
return s, gr.Tabs(selected=1), _img_html(), _dial_html("","","The curtain rises…","#7a6a4e"), "", None, ""
def stream_preset(preset_key, cur_state):
print(f"[DBG] stream: {preset_key}")
script = PRESETS[preset_key]
_stop_flag.clear()
_client_audio_done.set()
_audio_cache.clear()
s = dict(cur_state); s["script"] = script
for img, dial, hist, audio, status in _run_script(script, delay_start=2.5):
yield s, img, dial, hist, audio, status
def stream_comedy(s): yield from stream_preset("british_comedy", s)
def stream_drama(s): yield from stream_preset("victorian_drama", s)
def stream_infidelity(s): yield from stream_preset("infidelity", s)
def stream_custom(topic, cur_state):
_stop_flag.clear()
_client_audio_done.set()
_audio_cache.clear()
s = dict(cur_state)
_PIXEL = "data:image/gif;base64,R0lGODlhAQABAIAAAAAAAP///yH5BAEAAAAALAAAAAABAAEAAAIBRAA7"
# Phase 1: Generate script
yield s, gr.skip(), gr.skip(), gr.skip(), gr.skip(), "✍️ Writing your script…"
try:
script = pw.generate_script(topic, OPENROUTER_API_KEY)
except Exception as e:
hide_trigger = f'🎭 Stage Whisper '
'Choose your drama, or write your own.
')
with gr.Row(elem_classes="pbtn-row"):
btn_comedy = gr.Button("🇬🇧 British Comedy", elem_id="btn-comedy")
btn_drama = gr.Button("🏚️ Victorian Drama", elem_id="btn-drama")
btn_infidelity = gr.Button("💔 Infidelity", elem_id="btn-infidelity")
gr.HTML('— or —
')
custom_topic = gr.Textbox(placeholder="Describe your own scenario and press Enter…",
lines=2, elem_id="custom-topic", show_label=False, submit_btn=True)
status_box = gr.HTML("", elem_id="status-box")
with gr.Tab("Theater", id=1):
with gr.Column(elem_classes="th-wrap"):
h_scene_img = gr.HTML(_img_html())
with gr.Column(elem_classes="th-lower"):
h_dial = gr.HTML(_dial_html("","","The curtain rises…","#7a6a4e"))
with gr.Row(elem_classes="ctrl-row"):
hist_btn = gr.Button("📜", elem_id="hist-btn", scale=0, min_width=44)
with gr.Column(scale=1):
mode_value = gr.Textbox(value="Director", visible=False, elem_id="mode-value")
interrupt_input = gr.Textbox(placeholder="🎬 Director's cut — what happens next?",
lines=1, elem_id="interrupt-input",
show_label=False, submit_btn=True)
h_history = gr.HTML("", elem_id="history-panel")
audio_out = gr.HTML(visible=True, elem_id="audio-out")
btn_audio_ended = gr.Textbox(visible=True, elem_id="btn-audio-ended")
btn_audio_ended.change(fn=handle_audio_ended, inputs=[], outputs=[], queue=False)
switch_outs = [state, main_tabs, h_scene_img, h_dial, h_history, audio_out, status_box]
content_outs = [state, h_scene_img, h_dial, h_history, audio_out, status_box]
btn_comedy.click(fn=lambda s: open_theater(s,"british_comedy"), inputs=[state], outputs=switch_outs, js=make_play_js(PRESETS["british_comedy"].get("title", "British Comedy")), show_progress="hidden").then(fn=stream_comedy, inputs=[state], outputs=content_outs, show_progress="hidden")
btn_drama.click( fn=lambda s: open_theater(s,"victorian_drama"), inputs=[state], outputs=switch_outs, js=make_play_js(PRESETS["victorian_drama"].get("title", "Victorian Drama")), show_progress="hidden").then(fn=stream_drama, inputs=[state], outputs=content_outs, show_progress="hidden")
btn_infidelity.click(fn=lambda s: open_theater(s,"infidelity"), inputs=[state], outputs=switch_outs, js=make_play_js(PRESETS["infidelity"].get("title", "The Glass Perimeter")), show_progress="hidden").then(fn=stream_infidelity, inputs=[state], outputs=content_outs, show_progress="hidden")
custom_topic.submit(fn=lambda s, t: open_theater(s,"",t), inputs=[state, custom_topic], outputs=switch_outs, js=make_play_js("", True), show_progress="hidden").then(fn=stream_custom, inputs=[custom_topic,state], outputs=content_outs, show_progress="hidden")
# mode is always Director
hist_btn.click(fn=None, js=OPEN_HIST_JS)
interrupt_outs = [state, interrupt_input, h_scene_img, h_dial, h_history, audio_out, status_box]
interrupt_input.submit(fn=handle_interrupt, inputs=[interrupt_input, state, interrupt_mode], outputs=interrupt_outs, js="window.injectRewriting", show_progress="hidden").then(fn=stream_interrupted, inputs=[state], outputs=content_outs, show_progress="hidden")
demo.load(None, None, None, js=JS_FIX_AUTOPLAY)
demo.queue(max_size=3).launch(allowed_paths=[str(BASE)], css=CSS)
'''
else:
dial_text_html = f'