use super::{
cache::{
data_center_cache_request, node_cache_request, node_operator_cache_request,
node_provider_cache_request, subnet_catalog_cache_request,
},
model::TopologyRefreshParts,
};
use crate::{
nns::data_center::NnsDataCenterRefreshRequest, nns::node::NnsNodeRefreshRequest,
nns::node_operator::NnsNodeOperatorRefreshRequest,
nns::node_provider::NnsNodeProviderRefreshRequest, subnet_catalog::SubnetCatalogRefreshRequest,
};
pub(in crate::nns::topology::report) fn subnet_catalog_refresh_request(
request: &impl TopologyRefreshParts,
) -> SubnetCatalogRefreshRequest {
SubnetCatalogRefreshRequest::new(
subnet_catalog_cache_request(request),
request.source_endpoint(),
request.now_unix_secs(),
request.lock_stale_after_seconds(),
)
.with_dry_run(request.dry_run())
}
pub(in crate::nns::topology::report) fn node_refresh_request(
request: &impl TopologyRefreshParts,
) -> NnsNodeRefreshRequest {
NnsNodeRefreshRequest::new(
node_cache_request(request),
request.source_endpoint(),
request.now_unix_secs(),
request.lock_stale_after_seconds(),
)
.with_dry_run(request.dry_run())
}
macro_rules! component_refresh_request {
($name:ident, $request:path, $cache_request:ident) => {
pub(in crate::nns::topology::report) fn $name(
request: &impl TopologyRefreshParts,
) -> $request {
<$request>::new(
$cache_request(request),
request.source_endpoint(),
request.now_unix_secs(),
request.lock_stale_after_seconds(),
)
.with_dry_run(request.dry_run())
}
};
}
component_refresh_request!(
node_provider_refresh_request,
NnsNodeProviderRefreshRequest,
node_provider_cache_request
);
component_refresh_request!(
node_operator_refresh_request,
NnsNodeOperatorRefreshRequest,
node_operator_cache_request
);
component_refresh_request!(
data_center_refresh_request,
NnsDataCenterRefreshRequest,
data_center_cache_request
);