[interview] Conditional questions, agentic correction loop, bold review labels

From live testing:
- If current country == origin (person still in their country / in hiding), use
"what is happening … that makes you fear for your safety" wording and SKIP the
"how long ago did you leave" question (conditional script in interview_script).
- "Something needs changing" no longer resets the whole interview: the agent now
asks what to correct (free text) and an LLM maps the correction to the right
field(s), then re-shows the summary (agentic correction loop).
- Review summary labels are bold (markdown ** -> <strong> in the chat renderer).
- Assessment: thinking off so the reasoning narration streams visibly (was
stuck on "Beginning your assessment…") and runs faster.

64 fast tests pass.

Co-authored-by: Codex <noreply@openai.com>

app/interview_script.py

@@ -25,15 +25,17 @@ class Question:
     control: str        # "country" | "yesno" | "choice" | "text"
     kind: str = "str"   # str | bool | list | list_text
     options: list = field(default_factory=list)  # option string-ids for choice/yesno
+    alt_sid: str | None = None       # alternate text when still in country of origin
+    skip_if_in_origin: bool = False  # skip when current country == origin
 
 
 # Ordered interview plan. Controls are fixed; some questions template {origin}.
 QUESTIONS: list[Question] = [
     Question("q_current", "current_country", State.SITUATION, "country"),
     Question("q_origin", "origin_country", State.SITUATION, "country"),
-    Question("q_reason", "free_text_history", State.SITUATION, "text"),
+    Question("q_reason", "free_text_history", State.SITUATION, "text", alt_sid="q_reason_instill"),
     Question("q_danger", "immediate_danger", State.SITUATION, "yesno", kind="bool"),
-    Question("q_duration", "displacement_duration", State.HISTORY, "text"),
+    Question("q_duration", "displacement_duration", State.HISTORY, "text", skip_if_in_origin=True),
     Question("q_documents", "documents_available", State.HISTORY, "choice", kind="list",
              options=["opt_passport", "opt_id", "opt_birth", "opt_none", "opt_other"]),
     Question("q_languages", "languages_spoken", State.GOALS, "text", kind="list_text"),
@@ -236,15 +238,75 @@ TR: dict[str, dict[str, str]] = {
 }
 
 
+# Extra strings (still-in-country reason wording + the correction prompt),
+# merged into TR. t() falls back to English for any language missing a key.
+_EXTRA = {
+    "English": {
+        "q_reason_instill": "Can you tell me what is happening in {origin} that makes you fear for your safety?",
+        "q_correct": "What would you like to correct? You can tell me in your own words.",
+    },
+    "French": {
+        "q_reason_instill": "Pouvez-vous me dire ce qui se passe en {origin} qui vous fait craindre pour votre sécurité ?",
+        "q_correct": "Que souhaitez-vous corriger ? Dites-le-moi avec vos propres mots.",
+    },
+    "Spanish": {
+        "q_reason_instill": "¿Puedes contarme qué está pasando en {origin} que te hace temer por tu seguridad?",
+        "q_correct": "¿Qué te gustaría corregir? Puedes decírmelo con tus propias palabras.",
+    },
+    "Portuguese": {
+        "q_reason_instill": "Pode me contar o que está acontecendo em {origin} que faz você temer pela sua segurança?",
+        "q_correct": "O que você gostaria de corrigir? Pode me dizer com suas próprias palavras.",
+    },
+    "Arabic": {
+        "q_reason_instill": "هل يمكنك أن تخبرني بما يحدث في {origin} ويجعلك تخشى على سلامتك؟",
+        "q_correct": "ما الذي تودّ تصحيحه؟ يمكنك إخباري بكلماتك الخاصة.",
+    },
+    "Hindi": {
+        "q_reason_instill": "क्या आप बता सकते हैं कि {origin} में क्या हो रहा है जिससे आपको अपनी सुरक्षा का डर है?",
+        "q_correct": "आप क्या ठीक करना चाहेंगे? आप अपने शब्दों में बता सकते हैं।",
+    },
+    "Chinese": {
+        "q_reason_instill": "能告诉我{origin}正在发生什么、让您为自己的安全感到担忧吗？",
+        "q_correct": "您想更正什么？可以用您自己的话告诉我。",
+    },
+    "Japanese": {
+        "q_reason_instill": "{origin}で何が起きていて、ご自身の安全が脅かされていると感じるのか教えていただけますか？",
+        "q_correct": "どこを修正したいですか？ ご自身の言葉で教えてください。",
+    },
+    "Korean": {
+        "q_reason_instill": "{origin}에서 무슨 일이 일어나고 있어 안전이 걱정되시는지 말씀해 주시겠어요?",
+        "q_correct": "무엇을 고치고 싶으신가요? 편하게 말씀해 주세요.",
+    },
+    "Russian": {
+        "q_reason_instill": "Расскажите, что происходит в {origin}, из-за чего вы опасаетесь за свою безопасность?",
+        "q_correct": "Что вы хотели бы исправить? Можете рассказать своими словами.",
+    },
+}
+for _lang, _d in _EXTRA.items():
+    TR.setdefault(_lang, {}).update(_d)
+
+
 def t(language: str | None, sid: str) -> str:
     """Translation lookup with English fallback."""
     lang = language if language in TR else "English"
     return TR[lang].get(sid) or TR["English"].get(sid, sid)
 
 
+def in_origin(session) -> bool:
+    """True when the person is still in their country of origin."""
+    o = (session.interview.origin_country or "").strip().lower()
+    c = (session.interview.current_country or "").strip().lower()
+    return bool(o) and o == c
+
+
 def question_text(language: str | None, q: Question, session) -> str:
-    """Localised question text, templated with collected values."""
-    raw = t(language, q.sid)
+    """Localised question text, templated with collected values.
+
+    Uses the alternate wording when the person is still in their origin country
+    (so we don't ask "what made you leave" / "how long ago did you leave").
+    """
+    sid = q.alt_sid if (q.alt_sid and in_origin(session)) else q.sid
+    raw = t(language, sid)
     origin = session.interview.origin_country or t(language, "q_origin")
     current = session.interview.current_country or ""
     return raw.replace("{origin}", str(origin)).replace("{current}", str(current))
@@ -256,4 +318,5 @@ def option_labels(language: str | None, q: Question) -> list[str]:
     return [t(language, oid) for oid in q.options]
 
 
-__all__ = ["Question", "QUESTIONS", "REVIEW_INDEX", "TR", "t", "question_text", "option_labels"]
+__all__ = ["Question", "QUESTIONS", "REVIEW_INDEX", "TR", "t", "question_text",
+           "option_labels", "in_origin"]

app/phases/assessment.py

@@ -192,7 +192,7 @@ async def stream_assessment(session: SessionState, loop):
 
     async for ev in loop.run(
         prompt, session, system_prompt=system_prompt,
-        tools=ASSESSMENT_TOOLS, thinking_level="medium", hooks=hooks,
+        tools=ASSESSMENT_TOOLS, thinking_level="off", hooks=hooks,
     ):
         if isinstance(ev, TextDeltaEvent):
             acc += ev.delta

app/phases/interview.py

@@ -11,6 +11,7 @@ mismatched controls, drift). Answers are captured straight into
 from __future__ import annotations
 
 import html
+import re
 
 import gradio as gr
 
@@ -22,10 +23,13 @@ from app.interview_script import (
     QUESTIONS,
     REVIEW_INDEX,
     Question,
+    in_origin,
     option_labels,
     question_text,
     t,
 )
+
+CORRECT_INDEX = REVIEW_INDEX + 1  # pseudo-step: free-text correction
 from app.state.session import SessionState, State
 
 RAIL = [
@@ -98,8 +102,13 @@ def render_rail(state: State) -> str:
     return f'<div class="iv-rail" aria-label="Interview progress">{"".join(pills)}</div>'
 
 
+def _bold(escaped: str) -> str:
+    """Render **markdown bold** (used for review summary labels)."""
+    return re.sub(r"\*\*(.+?)\*\*", r"<strong>\1</strong>", escaped)
+
+
 def _bubble(role: str, text: str, current: bool = False) -> str:
-    safe = html.escape(text).replace("\n", "<br>")
+    safe = _bold(html.escape(text)).replace("\n", "<br>")
     if role == "user":
         return ('<div class="iv-msg iv-msg--user"><div class="iv-msg__av"><span>You</span></div>'
                 f'<div class="iv-msg__bubble">{safe}</div></div>')
@@ -136,9 +145,20 @@ def advance_to(session: SessionState, target) -> None:
 # Controls (deterministic per question)
 # --------------------------------------------------------------------------
 
+def _next_index(session: SessionState, idx: int) -> int:
+    """Next applicable question index, skipping ones that don't apply."""
+    j = idx + 1
+    while j < REVIEW_INDEX and QUESTIONS[j].skip_if_in_origin and in_origin(session):
+        j += 1
+    return j
+
+
 def control_updates(session: SessionState, idx: int):
     """(radio, multi, country, text) updates for the question at ``idx``."""
     lang = session.language
+    if idx == CORRECT_INDEX:  # free-text correction
+        return (gr.update(visible=False), gr.update(visible=False), gr.update(visible=False),
+                gr.update(visible=True, value=""))
     if idx >= REVIEW_INDEX:
         choices = [t(lang, "review_yes"), t(lang, "review_no")]
         return (gr.update(visible=True, choices=choices, value=None),
@@ -208,6 +228,8 @@ def _facts_recap(session: SessionState) -> str:
 
 
 def _agent_message_for(session: SessionState, idx: int, *, welcome: bool = False) -> str:
+    if idx == CORRECT_INDEX:
+        return t(session.language, "q_correct")
     text = question_text(session.language, QUESTIONS[idx], session)
     if welcome:
         return f"{t(session.language, 'welcome')}\n{text}"
@@ -229,13 +251,27 @@ def _labeled_facts(session: SessionState) -> str:
     return "\n".join(f"{k}: {v}" for k, v in fields if v)
 
 
+def _bold_labels(text: str) -> str:
+    """Wrap the 'Label:' prefix of each line in ** so it renders bold."""
+    out = []
+    for line in text.split("\n"):
+        if ":" in line and not line.lstrip().startswith("**"):
+            label, _, rest = line.partition(":")
+            if 0 < len(label) <= 40:
+                out.append(f"**{label.strip()}:**{rest}")
+                continue
+        out.append(line)
+    return "\n".join(out)
+
+
 def _labeled_fallback(session: SessionState) -> str:
     lang = session.language
-    return f"{t(lang, 'review_intro')}\n{_labeled_facts(session)}\n\n{t(lang, 'review_confirm')}"
+    facts = _bold_labels(_labeled_facts(session))
+    return f"{t(lang, 'review_intro')}\n{facts}\n\n{t(lang, 'review_confirm')}"
 
 
 async def _draft_review(session: SessionState, loop) -> str:
-    """LLM-written labeled review summary in the person's language."""
+    """LLM-written labeled review summary in the person's language (bold labels)."""
     lang = session.language or "English"
     system_prompt = (
         load_prompt("system")
@@ -253,7 +289,48 @@ async def _draft_review(session: SessionState, loop) -> str:
                 acc += ev.delta
     except Exception:
         acc = ""
-    return acc.strip() or _labeled_fallback(session)
+    return _bold_labels(acc.strip()) if acc.strip() else _labeled_fallback(session)
+
+
+_FIELD_KEYS = {
+    "origin_country", "current_country", "free_text_history", "immediate_danger",
+    "displacement_duration", "documents_available", "languages_spoken", "destination_preferences",
+}
+
+
+async def _apply_correction(session: SessionState, loop, correction: str) -> None:
+    """Agentic correction: the LLM maps the person's free-text fix to fields."""
+    system_prompt = (
+        "You update a structured interview record from a person's free-text correction. "
+        "Output ONLY lines of the form field=value, using these field names exactly: "
+        + ", ".join(sorted(_FIELD_KEYS)) + ". "
+        "immediate_danger must be yes or no. Only output the fields that should change. "
+        "No commentary."
+    )
+    prompt = (
+        "Current record:\n" + _labeled_facts(session)
+        + f"\n\nThe person says: {correction}\n\nWhat should change?"
+    )
+    acc = ""
+    try:
+        async for ev in loop.run(prompt, session=None, system_prompt=system_prompt, thinking_level="off"):
+            if isinstance(ev, TextDeltaEvent):
+                acc += ev.delta
+    except Exception:
+        acc = ""
+    for line in acc.splitlines():
+        if "=" not in line:
+            continue
+        key, _, val = line.partition("=")
+        key, val = key.strip(), val.strip()
+        if key not in _FIELD_KEYS or not val:
+            continue
+        if key == "immediate_danger":
+            setattr(session.interview, key, val.lower().startswith("y"))
+        elif key in ("documents_available", "languages_spoken", "destination_preferences"):
+            setattr(session.interview, key, [p.strip() for p in val.replace(";", ",").split(",") if p.strip()])
+        else:
+            setattr(session.interview, key, val)
 
 
 # --------------------------------------------------------------------------
@@ -292,11 +369,13 @@ def build(visible: bool = True, session_st=None, loop_st=None, slot_idx_st=None)
     stream_outputs = [chat, rail, radio, multi, country, text, session_st, loop_st, slot_idx_st]
 
     async def _present(session, loop, idx):
-        """Append the agent's message (scripted question, or LLM review summary)
-        and show the right control for the step."""
+        """Append the agent's message (scripted question, LLM review, or the
+        correction prompt) and show the right control for the step."""
         target = State.REVIEW if idx >= REVIEW_INDEX else QUESTIONS[idx].phase
         advance_to(session, target)
-        if idx >= REVIEW_INDEX:
+        if idx == CORRECT_INDEX:
+            msg = _agent_message_for(session, idx)
+        elif idx >= REVIEW_INDEX:
             msg = await _draft_review(session, loop)
         else:
             msg = _agent_message_for(session, idx, welcome=(idx == 0))
@@ -320,6 +399,17 @@ def build(visible: bool = True, session_st=None, loop_st=None, slot_idx_st=None)
         loop = loop or create_loop()
         lang = session.language
 
+        # Correction step: the person typed what to change; the agent applies it.
+        if idx == CORRECT_INDEX:
+            correction = (text_v or "").strip()
+            if not correction:
+                return (gr.update(), gr.update(), *control_updates(session, idx), session, loop, idx)
+            session.messages = list(session.messages) + [{"role": "user", "content": correction}]
+            await _apply_correction(session, loop, correction)
+            o = await _present(session, loop, REVIEW_INDEX)  # show the corrected summary
+            return (o[0], o[1], o[2], o[3], o[4], o[5], o[6], loop, o[7])
+
+        # Review step
         if idx >= REVIEW_INDEX:
             if not radio_v:
                 return (gr.update(), gr.update(), *control_updates(session, idx), session, loop, idx)
@@ -329,7 +419,7 @@ def build(visible: bool = True, session_st=None, loop_st=None, slot_idx_st=None)
                 return (render_chat(session.messages), render_rail(session.state),
                         gr.update(visible=False), gr.update(visible=False),
                         gr.update(visible=False), gr.update(visible=False), session, loop, idx)
-            o = await _present(session, loop, 0)  # "something needs changing" → restart
+            o = await _present(session, loop, CORRECT_INDEX)  # ask what to change (free text)
             return (o[0], o[1], o[2], o[3], o[4], o[5], o[6], loop, o[7])
 
         q = QUESTIONS[idx]
@@ -337,7 +427,7 @@ def build(visible: bool = True, session_st=None, loop_st=None, slot_idx_st=None)
         if display is None:
             return (gr.update(), gr.update(), *control_updates(session, idx), session, loop, idx)
         session.messages = list(session.messages) + [{"role": "user", "content": display}]
-        o = await _present(session, loop, idx + 1)
+        o = await _present(session, loop, _next_index(session, idx))
         return (o[0], o[1], o[2], o[3], o[4], o[5], o[6], loop, o[7])
 
     continue_event = cont.click(