commit 9455b591dea941d1dbec3e85aa4ec8fd18102d0a
Author: sal <shinalok357@gmail.com>
Date:   Sat May 30 22:09:53 2026 +0900

    Add initial implementation of Youlbot WebUI with Gradio frontend

diff --git a/api_client.py b/api_client.py
new file mode 100644
index 0000000..9e4f74e
--- /dev/null
+++ b/api_client.py
@@ -0,0 +1,112 @@
+"""율봇 API 클라이언트 — youlbot REST API(Phase 22)를 httpx로 호출."""
+import json
+import os
+from typing import AsyncIterator
+
+import httpx
+from dotenv import load_dotenv
+
+load_dotenv()
+
+_API_URL = os.getenv("YOULBOT_API_URL", "http://localhost:8000").rstrip("/")
+_API_TOKEN = os.getenv("YOULBOT_API_TOKEN", "")
+
+
+def _headers() -> dict:
+    if _API_TOKEN:
+        return {"Authorization": f"Bearer {_API_TOKEN}"}
+    return {}
+
+
+async def chat(
+    message: str,
+    user_id: str = "default",
+    show_thinking: bool = False,
+) -> AsyncIterator[tuple[str, str | None]]:
+    """SSE 스트림을 읽어 (token, run_id) 튜플을 yield.
+
+    - 일반 토큰: (token_str, None)
+    - 스트림 종료: ("", run_id_or_None)  ← __done 이벤트
+    """
+    async with httpx.AsyncClient(timeout=180) as client:
+        async with client.stream(
+            "POST",
+            f"{_API_URL}/chat",
+            json={"message": message, "user_id": user_id, "show_thinking": show_thinking},
+            headers=_headers(),
+        ) as response:
+            response.raise_for_status()
+            async for line in response.aiter_lines():
+                if not line.startswith("data: "):
+                    continue
+                raw = line[6:]
+                try:
+                    payload = json.loads(raw)
+                except json.JSONDecodeError:
+                    yield raw, None
+                    continue
+                if isinstance(payload, dict) and payload.get("__done"):
+                    yield "", payload.get("run_id")
+                    return
+                yield payload, None
+
+
+async def reset(user_id: str = "default") -> None:
+    async with httpx.AsyncClient(timeout=30) as client:
+        r = await client.post(
+            f"{_API_URL}/reset",
+            params={"user_id": user_id},
+            headers=_headers(),
+        )
+        r.raise_for_status()
+
+
+async def ingest(file_path: str) -> dict:
+    async with httpx.AsyncClient(timeout=300) as client:
+        with open(file_path, "rb") as f:
+            filename = os.path.basename(file_path)
+            r = await client.post(
+                f"{_API_URL}/ingest",
+                files={"file": (filename, f, "application/octet-stream")},
+                headers=_headers(),
+            )
+        r.raise_for_status()
+        return r.json()
+
+
+async def list_documents() -> list[str]:
+    async with httpx.AsyncClient(timeout=30) as client:
+        r = await client.get(f"{_API_URL}/documents", headers=_headers())
+        r.raise_for_status()
+        return r.json().get("documents", [])
+
+
+async def delete_document(source: str) -> None:
+    async with httpx.AsyncClient(timeout=30) as client:
+        r = await client.delete(
+            f"{_API_URL}/documents/{source}",
+            headers=_headers(),
+        )
+        r.raise_for_status()
+
+
+async def save_feedback(
+    user_id: str,
+    user_msg: str,
+    asst_msg: str,
+    rating: int,
+    run_id: str | None = None,
+) -> None:
+    async with httpx.AsyncClient(timeout=30) as client:
+        r = await client.post(
+            f"{_API_URL}/feedback",
+            json={
+                "user_id": user_id,
+                "user_msg": user_msg,
+                "asst_msg": asst_msg,
+                "rating": rating,
+                "run_id": run_id,
+            },
+            headers=_headers(),
+        )
+        r.raise_for_status()
diff --git a/app.py b/app.py
new file mode 100644
index 0000000..4a3a3fd
--- /dev/null
+++ b/app.py
@@ -0,0 +1,276 @@
+"""율봇 WebUI — youlbot REST API를 호출하는 Gradio 프론트엔드.
+
+실행:
+    python app.py
+
+환경변수 (.env):
+    YOULBOT_API_URL=http://localhost:8000
+    YOULBOT_API_TOKEN=           ← api.py에 API_TOKEN 설정 시 동일 값
+"""
+import asyncio
+import os
+import subprocess
+import tempfile
+
+import gradio as gr
+from dotenv import load_dotenv
+
+load_dotenv()
+
+import api_client
+
+USER_LABELS = ["아록", "근혜", "도율", "하율"]
+DEFAULT_USER = "아록"
+
+# ── STT (Whisper) — 로컬 실행 유지 ──────────────────────────────
+_whisper_model = None
+_WHISPER_SIZE = os.getenv("WHISPER_MODEL_SIZE", "small")
+_TTS_VOICE = os.getenv("TTS_VOICE", "Yuna")
+
+
+def _get_whisper():
+    global _whisper_model
+    if _whisper_model is None:
+        import whisper
+        _whisper_model = whisper.load_model(_WHISPER_SIZE)
+    return _whisper_model
+
+
+def transcribe_audio(filepath: str) -> str:
+    if not filepath:
+        return ""
+    model = _get_whisper()
+    result = model.transcribe(filepath, language="ko")
+    return result["text"].strip()
+
+
+def tts_speak(text: str) -> str | None:
+    """macOS say 명령어로 TTS, 재생용 aiff 파일 경로 반환."""
+    if not text:
+        return None
+    try:
+        tmp = tempfile.NamedTemporaryFile(suffix=".aiff", delete=False)
+        tmp.close()
+        subprocess.run(
+            ["say", "-v", _TTS_VOICE, "-o", tmp.name, text],
+            check=True,
+            capture_output=True,
+        )
+        return tmp.name
+    except Exception:
+        return None
+
+
+# ── 채팅 ─────────────────────────────────────────────────────────
+
+async def respond(message, history, show_thinking, user_id, use_tts, run_ids):
+    if not message.strip():
+        yield history, "", None, run_ids
+        return
+
+    history = list(history)
+    run_ids = list(run_ids)
+    history.append({"role": "user", "content": message})
+    history.append({"role": "assistant", "content": ""})
+    yield history, "", None, run_ids
+
+    collected_run_id: str | None = None
+    try:
+        async for token, run_id in api_client.chat(message, user_id, show_thinking):
+            if run_id is not None:
+                collected_run_id = run_id
+                break
+            history[-1]["content"] += token
+            yield history, "", None, run_ids
+    except Exception as e:
+        history[-1]["content"] += f"\n\n[오류: {e}]"
+        yield history, "", None, run_ids
+        return
+
+    run_ids.append(collected_run_id)
+
+    if use_tts:
+        audio_path = tts_speak(history[-1]["content"])
+        yield history, "", audio_path, run_ids
+    else:
+        yield history, "", None, run_ids
+
+
+def handle_feedback(like_data: gr.LikeData, history, run_ids, user_id):
+    idx = like_data.index
+    if isinstance(idx, (list, tuple)):
+        idx = idx[0]
+    if not isinstance(idx, int) or idx >= len(history):
+        return
+    if history[idx].get("role") != "assistant":
+        return
+    asst_turn = sum(1 for m in history[:idx] if m.get("role") == "assistant")
+    run_id = run_ids[asst_turn] if asst_turn < len(run_ids) else None
+
+    user_msg = str(history[idx - 1]["content"]) if idx > 0 else ""
+    asst_msg = str(history[idx]["content"])
+    rating = 1 if like_data.liked else -1
+
+    try:
+        asyncio.get_event_loop().run_until_complete(
+            api_client.save_feedback(user_id, user_msg, asst_msg, rating, run_id)
+        )
+    except Exception as e:
+        print(f"[Feedback] 저장 실패: {e}")
+
+
+def switch_user(user_id):
+    return [], []
+
+
+def reset_chat(user_id):
+    try:
+        asyncio.get_event_loop().run_until_complete(api_client.reset(user_id))
+    except Exception as e:
+        print(f"[Reset] 실패: {e}")
+    return [], []
+
+
+# ── 문서 관리 ─────────────────────────────────────────────────────
+
+def ingest_files(files):
+    if not files:
+        return "파일을 선택해주세요."
+    paths = [f if isinstance(f, str) else f.name for f in files]
+    results = []
+    for path in paths:
+        try:
+            result = asyncio.get_event_loop().run_until_complete(api_client.ingest(path))
+            name = os.path.basename(path)
+            results.append(f"{name} → {result.get('chunks', '?')}개 청크")
+        except Exception as e:
+            results.append(f"{os.path.basename(path)} 오류: {e}")
+    return "\n".join(results)
+
+
+def list_docs():
+    try:
+        sources = asyncio.get_event_loop().run_until_complete(api_client.list_documents())
+        return [[os.path.basename(s), s] for s in sources]
+    except Exception as e:
+        return [[f"오류: {e}", ""]]
+
+
+def delete_doc(source):
+    if not source.strip():
+        return "삭제할 파일 경로를 입력하세요.", list_docs()
+    try:
+        asyncio.get_event_loop().run_until_complete(api_client.delete_document(source.strip()))
+        return f"삭제 완료: {os.path.basename(source.strip())}", list_docs()
+    except Exception as e:
+        return f"오류: {e}", list_docs()
+
+
+# ── UI 구성 ──────────────────────────────────────────────────────
+
+with gr.Blocks(title="율봇") as demo:
+    gr.Markdown("# 율봇\n육아·금융 전문 AI 상담 도우미")
+
+    user_state = gr.State(DEFAULT_USER)
+    run_ids_state = gr.State([])
+
+    with gr.Tab("대화"):
+        with gr.Row():
+            user_selector = gr.Dropdown(
+                choices=USER_LABELS,
+                value=DEFAULT_USER,
+                label="사용자",
+                scale=1,
+            )
+
+        chatbot = gr.Chatbot(label="율봇", height=500)
+        with gr.Row():
+            msg_box = gr.Textbox(
+                placeholder="질문을 입력하세요... (Enter로 전송)",
+                label="",
+                scale=5,
+                autofocus=True,
+            )
+            send_btn = gr.Button("전송", variant="primary", scale=1)
+
+        with gr.Row():
+            audio_input = gr.Audio(
+                sources=["microphone"],
+                type="filepath",
+                label="음성으로 질문하기",
+                scale=4,
+            )
+            transcribe_btn = gr.Button("음성 → 텍스트 변환", scale=1)
+
+        with gr.Row():
+            show_thinking = gr.Checkbox(label="사고 과정 표시", value=False)
+            use_tts = gr.Checkbox(label="음성으로 답변 읽기 (TTS)", value=False)
+            reset_btn = gr.Button("대화 초기화", size="sm")
+
+        tts_output = gr.Audio(label="음성 답변", autoplay=True, visible=False)
+        use_tts.change(lambda v: gr.Audio(visible=v), inputs=[use_tts], outputs=[tts_output])
+
+        user_selector.change(
+            switch_user,
+            inputs=[user_selector],
+            outputs=[chatbot, run_ids_state],
+        ).then(
+            lambda u: u, inputs=[user_selector], outputs=[user_state]
+        )
+
+        transcribe_btn.click(transcribe_audio, inputs=[audio_input], outputs=[msg_box])
+
+        send_btn.click(
+            respond,
+            inputs=[msg_box, chatbot, show_thinking, user_state, use_tts, run_ids_state],
+            outputs=[chatbot, msg_box, tts_output, run_ids_state],
+        )
+        msg_box.submit(
+            respond,
+            inputs=[msg_box, chatbot, show_thinking, user_state, use_tts, run_ids_state],
+            outputs=[chatbot, msg_box, tts_output, run_ids_state],
+        )
+        reset_btn.click(reset_chat, inputs=[user_state], outputs=[chatbot, run_ids_state])
+
+        chatbot.like(
+            handle_feedback,
+            inputs=[chatbot, run_ids_state, user_state],
+            outputs=[],
+        )
+
+    with gr.Tab("문서 등록"):
+        gr.Markdown("PDF 또는 TXT 파일을 업로드하면 율봇이 내용을 참고해 답변합니다.")
+        file_input = gr.File(
+            file_types=[".pdf", ".txt"],
+            file_count="multiple",
+            label="파일 선택",
+        )
+        ingest_btn = gr.Button("문서 수집", variant="primary")
+        ingest_status = gr.Textbox(label="결과", interactive=False)
+        ingest_btn.click(ingest_files, inputs=[file_input], outputs=[ingest_status])
+
+    with gr.Tab("문서 관리"):
+        gr.Markdown("Qdrant에 등록된 문서 목록입니다. 불필요한 문서를 삭제할 수 있습니다.")
+        doc_table = gr.Dataframe(
+            headers=["파일명", "전체 경로"],
+            label="등록된 문서",
+            interactive=False,
+        )
+        refresh_btn = gr.Button("새로고침")
+        gr.Markdown("---")
+        with gr.Row():
+            delete_source = gr.Textbox(
+                label="삭제할 파일 경로",
+                placeholder="위 표에서 전체 경로를 복사해 붙여넣으세요",
+                scale=4,
+            )
+            delete_btn = gr.Button("삭제", variant="stop", scale=1)
+        delete_status = gr.Textbox(label="결과", interactive=False)
+
+        refresh_btn.click(list_docs, outputs=[doc_table])
+        delete_btn.click(delete_doc, inputs=[delete_source], outputs=[delete_status, doc_table])
+        demo.load(list_docs, outputs=[doc_table])
+
+
+if __name__ == "__main__":
+    demo.launch(server_name="0.0.0.0", server_port=7860, theme=gr.themes.Soft())
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..16bcfc0
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,4 @@
+gradio>=4.0.0
+httpx>=0.27.0
+python-dotenv>=1.0.0
+openai-whisper>=20231117