manta-server 2.0.0-beta.62

//! `StaticBackendDispatcher` trait implementations.
//!
//! [`crate::dispatcher::StaticBackendDispatcher`] is the enum that
//! wraps a CSM or an OCHAMI backend; the trait impls live here so the
//! enum stays a pure data type and the routing logic lives next door
//! to the imports it needs. Each backend trait from
//! `manta-backend-dispatcher::interfaces::*` gets its own sibling file
//! under this module.
//!
//! # Structure
//!
//! Sibling files do `use super::*;` to pick up the shared trait,
//! type, and macro imports defined here, so an individual impl file
//! only needs to declare the `impl` block. The `dispatch!` macro
//! is textually scoped: it's visible to every `mod` declaration that
//! follows it in this file.
//!
//! # Why every trait needs an explicit forward
//!
//! Some traits in `manta-backend-dispatcher` ship a default
//! "not implemented" body for each method. If a trait isn't
//! explicitly implemented here, every method call falls through to
//! that default — silently returning "not implemented" even when the
//! underlying CSM or OCHAMI backend would have handled it. The
//! `apply_sat_image_create_session` regression was exactly this
//! shape, so the rule is: any trait a handler reaches through must
//! have a sibling file under this module, even if the body is a
//! straight `dispatch!` forward.

use std::collections::HashMap;
use std::pin::Pin;

use chrono::NaiveDateTime;
use futures::AsyncBufRead;
use serde_json::Value;
use tokio::io::{AsyncRead, AsyncWrite};

use manta_backend_dispatcher::error::Error;
use manta_backend_dispatcher::interfaces::apply_hw_cluster_pin::ApplyHwClusterPin;
use manta_backend_dispatcher::interfaces::apply_sat_file::{
  ApplyConfigurationParams, ApplyImageCreateSessionParams, ApplyImageParams,
  ApplyImageStampParams, ApplySatFileParams, ApplySessionTemplateParams,
  SatTrait,
};
use manta_backend_dispatcher::interfaces::apply_session::ApplySessionTrait;
use manta_backend_dispatcher::interfaces::authentication::AuthenticationTrait;
use manta_backend_dispatcher::interfaces::bos::{
  ClusterSessionTrait, ClusterTemplateTrait,
};
use manta_backend_dispatcher::interfaces::bss::BootParametersTrait;
use manta_backend_dispatcher::interfaces::cfs::CfsTrait;
use manta_backend_dispatcher::interfaces::console::ConsoleTrait;
use manta_backend_dispatcher::interfaces::delete_configurations_and_data_related::DeleteConfigurationsAndDataRelatedTrait;
use manta_backend_dispatcher::interfaces::hsm::component::ComponentTrait;
use manta_backend_dispatcher::interfaces::hsm::group::GroupTrait;
use manta_backend_dispatcher::interfaces::hsm::hardware_inventory::HardwareInventory;
use manta_backend_dispatcher::interfaces::hsm::redfish_endpoint::RedfishEndpointTrait;
use manta_backend_dispatcher::interfaces::ims::{
  GetImagesAndDetailsTrait, ImsTrait,
};
use manta_backend_dispatcher::interfaces::migrate_backup::MigrateBackupTrait;
use manta_backend_dispatcher::interfaces::migrate_restore::MigrateRestoreTrait;
use manta_backend_dispatcher::interfaces::pcs::PCSTrait;
use manta_backend_dispatcher::types::{
  self, Component, ComponentArrayPostArray, Group, HWInventory,
  HWInventoryByLocationList, HsmActionResponse, K8sDetails, NodeMetadataArray,
  NodeSummary,
};
use manta_backend_dispatcher::types::bos::session::BosSession;
use manta_backend_dispatcher::types::bos::session_template::BosSessionTemplate;
use manta_backend_dispatcher::types::bss::BootParameters;
use manta_backend_dispatcher::types::cfs::cfs_configuration_details::LayerDetails;
use manta_backend_dispatcher::types::cfs::cfs_configuration_request::CfsConfigurationRequest;
use manta_backend_dispatcher::types::cfs::cfs_configuration_response::{
  CfsConfigurationResponse, Layer,
};
use manta_backend_dispatcher::types::cfs::component::Component as CfsComponent;
use manta_backend_dispatcher::types::cfs::session::{
  CfsSessionGetResponse, CfsSessionPostRequest,
};
use manta_backend_dispatcher::types::hsm::inventory::{
  RedfishEndpoint, RedfishEndpointArray,
};
use manta_backend_dispatcher::types::ims::{Image, PatchImage};
use manta_backend_dispatcher::types::pcs::transitions::types::{
  TransitionResponse, TransitionStartOutput,
};

use crate::dispatcher::StaticBackendDispatcher;
use StaticBackendDispatcher::*;

/// Dispatches a method call to the underlying backend variant.
///
/// Both `CSM` and `OCHAMI` variants always delegate to the same
/// method on the wrapped client with identical arguments, so this
/// macro eliminates the repetitive `match self` boilerplate found in
/// every trait impl in this module.
///
/// # Usage
///
/// ```ignore
/// // async method (default):
/// dispatch!(self, method_name, arg1, arg2)
/// // sync method:
/// dispatch!(sync self, method_name, arg1)
/// ```
///
/// The async form expands to a `match self` whose arms call the named
/// method and `.await` the result; the `sync` form omits the
/// `.await`. The macro is intentionally minimal — when CSM and OCHAMI
/// diverge in their method names or arguments, write a manual
/// `match self` body instead.
macro_rules! dispatch {
  // async (default): adds `.await` after the call
  ($self:ident, $method:ident $(, $arg:expr)*) => {
    match $self {
      CSM(b) => b.$method($($arg),*).await,
      OCHAMI(b) => b.$method($($arg),*).await,
    }
  };
  // sync: no `.await`
  (sync $self:ident, $method:ident $(, $arg:expr)*) => {
    match $self {
      CSM(b) => b.$method($($arg),*),
      OCHAMI(b) => b.$method($($arg),*),
    }
  };
}

mod apply_hw_cluster_pin;
mod apply_session;
mod authentication;
mod boot_parameters;
mod cfs;
mod cluster_session;
mod cluster_template;
mod component;
mod component_ethernet_interface;
mod console;
mod delete_configurations;
mod get_images;
mod group;
mod hardware_inventory;
mod ims;
mod migrate_backup;
mod migrate_restore;
mod pcs;
mod redfish_endpoint;
mod sat;