Function record_client_stream_stats

packages/server/src/api/routes.rs:1603–1616

(
    State(state): State<AppState>,
    Json(payload): Json<ClientStreamStats>,
)

}

async fn record_client_stream_stats(
    State(state): State<AppState>,
    Json(payload): Json<ClientStreamStats>,
) -> Result<Json<Value>, AppError> {
    if payload.client_id.trim().is_empty() || payload.kind.trim().is_empty() {
        return Err(AppError::bad_request(
            "Request body must include `clientId` and `kind`.",
        ));
    }

    apply_stream_client_foreground_from_stats(&state, &payload);
    state.metrics.record_client_stream_stats(payload);
    Ok(json(json_value!({ "ok": true })))
}

pub(crate) fn apply_stream_client_foreground_from_stats(
    state: &AppState,