Update app.py

app.py

@@ -525,13 +525,12 @@ def analyze_composite(msg1, date1, msg2, date2, msg3, date3, *answers_and_none):
         escalation_score = None
         risk_level = "unknown"
     else:
-        escalation_score = sum(w for (_, w), a in zip(ESCALATION_QUESTIONS, answers_and_none[:-1]) if a)
-        risk_level = (
-            "High" if escalation_score >= 16 else
-            "Moderate" if escalation_score >= 8 else
-            "Low"
-        )
+    escalation_score = sum(w for (_, w), a in zip(ESCALATION_QUESTIONS, answers_and_none[:-1]) if a)
+    escalation_bump = 0  # Will be computed later
+    hybrid_score = escalation_score  # Start with raw
 
+    # We'll finalize `risk_level` after computing bump below
+    risk_level = "Low"
     messages = [msg1, msg2, msg3]
     dates = [date1, date2, date3]
     active = [(m, d) for m, d in zip(messages, dates) if m.strip()]
@@ -539,6 +538,19 @@ def analyze_composite(msg1, date1, msg2, date2, msg3, date3, *answers_and_none):
         return "Please enter at least one message."
 
     results = [(analyze_single_message(m, THRESHOLDS.copy()), d) for m, d in active]
+    escalation_bump = 0
+
+    for result, _ in results:
+        abuse_score, threshold_labels, top_patterns, sentiment, stage, darvo_score, tone_tag = result
+
+        if darvo_score > 0.65:
+            escalation_bump += 3
+        if tone_tag in ["forced accountability flip", "emotional threat"]:
+            escalation_bump += 2
+        if abuse_score > 80:
+            escalation_bump += 2
+        if stage == 2:
+            escalation_bump += 3
     for result, date in results:
         assert len(result) == 7, "Unexpected output from analyze_single_message"
     abuse_scores = [r[0][0] for r in results]