Function build_cache_telemetry_event

crates/python/src/py_adaptive.rs:322–367

(
    py: Python<'_>,
    provider: &str,
    request_id: &str,
    usage: Option<&Bound<'_, PyAny>>,
    request_facts: Option<&Bound<'_, PyAny>>,
    agent_id: &str,
    template_version: &str,
    

    text_signature = "(*, provider: str, request_id: str, usage: dict | None = None, request_facts: object | None = None, agent_id: str, template_version: str, toolset_hash: str, model_family: str, tenant_scope: str, timestamp: str | None = None) -> dict | None"
)]
fn build_cache_telemetry_event(
    py: Python<'_>,
    provider: &str,
    request_id: &str,
    usage: Option<&Bound<'_, PyAny>>,
    request_facts: Option<&Bound<'_, PyAny>>,
    agent_id: &str,
    template_version: &str,
    toolset_hash: &str,
    model_family: &str,
    tenant_scope: &str,
    timestamp: Option<&str>,
) -> PyResult<Py<PyAny>> {
    let provider = parse_cache_telemetry_provider(provider)?;
    let request_id = parse_cache_telemetry_request_id(request_id)?;
    let timestamp = parse_cache_telemetry_timestamp(timestamp)?;
    let Some(usage_json) = opt_py_to_json(usage)? else {
        return Ok(py.None());
    };
    let request_facts = parse_cache_request_facts(request_facts)?;
    let usage: Usage = serde_json::from_value(usage_json)
        .map_err(|e| pyo3::exceptions::PyValueError::new_err(format!("invalid usage: {e}")))?;
    let agent_identity = AgentIdentity {
        agent_id: agent_id.to_string(),
        template_version: template_version.to_string(),
        toolset_hash: toolset_hash.to_string(),
        model_family: model_family.to_string(),
        tenant_scope: tenant_scope.to_string(),
    };

    match CacheTelemetryEvent::from_usage(
        request_id,
        agent_identity,
        provider,
        &usage,
        timestamp,
        request_facts.as_ref(),
    ) {
        Some(event) => {
            let event = serde_json::to_value(&event)
                .map_err(|e| pyo3::exceptions::PyRuntimeError::new_err(e.to_string()))?;
            json_to_py(py, &event)
        }
        None => Ok(py.None()),
    }
}

#[pyfunction]
#[pyo3(signature = (config: "object") -> "object", text_signature = "(config: object) -> object")]