From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from gate001.proxmox.com (gate001.proxmox.com [IPv6:2a0f:8001:1:32::40]) by lore.proxmox.com (Postfix) with ESMTPS id 022CD1FF0A8 for ; Thu, 20 Aug 2026 16:53:07 +0200 (CEST) Received: from gate001.proxmox.com (localhost.localdomain [127.0.0.1]) by gate001.proxmox.com (Proxmox) with ESMTP id F0A95215ED; Thu, 20 Aug 2026 16:52:47 +0200 (CEST) From: Lukas Wagner To: pdm-devel@lists.proxmox.com Subject: [PATCH datacenter-manager v2 13/20] api: sdn: use PdmApplication handle for accessing remotes Date: Thu, 20 Aug 2026 16:52:13 +0200 Message-ID: <20260820145220.418032-14-l.wagner@proxmox.com> X-Mailer: git-send-email 2.47.3 In-Reply-To: <20260820145220.418032-1-l.wagner@proxmox.com> References: <20260820145220.418032-1-l.wagner@proxmox.com> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-Bm-Milter-Handled: 55990f41-d878-4baa-be0a-ee34c49e34d2 X-Bm-Transport-Timestamp: 1787237519431 X-SPAM-LEVEL: Spam detection results: 0 AWL 0.714 Adjusted score from AWL reputation of From: address DMARC_MISSING 0.1 Missing DMARC policy KAM_DMARC_STATUS 0.01 Test Rule for DKIM or SPF Failure with Strict Alignment (newer systems) RCVD_IN_DNSWL_MED -2.3 Sender listed at https://www.dnswl.org/, medium trust SPF_HELO_NONE 0.001 SPF: HELO does not publish an SPF Record SPF_PASS -0.001 SPF: sender matches SPF record Message-ID-Hash: JJXNGFTNW4ODAB3DUAQC2PB5GAN3ELP6 X-Message-ID-Hash: JJXNGFTNW4ODAB3DUAQC2PB5GAN3ELP6 X-MailFrom: l.wagner@proxmox.com X-Mailman-Rule-Misses: dmarc-mitigation; no-senders; approved; loop; banned-address; emergency; member-moderation; nonmember-moderation; administrivia; implicit-dest; max-recipients; max-size; news-moderation; no-subject; digests; suspicious-header X-Mailman-Version: 3.3.10 Precedence: list List-Id: Proxmox Datacenter Manager development discussion List-Help: List-Owner: List-Post: List-Subscribe: List-Unsubscribe: By using the State extractor in the API handler, we can get a handle to the PdmApplication injected at server startup. SDN routes only need to read the remote configuration and use ParallelFetcher to make requests to remotes, all of which are easily possible via PdmApplication already. Signed-off-by: Lukas Wagner --- server/src/api/sdn/controllers.rs | 16 +++++++++++----- server/src/api/sdn/vnets.rs | 17 +++++++++++------ server/src/api/sdn/zones.rs | 16 ++++++++++------ 3 files changed, 32 insertions(+), 17 deletions(-) diff --git a/server/src/api/sdn/controllers.rs b/server/src/api/sdn/controllers.rs index 049358cd..2375b043 100644 --- a/server/src/api/sdn/controllers.rs +++ b/server/src/api/sdn/controllers.rs @@ -5,12 +5,12 @@ use anyhow::{Context, Error}; use pbs_api_types::REMOTE_ID_SCHEMA; use pdm_api_types::{Authid, PRIV_RESOURCE_AUDIT, remotes::RemoteType, sdn::ListController}; use proxmox_access_control::CachedUserInfo; -use proxmox_router::{Permission, Router, RpcEnvironment, http_bail}; +use proxmox_router::{Permission, Router, RpcEnvironment, State, http_bail}; use proxmox_schema::api; use pve_api_types::ListControllersType; -use crate::api::pve; use crate::api::remotes::RemoteIterator; +use crate::context::PdmApplication; use crate::parallel_fetcher::ParallelFetcher; pub const ROUTER: Router = Router::new().get(&API_METHOD_LIST_CONTROLLERS); @@ -63,6 +63,7 @@ pub async fn list_controllers( ty: Option, remotes: Option>, rpcenv: &mut dyn RpcEnvironment, + app: State, ) -> Result, Error> { let user_info = CachedUserInfo::new()?; @@ -75,7 +76,7 @@ pub async fn list_controllers( http_bail!(FORBIDDEN, "user has no access to resources"); } - let mut iter = RemoteIterator::new(pdm_config::remotes::instance())? + let mut iter = RemoteIterator::new(app.remote_config())? .remote_type(RemoteType::Pve) .any_privs(&user_info, &auth_id, PRIV_RESOURCE_AUDIT); if let Some(ref filter) = remotes { @@ -83,11 +84,16 @@ pub async fn list_controllers( } let mut vnets = Vec::new(); - let fetcher = ParallelFetcher::new((pending, running, ty)); + + let fetcher = ParallelFetcher::builder((pending, running, ty)) + .client_factory(app.client_factory_shared()) + .build(); let results = fetcher .do_for_all_remotes(iter.into_remotes(), async |args| { - Ok(pve::connect(&args.remote)? + Ok(args + .client_factory + .make_pve_client(&args.remote)? .list_controllers(args.context.0, args.context.1, args.context.2) .await?) }) diff --git a/server/src/api/sdn/vnets.rs b/server/src/api/sdn/vnets.rs index 8e7ae52b..1d72114e 100644 --- a/server/src/api/sdn/vnets.rs +++ b/server/src/api/sdn/vnets.rs @@ -1,6 +1,7 @@ use std::collections::HashSet; use anyhow::{Context, Error}; + use pbs_api_types::REMOTE_ID_SCHEMA; use pdm_api_types::{ Authid, PRIV_RESOURCE_AUDIT, @@ -9,12 +10,11 @@ use pdm_api_types::{ }; use proxmox_access_control::CachedUserInfo; use proxmox_rest_server::WorkerTask; -use proxmox_router::{Permission, Router, RpcEnvironment, http_bail}; +use proxmox_router::{Permission, Router, RpcEnvironment, State, http_bail}; use proxmox_schema::api; use pve_api_types::{CreateVnet, SdnVnetType}; -use crate::api::pve; -use crate::api::remotes::RemoteIterator; +use crate::{api::remotes::RemoteIterator, context::PdmApplication}; use crate::{parallel_fetcher::ParallelFetcher, sdn_client::LockedSdnClients}; pub const ROUTER: Router = Router::new() @@ -64,6 +64,7 @@ async fn list_vnets( running: Option, remotes: Option>, rpcenv: &mut dyn RpcEnvironment, + app: State, ) -> Result, Error> { let user_info = CachedUserInfo::new()?; @@ -76,7 +77,7 @@ async fn list_vnets( http_bail!(FORBIDDEN, "user has no access to resources"); } - let mut iter = RemoteIterator::new(pdm_config::remotes::instance())? + let mut iter = RemoteIterator::new(app.remote_config())? .remote_type(RemoteType::Pve) .any_privs(&user_info, &auth_id, PRIV_RESOURCE_AUDIT); if let Some(ref filter) = remotes { @@ -84,11 +85,15 @@ async fn list_vnets( } let mut vnets = Vec::new(); - let fetcher = ParallelFetcher::new((pending, running)); + let fetcher = ParallelFetcher::builder((pending, running)) + .client_factory(app.client_factory_shared()) + .build(); let results = fetcher .do_for_all_remotes(iter.into_remotes(), async |args| { - Ok(pve::connect(&args.remote)? + Ok(args + .client_factory + .make_pve_client(&args.remote)? .list_vnets(args.context.0, args.context.1) .await?) }) diff --git a/server/src/api/sdn/zones.rs b/server/src/api/sdn/zones.rs index bb7a3822..58b69414 100644 --- a/server/src/api/sdn/zones.rs +++ b/server/src/api/sdn/zones.rs @@ -10,12 +10,11 @@ use pdm_api_types::{ }; use proxmox_access_control::CachedUserInfo; use proxmox_rest_server::WorkerTask; -use proxmox_router::{Permission, Router, RpcEnvironment, http_bail}; +use proxmox_router::{Permission, Router, RpcEnvironment, State, http_bail}; use proxmox_schema::api; use pve_api_types::{CreateZone, ListZonesType}; -use crate::api::pve; -use crate::api::remotes::RemoteIterator; +use crate::{api::remotes::RemoteIterator, context::PdmApplication}; use crate::{parallel_fetcher::ParallelFetcher, sdn_client::LockedSdnClients}; pub const ROUTER: Router = Router::new() @@ -70,6 +69,7 @@ pub async fn list_zones( ty: Option, remotes: Option>, rpcenv: &mut dyn RpcEnvironment, + app: State, ) -> Result, Error> { let user_info = CachedUserInfo::new()?; @@ -82,7 +82,7 @@ pub async fn list_zones( http_bail!(FORBIDDEN, "user has no access to resources"); } - let mut iter = RemoteIterator::new(pdm_config::remotes::instance())? + let mut iter = RemoteIterator::new(app.remote_config())? .remote_type(RemoteType::Pve) .any_privs(&user_info, &auth_id, PRIV_RESOURCE_AUDIT); if let Some(ref filter) = remotes { @@ -90,11 +90,15 @@ pub async fn list_zones( } let mut vnets = Vec::new(); - let fetcher = ParallelFetcher::new((pending, running, ty)); + let fetcher = ParallelFetcher::builder((pending, running, ty)) + .client_factory(app.client_factory_shared()) + .build(); let results = fetcher .do_for_all_remotes(iter.into_remotes(), async |args| { - Ok(pve::connect(&args.remote)? + Ok(args + .client_factory + .make_pve_client(&args.remote)? .list_zones(args.context.0, args.context.1, args.context.2) .await?) }) -- 2.47.3