Function verification_event

core/src/ahp/contract.rs:169–225

(
    run_id: &str,
    session_id: &str,
    agent_id: &str,
    depth: u32,
    summary: &crate::verification::VerificationSummary,
)

}

fn verification_event(
    run_id: &str,
    session_id: &str,
    agent_id: &str,
    depth: u32,
    summary: &crate::verification::VerificationSummary,
) -> a3s_ahp::AhpEvent {
    let mut residual_risks = Vec::new();
    if !summary.pending_subjects.is_empty() {
        residual_risks.push(format!(
            "pending verification subjects: {}",
            summary.pending_subjects.join(", ")
        ));
    }
    if !summary.failed_subjects.is_empty() {
        residual_risks.push(format!(
            "failed verification subjects: {}",
            summary.failed_subjects.join(", ")
        ));
    }

    let metadata = std::collections::HashMap::from([
        (
            "report_count".to_string(),
            serde_json::json!(summary.report_count),
        ),
        (
            "required_check_count".to_string(),
            serde_json::json!(summary.required_check_count),
        ),
        (
            "pending_required_check_count".to_string(),
            serde_json::json!(summary.pending_required_check_count),
        ),
        (
            "failed_check_count".to_string(),
            serde_json::json!(summary.failed_check_count),
        ),
    ]);

    let payload = a3s_ahp::VerificationEvent {
        run_id: run_id.to_string(),
        session_id: session_id.to_string(),
        status: verification_status_to_ahp(summary.status),
        checks: Vec::new(),
        residual_risks,
        updated_at: now(),
        metadata: Some(metadata),
    };
    ahp_event(
        a3s_ahp::EventType::Verification,
        session_id,
        agent_id,
        depth,
        serde_json::to_value(payload).expect("verification payload serializes"),
    )
}