fix(api): include delivered callback replies in observed filter

apps/api/src/services/platform_operator_service.py

@@ -38,8 +38,8 @@ from src.db.awooop_models import (
 from src.db.base import get_db_context
 from src.db.models import IncidentRecord, MCPAuditLog
 from src.services.audit_sink import write_audit
-from src.services.awooop_approval_token import issue_approval_token, record_approval
 from src.services.awooop_ansible_audit_service import summarize_ansible_execution
+from src.services.awooop_approval_token import issue_approval_token, record_approval
 from src.services.awooop_truth_chain_service import (
     _summarize_gateway_mcp,
     _summarize_mcp,
@@ -376,18 +376,6 @@ async def list_callback_replies(
             "m.source_envelope #>> '{callback_reply,status}' = :raw_status"
         )
         params["raw_status"] = raw_status
-    elif callback_reply_status == "observed":
-        where_clauses.append(
-            """
-            COALESCE(m.source_envelope #>> '{callback_reply,status}', '')
-            NOT IN (
-                'callback_reply_sent',
-                'callback_reply_fallback_sent',
-                'callback_reply_rescue_sent',
-                'callback_reply_failed'
-            )
-            """
-        )
 
     if callback_action:
         where_clauses.append(
@@ -3937,6 +3925,8 @@ def _callback_reply_summary_matches_status(
     if callback_reply_status is None:
         return True
     status_value = str((summary or {}).get("status") or "no_callback")
+    if callback_reply_status == "observed":
+        return status_value != "no_callback"
     return status_value == callback_reply_status