Function build_server_response

crates/server/src/router/api/server.rs:245–302

(
    s: server::Model,
    agent_manager: &AgentManager,
    outstanding_enrollment: Option<OutstandingEnrollmentSummary>,
)

}

#[derive(Debug, Deserialize, utoipa::IntoParams)]
pub struct AuthorityHistoryQuery {
    pub server_id: String,
    #[serde(default = "default_authority_history_limit")]
    pub limit: u64,
}

fn default_authority_history_limit() -> u64 {
    100
}

#[derive(Debug, Serialize, utoipa::ToSchema)]
pub struct AuthorityEventResponse {
    pub id: String,
    pub server_id: String,
    pub server_name: String,
    pub actor_kind: String,
    pub actor_id: Option<String>,
    pub request_source: String,
    pub offer_id: Option<String>,
    pub transition: String,
    pub mode: Option<String>,
    pub offer_outcome: Option<String>,
    pub authority_before: String,
    pub authority_after: String,
    pub created_at: DateTime<Utc>,
}

fn runtime_capability_fields(
    agent_manager: &AgentManager,
    server_id: &str,
) -> (Option<i32>, Option<i32>) {
    (
        agent_manager
            .get_agent_local_capabilities(server_id)
            .map(|caps| caps as i32),
        agent_manager
            .get_effective_capabilities(server_id)
            .map(|caps| caps as i32),
    )
}

fn build_server_response(
    s: server::Model,
    agent_manager: &AgentManager,
    agent_authority: AgentAuthorityStateSummary,
) -> ServerResponse {
    let (agent_local_capabilities, effective_capabilities) =
        runtime_capability_fields(agent_manager, &s.id);

    let temporary = agent_manager
        .get_temporary_grants(&s.id)
        .into_iter()
        .map(Into::into)
        .collect();

    let has_token = agent_authority.status == AgentAuthorityStatus::Claimed;
    let outstanding_enrollment = agent_authority.outstanding_offer.clone();