Upload 2 files

app.py

@@ -148,8 +148,16 @@ def patient_input():
     })
 
 
-@app.route("/provider-response", methods=["POST"])
-def provider_response():
+@app.route("/preview-response", methods=["POST"])
+def preview_response():
+    """
+    Runs the exact same translate + synthesize pipeline as
+    /provider-response below, so the provider can read and hear precisely
+    what the patient will receive before committing to it. Unlike
+    /provider-response, this never touches the database - only "Send
+    reply" actually saves a response. Each preview click is a real
+    translation + speech synthesis call, same cost as an actual send.
+    """
     interaction_id = request.form.get("interaction_id")
     response_text = request.form.get("response_text")
 
@@ -163,10 +171,49 @@ def provider_response():
     patient_language = interaction["detected_language"]
     translated_response = translation.translate(response_text, "english", patient_language)
 
-    audio_filename = f"response_{interaction_id}.wav"
+    audio_filename = f"preview_{interaction_id}.wav"
     audio_path = os.path.join(AUDIO_DIR, audio_filename)
     tts.synthesize_speech(translated_response, patient_language, audio_path)
 
+    return jsonify({
+        "translated_response": translated_response,
+        "audio_url": f"/static/audio/{audio_filename}",
+    })
+
+
+@app.route("/provider-response", methods=["POST"])
+def provider_response():
+    interaction_id = request.form.get("interaction_id")
+    response_text = request.form.get("response_text")
+    # Optional cache-reuse fields: if the provider already generated a
+    # preview of this exact reply via /preview-response and didn't edit
+    # it afterward, the frontend passes the already-computed translation
+    # back here so this route can skip re-translating and re-synthesizing
+    # speech. Both are best-effort - if the preview audio isn't actually
+    # on disk, this quietly falls back to doing the full work itself,
+    # exactly as if these fields had never been sent.
+    cached_translation = request.form.get("translated_response")
+    reuse_audio = request.form.get("reuse_audio") == "true"
+
+    if not interaction_id or not response_text:
+        return jsonify({"error": "interaction_id and response_text are required"}), 400
+
+    interaction = database.get_interaction(interaction_id)
+    if not interaction:
+        return jsonify({"error": "interaction not found"}), 404
+
+    patient_language = interaction["detected_language"]
+    audio_filename = f"response_{interaction_id}.wav"
+    audio_path = os.path.join(AUDIO_DIR, audio_filename)
+    preview_path = os.path.join(AUDIO_DIR, f"preview_{interaction_id}.wav")
+
+    if cached_translation and reuse_audio and os.path.exists(preview_path):
+        translated_response = cached_translation
+        os.replace(preview_path, audio_path)
+    else:
+        translated_response = translation.translate(response_text, "english", patient_language)
+        tts.synthesize_speech(translated_response, patient_language, audio_path)
+
     database.update_interaction_response(interaction_id, response_text, translated_response)
 
     return jsonify({
@@ -193,6 +240,11 @@ def pending_interactions():
     return jsonify(database.get_pending_interactions())
 
 
+@app.route("/completed-interactions")
+def completed_interactions():
+    return jsonify(database.get_completed_interactions())
+
+
 @app.route("/history")
 def history():
     if "user_id" not in session:
@@ -200,6 +252,18 @@ def history():
     return jsonify(database.get_interactions_for_user(session["user_id"]))
 
 
+@app.route("/patient-history/<user_id>")
+def patient_history(user_id):
+    """
+    All of one patient's interactions, for the provider workspace's
+    "conversation history" panel. Distinct from /history above: that route
+    always looks up the current browser's own session, which only works
+    for the patient viewing their own messages. The provider needs to look
+    up a specific patient's history by id instead.
+    """
+    return jsonify(database.get_interactions_for_user(user_id))
+
+
 @app.route("/end-session", methods=["POST"])
 def end_session_route():
     if "session_id" in session:

database.py

@@ -114,6 +114,15 @@ def get_pending_interactions():
         return [dict(row) for row in cursor.fetchall()]
 
 
+def get_completed_interactions():
+    with get_connection() as connection:
+        cursor = _run(
+            connection,
+            "SELECT * FROM interaction WHERE provider_response IS NOT NULL ORDER BY timestamp DESC",
+        )
+        return [dict(row) for row in cursor.fetchall()]
+
+
 def get_interaction(interaction_id):
     with get_connection() as connection:
         cursor = _run(connection, "SELECT * FROM interaction WHERE id = ?", (interaction_id,))