Function handle_list_services

crates/openshell-server/src/grpc/service.rs:142–168

(
    state: &Arc<ServerState>,
    request: Request<ListServicesRequest>,
)

}

pub(super) async fn handle_list_services(
    state: &Arc<ServerState>,
    request: Request<ListServicesRequest>,
) -> Result<Response<ListServicesResponse>, Status> {
    let req = request.into_inner();
    if !req.sandbox.is_empty() {
        validate_endpoint_name("sandbox", &req.sandbox, MAX_SANDBOX_NAME_LEN)?;
    }

    let limit = super::clamp_limit(req.limit, 100, super::MAX_PAGE_SIZE);
    let endpoints: Vec<ServiceEndpoint> = if req.sandbox.is_empty() {
        state.store.list_messages(limit, req.offset).await
    } else {
        state
            .store
            .list_messages_with_selector(&format!("sandbox={}", req.sandbox), limit, req.offset)
            .await
    }
    .map_err(|e| Status::internal(format!("list endpoints failed: {e}")))?;

    let services = endpoints
        .into_iter()
        .map(|ep| service_endpoint_response(state, ep))
        .collect();

    Ok(Response::new(ListServicesResponse { services }))
}

pub(super) async fn handle_delete_service(
    state: &Arc<ServerState>,