Compare commits
10 Commits
77e09436a9
...
configure-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ea7322f38c | ||
|
|
2edd24753a | ||
|
|
da5be17cb6 | ||
|
|
1265cebfa7 | ||
|
|
073cccde2f | ||
| cf576192a8 | |||
| f7e9669009 | |||
| f65e16df7b | |||
| cbbaae2ac8 | |||
| 4a500e4eb7 |
27
Cargo.lock
generated
27
Cargo.lock
generated
@@ -680,11 +680,13 @@ version = "0.1.0"
|
|||||||
dependencies = [
|
dependencies = [
|
||||||
"async-trait",
|
"async-trait",
|
||||||
"env_logger",
|
"env_logger",
|
||||||
|
"harmony_secret",
|
||||||
"harmony_types",
|
"harmony_types",
|
||||||
"log",
|
"log",
|
||||||
"regex",
|
"regex",
|
||||||
"russh",
|
"russh",
|
||||||
"russh-keys",
|
"russh-keys",
|
||||||
|
"serde",
|
||||||
"tokio",
|
"tokio",
|
||||||
]
|
]
|
||||||
|
|
||||||
@@ -1818,6 +1820,18 @@ dependencies = [
|
|||||||
"url",
|
"url",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "example-openbao"
|
||||||
|
version = "0.1.0"
|
||||||
|
dependencies = [
|
||||||
|
"harmony",
|
||||||
|
"harmony_cli",
|
||||||
|
"harmony_macros",
|
||||||
|
"harmony_types",
|
||||||
|
"tokio",
|
||||||
|
"url",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "example-opnsense"
|
name = "example-opnsense"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
@@ -1833,6 +1847,18 @@ dependencies = [
|
|||||||
"url",
|
"url",
|
||||||
]
|
]
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "example-penpot"
|
||||||
|
version = "0.1.0"
|
||||||
|
dependencies = [
|
||||||
|
"harmony",
|
||||||
|
"harmony_cli",
|
||||||
|
"harmony_macros",
|
||||||
|
"harmony_types",
|
||||||
|
"tokio",
|
||||||
|
"url",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "example-pxe"
|
name = "example-pxe"
|
||||||
version = "0.1.0"
|
version = "0.1.0"
|
||||||
@@ -2363,6 +2389,7 @@ dependencies = [
|
|||||||
"once_cell",
|
"once_cell",
|
||||||
"opnsense-config",
|
"opnsense-config",
|
||||||
"opnsense-config-xml",
|
"opnsense-config-xml",
|
||||||
|
"option-ext",
|
||||||
"pretty_assertions",
|
"pretty_assertions",
|
||||||
"reqwest 0.11.27",
|
"reqwest 0.11.27",
|
||||||
"russh",
|
"russh",
|
||||||
|
|||||||
@@ -14,3 +14,5 @@ tokio.workspace = true
|
|||||||
log.workspace = true
|
log.workspace = true
|
||||||
env_logger.workspace = true
|
env_logger.workspace = true
|
||||||
regex = "1.11.3"
|
regex = "1.11.3"
|
||||||
|
harmony_secret = { path = "../harmony_secret" }
|
||||||
|
serde.workspace = true
|
||||||
|
|||||||
@@ -1,54 +1,70 @@
|
|||||||
use std::net::{IpAddr, Ipv4Addr};
|
use std::net::{IpAddr, Ipv4Addr};
|
||||||
|
|
||||||
|
use brocade::BrocadeOptions;
|
||||||
|
use harmony_secret::{Secret, SecretManager};
|
||||||
use harmony_types::switch::PortLocation;
|
use harmony_types::switch::PortLocation;
|
||||||
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
|
#[derive(Secret, Clone, Debug, Serialize, Deserialize)]
|
||||||
|
struct BrocadeSwitchAuth {
|
||||||
|
username: String,
|
||||||
|
password: String,
|
||||||
|
}
|
||||||
|
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() {
|
async fn main() {
|
||||||
env_logger::init();
|
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init();
|
||||||
|
|
||||||
let ip = IpAddr::V4(Ipv4Addr::new(10, 0, 0, 250)); // old brocade @ ianlet
|
// let ip = IpAddr::V4(Ipv4Addr::new(10, 0, 0, 250)); // old brocade @ ianlet
|
||||||
// let ip = IpAddr::V4(Ipv4Addr::new(192, 168, 55, 101)); // brocade @ sto1
|
let ip = IpAddr::V4(Ipv4Addr::new(192, 168, 55, 101)); // brocade @ sto1
|
||||||
|
// let ip = IpAddr::V4(Ipv4Addr::new(192, 168, 4, 11)); // brocade @ st
|
||||||
let switch_addresses = vec![ip];
|
let switch_addresses = vec![ip];
|
||||||
|
|
||||||
let brocade = brocade::init(&switch_addresses, 22, "admin", "password", None)
|
let config = SecretManager::get_or_prompt::<BrocadeSwitchAuth>()
|
||||||
.await
|
.await
|
||||||
.expect("Brocade client failed to connect");
|
.unwrap();
|
||||||
|
|
||||||
|
let brocade = brocade::init(
|
||||||
|
&switch_addresses,
|
||||||
|
22,
|
||||||
|
&config.username,
|
||||||
|
&config.password,
|
||||||
|
Some(BrocadeOptions {
|
||||||
|
dry_run: true,
|
||||||
|
..Default::default()
|
||||||
|
}),
|
||||||
|
)
|
||||||
|
.await
|
||||||
|
.expect("Brocade client failed to connect");
|
||||||
|
|
||||||
|
let entries = brocade.get_stack_topology().await.unwrap();
|
||||||
|
println!("Stack topology: {entries:#?}");
|
||||||
|
|
||||||
|
let entries = brocade.get_interfaces().await.unwrap();
|
||||||
|
println!("Interfaces: {entries:#?}");
|
||||||
|
|
||||||
let version = brocade.version().await.unwrap();
|
let version = brocade.version().await.unwrap();
|
||||||
println!("Version: {version:?}");
|
println!("Version: {version:?}");
|
||||||
|
|
||||||
println!("--------------");
|
println!("--------------");
|
||||||
println!("Showing MAC Address table...");
|
let mac_adddresses = brocade.get_mac_address_table().await.unwrap();
|
||||||
|
|
||||||
let mac_adddresses = brocade.show_mac_address_table().await.unwrap();
|
|
||||||
println!("VLAN\tMAC\t\t\tPORT");
|
println!("VLAN\tMAC\t\t\tPORT");
|
||||||
for mac in mac_adddresses {
|
for mac in mac_adddresses {
|
||||||
println!("{}\t{}\t{}", mac.vlan, mac.mac_address, mac.port);
|
println!("{}\t{}\t{}", mac.vlan, mac.mac_address, mac.port);
|
||||||
}
|
}
|
||||||
|
|
||||||
println!("--------------");
|
println!("--------------");
|
||||||
let channel_name = "HARMONY_LAG";
|
let channel_name = "1";
|
||||||
println!("Clearing port channel '{channel_name}'...");
|
|
||||||
|
|
||||||
brocade.clear_port_channel(channel_name).await.unwrap();
|
brocade.clear_port_channel(channel_name).await.unwrap();
|
||||||
|
|
||||||
println!("Cleared");
|
|
||||||
|
|
||||||
println!("--------------");
|
println!("--------------");
|
||||||
println!("Finding next available channel...");
|
|
||||||
|
|
||||||
let channel_id = brocade.find_available_channel_id().await.unwrap();
|
let channel_id = brocade.find_available_channel_id().await.unwrap();
|
||||||
println!("Channel id: {channel_id}");
|
|
||||||
|
|
||||||
println!("--------------");
|
println!("--------------");
|
||||||
let channel_name = "HARMONY_LAG";
|
let channel_name = "HARMONY_LAG";
|
||||||
let ports = [PortLocation(1, 1, 3), PortLocation(1, 1, 4)];
|
let ports = [PortLocation(2, 0, 35)];
|
||||||
println!("Creating port channel '{channel_name}' with ports {ports:?}'...");
|
|
||||||
|
|
||||||
brocade
|
brocade
|
||||||
.create_port_channel(channel_id, channel_name, &ports)
|
.create_port_channel(channel_id, channel_name, &ports)
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
println!("Created");
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
use super::BrocadeClient;
|
use super::BrocadeClient;
|
||||||
use crate::{
|
use crate::{
|
||||||
BrocadeInfo, Error, ExecutionMode, MacAddressEntry, PortChannelId, parse_brocade_mac_address,
|
BrocadeInfo, Error, ExecutionMode, InterSwitchLink, InterfaceInfo, MacAddressEntry,
|
||||||
shell::BrocadeShell,
|
PortChannelId, PortOperatingMode, parse_brocade_mac_address, shell::BrocadeShell,
|
||||||
};
|
};
|
||||||
|
|
||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
@@ -11,12 +11,22 @@ use regex::Regex;
|
|||||||
use std::{collections::HashSet, str::FromStr};
|
use std::{collections::HashSet, str::FromStr};
|
||||||
|
|
||||||
pub struct FastIronClient {
|
pub struct FastIronClient {
|
||||||
pub shell: BrocadeShell,
|
shell: BrocadeShell,
|
||||||
pub version: BrocadeInfo,
|
version: BrocadeInfo,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl FastIronClient {
|
impl FastIronClient {
|
||||||
pub fn parse_mac_entry(&self, line: &str) -> Option<Result<MacAddressEntry, Error>> {
|
pub fn init(mut shell: BrocadeShell, version_info: BrocadeInfo) -> Self {
|
||||||
|
shell.before_all(vec!["skip-page-display".into()]);
|
||||||
|
shell.after_all(vec!["page".into()]);
|
||||||
|
|
||||||
|
Self {
|
||||||
|
shell,
|
||||||
|
version: version_info,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn parse_mac_entry(&self, line: &str) -> Option<Result<MacAddressEntry, Error>> {
|
||||||
debug!("[Brocade] Parsing mac address entry: {line}");
|
debug!("[Brocade] Parsing mac address entry: {line}");
|
||||||
let parts: Vec<&str> = line.split_whitespace().collect();
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
if parts.len() < 3 {
|
if parts.len() < 3 {
|
||||||
@@ -49,10 +59,25 @@ impl FastIronClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn build_port_channel_commands(
|
fn parse_stack_port_entry(&self, line: &str) -> Option<Result<InterSwitchLink, Error>> {
|
||||||
|
debug!("[Brocade] Parsing stack port entry: {line}");
|
||||||
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
|
if parts.len() < 10 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
let local_port = PortLocation::from_str(parts[0]).ok()?;
|
||||||
|
|
||||||
|
Some(Ok(InterSwitchLink {
|
||||||
|
local_port,
|
||||||
|
remote_port: None, // FIXME: Map the remote port as well
|
||||||
|
}))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn build_port_channel_commands(
|
||||||
&self,
|
&self,
|
||||||
|
channel_id: PortChannelId,
|
||||||
channel_name: &str,
|
channel_name: &str,
|
||||||
channel_id: u8,
|
|
||||||
ports: &[PortLocation],
|
ports: &[PortLocation],
|
||||||
) -> Vec<String> {
|
) -> Vec<String> {
|
||||||
let mut commands = vec![
|
let mut commands = vec![
|
||||||
@@ -80,7 +105,7 @@ impl BrocadeClient for FastIronClient {
|
|||||||
Ok(self.version.clone())
|
Ok(self.version.clone())
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn show_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error> {
|
async fn get_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error> {
|
||||||
info!("[Brocade] Showing MAC address table...");
|
info!("[Brocade] Showing MAC address table...");
|
||||||
|
|
||||||
let output = self
|
let output = self
|
||||||
@@ -95,6 +120,30 @@ impl BrocadeClient for FastIronClient {
|
|||||||
.collect()
|
.collect()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async fn get_stack_topology(&self) -> Result<Vec<InterSwitchLink>, Error> {
|
||||||
|
let output = self
|
||||||
|
.shell
|
||||||
|
.run_command("show interface stack-ports", crate::ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
output
|
||||||
|
.lines()
|
||||||
|
.skip(1)
|
||||||
|
.filter_map(|line| self.parse_stack_port_entry(line))
|
||||||
|
.collect()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_interfaces(&self) -> Result<Vec<InterfaceInfo>, Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn configure_interfaces(
|
||||||
|
&self,
|
||||||
|
_interfaces: Vec<(String, PortOperatingMode)>,
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error> {
|
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error> {
|
||||||
info!("[Brocade] Finding next available channel id...");
|
info!("[Brocade] Finding next available channel id...");
|
||||||
|
|
||||||
@@ -135,7 +184,7 @@ impl BrocadeClient for FastIronClient {
|
|||||||
"[Brocade] Configuring port-channel '{channel_name} {channel_id}' with ports: {ports:?}"
|
"[Brocade] Configuring port-channel '{channel_name} {channel_id}' with ports: {ports:?}"
|
||||||
);
|
);
|
||||||
|
|
||||||
let commands = self.build_port_channel_commands(channel_name, channel_id, ports);
|
let commands = self.build_port_channel_commands(channel_id, channel_name, ports);
|
||||||
self.shell
|
self.shell
|
||||||
.run_commands(commands, ExecutionMode::Privileged)
|
.run_commands(commands, ExecutionMode::Privileged)
|
||||||
.await?;
|
.await?;
|
||||||
@@ -145,7 +194,7 @@ impl BrocadeClient for FastIronClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async fn clear_port_channel(&self, channel_name: &str) -> Result<(), Error> {
|
async fn clear_port_channel(&self, channel_name: &str) -> Result<(), Error> {
|
||||||
debug!("[Brocade] Clearing port-channel: {channel_name}");
|
info!("[Brocade] Clearing port-channel: {channel_name}");
|
||||||
|
|
||||||
let commands = vec![
|
let commands = vec![
|
||||||
"configure terminal".to_string(),
|
"configure terminal".to_string(),
|
||||||
@@ -156,6 +205,7 @@ impl BrocadeClient for FastIronClient {
|
|||||||
.run_commands(commands, ExecutionMode::Privileged)
|
.run_commands(commands, ExecutionMode::Privileged)
|
||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
|
info!("[Brocade] Port-channel '{channel_name}' cleared.");
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ use std::{
|
|||||||
time::Duration,
|
time::Duration,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
use crate::network_operating_system::NetworkOperatingSystemClient;
|
||||||
use crate::{
|
use crate::{
|
||||||
fast_iron::FastIronClient,
|
fast_iron::FastIronClient,
|
||||||
shell::{BrocadeSession, BrocadeShell},
|
shell::{BrocadeSession, BrocadeShell},
|
||||||
@@ -15,6 +16,7 @@ use harmony_types::switch::{PortDeclaration, PortLocation};
|
|||||||
use regex::Regex;
|
use regex::Regex;
|
||||||
|
|
||||||
mod fast_iron;
|
mod fast_iron;
|
||||||
|
mod network_operating_system;
|
||||||
mod shell;
|
mod shell;
|
||||||
mod ssh;
|
mod ssh;
|
||||||
|
|
||||||
@@ -36,7 +38,7 @@ pub struct TimeoutConfig {
|
|||||||
impl Default for TimeoutConfig {
|
impl Default for TimeoutConfig {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
Self {
|
Self {
|
||||||
shell_ready: Duration::from_secs(3),
|
shell_ready: Duration::from_secs(10),
|
||||||
command_execution: Duration::from_secs(60), // Commands like `deploy` (for a LAG) can take a while
|
command_execution: Duration::from_secs(60), // Commands like `deploy` (for a LAG) can take a while
|
||||||
cleanup: Duration::from_secs(10),
|
cleanup: Duration::from_secs(10),
|
||||||
message_wait: Duration::from_millis(500),
|
message_wait: Duration::from_millis(500),
|
||||||
@@ -71,6 +73,70 @@ pub struct MacAddressEntry {
|
|||||||
|
|
||||||
pub type PortChannelId = u8;
|
pub type PortChannelId = u8;
|
||||||
|
|
||||||
|
/// Represents a single physical or logical link connecting two switches within a stack or fabric.
|
||||||
|
///
|
||||||
|
/// This structure provides a standardized view of the topology regardless of the
|
||||||
|
/// underlying Brocade OS configuration (stacking vs. fabric).
|
||||||
|
#[derive(Debug, PartialEq, Eq, Clone)]
|
||||||
|
pub struct InterSwitchLink {
|
||||||
|
/// The local port on the switch where the topology command was run.
|
||||||
|
pub local_port: PortLocation,
|
||||||
|
/// The port on the directly connected neighboring switch.
|
||||||
|
pub remote_port: Option<PortLocation>,
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Represents the key running configuration status of a single switch interface.
|
||||||
|
#[derive(Debug, PartialEq, Eq, Clone)]
|
||||||
|
pub struct InterfaceInfo {
|
||||||
|
/// The full configuration name (e.g., "TenGigabitEthernet 1/0/1", "FortyGigabitEthernet 2/0/2").
|
||||||
|
pub name: String,
|
||||||
|
/// The physical location of the interface.
|
||||||
|
pub port_location: PortLocation,
|
||||||
|
/// The parsed type and name prefix of the interface.
|
||||||
|
pub interface_type: InterfaceType,
|
||||||
|
/// The primary configuration mode defining the interface's behavior (L2, L3, Fabric).
|
||||||
|
pub operating_mode: Option<PortOperatingMode>,
|
||||||
|
/// Indicates the current state of the interface.
|
||||||
|
pub status: InterfaceStatus,
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Categorizes the functional type of a switch interface.
|
||||||
|
#[derive(Debug, PartialEq, Eq, Clone)]
|
||||||
|
pub enum InterfaceType {
|
||||||
|
/// Physical or virtual Ethernet interface (e.g., TenGigabitEthernet, FortyGigabitEthernet).
|
||||||
|
Ethernet(String),
|
||||||
|
}
|
||||||
|
|
||||||
|
impl fmt::Display for InterfaceType {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
|
||||||
|
match self {
|
||||||
|
InterfaceType::Ethernet(name) => write!(f, "{name}"),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Defines the primary configuration mode of a switch interface, representing mutually exclusive roles.
|
||||||
|
#[derive(Debug, PartialEq, Eq, Clone)]
|
||||||
|
pub enum PortOperatingMode {
|
||||||
|
/// The interface is explicitly configured for Brocade fabric roles (ISL or Trunk enabled).
|
||||||
|
Fabric,
|
||||||
|
/// The interface is configured for standard Layer 2 switching as Trunk port (`switchport mode trunk`).
|
||||||
|
Trunk,
|
||||||
|
/// The interface is configured for standard Layer 2 switching as Access port (`switchport` without trunk mode).
|
||||||
|
Access,
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Defines the possible status of an interface.
|
||||||
|
#[derive(Debug, PartialEq, Eq, Clone)]
|
||||||
|
pub enum InterfaceStatus {
|
||||||
|
/// The interface is connected.
|
||||||
|
Connected,
|
||||||
|
/// The interface is not connected and is not expected to be.
|
||||||
|
NotConnected,
|
||||||
|
/// The interface is not connected but is expected to be (configured with `no shutdown`).
|
||||||
|
SfpAbsent,
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn init(
|
pub async fn init(
|
||||||
ip_addresses: &[IpAddr],
|
ip_addresses: &[IpAddr],
|
||||||
port: u16,
|
port: u16,
|
||||||
@@ -87,23 +153,81 @@ pub async fn init(
|
|||||||
.await?;
|
.await?;
|
||||||
|
|
||||||
Ok(match version_info.os {
|
Ok(match version_info.os {
|
||||||
BrocadeOs::FastIron => Box::new(FastIronClient {
|
BrocadeOs::FastIron => Box::new(FastIronClient::init(shell, version_info)),
|
||||||
shell,
|
BrocadeOs::NetworkOperatingSystem => {
|
||||||
version: version_info,
|
Box::new(NetworkOperatingSystemClient::init(shell, version_info))
|
||||||
}),
|
}
|
||||||
BrocadeOs::NetworkOperatingSystem => todo!(),
|
|
||||||
BrocadeOs::Unknown => todo!(),
|
BrocadeOs::Unknown => todo!(),
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
pub trait BrocadeClient {
|
pub trait BrocadeClient {
|
||||||
|
/// Retrieves the operating system and version details from the connected Brocade switch.
|
||||||
|
///
|
||||||
|
/// This is typically the first call made after establishing a connection to determine
|
||||||
|
/// the switch OS family (e.g., FastIron, NOS) for feature compatibility.
|
||||||
|
///
|
||||||
|
/// # Returns
|
||||||
|
///
|
||||||
|
/// A `BrocadeInfo` structure containing parsed OS type and version string.
|
||||||
async fn version(&self) -> Result<BrocadeInfo, Error>;
|
async fn version(&self) -> Result<BrocadeInfo, Error>;
|
||||||
|
|
||||||
async fn show_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error>;
|
/// Retrieves the dynamically learned MAC address table from the switch.
|
||||||
|
///
|
||||||
|
/// This is crucial for discovering where specific network endpoints (MAC addresses)
|
||||||
|
/// are currently located on the physical ports.
|
||||||
|
///
|
||||||
|
/// # Returns
|
||||||
|
///
|
||||||
|
/// A vector of `MacAddressEntry`, where each entry typically contains VLAN, MAC address,
|
||||||
|
/// and the associated port name/index.
|
||||||
|
async fn get_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error>;
|
||||||
|
|
||||||
|
/// Derives the physical connections used to link multiple switches together
|
||||||
|
/// to form a single logical entity (stack, fabric, etc.).
|
||||||
|
///
|
||||||
|
/// This abstracts the underlying configuration (e.g., stack ports, fabric ports)
|
||||||
|
/// to return a standardized view of the topology.
|
||||||
|
///
|
||||||
|
/// # Returns
|
||||||
|
///
|
||||||
|
/// A vector of `InterSwitchLink` structs detailing which ports are used for stacking/fabric.
|
||||||
|
/// If the switch is not stacked, returns an empty vector.
|
||||||
|
async fn get_stack_topology(&self) -> Result<Vec<InterSwitchLink>, Error>;
|
||||||
|
|
||||||
|
/// Retrieves the status for all interfaces
|
||||||
|
///
|
||||||
|
/// # Returns
|
||||||
|
///
|
||||||
|
/// A vector of `InterfaceInfo` structures.
|
||||||
|
async fn get_interfaces(&self) -> Result<Vec<InterfaceInfo>, Error>;
|
||||||
|
|
||||||
|
/// Configures a set of interfaces to be operated with a specified mode (access ports, ISL, etc.).
|
||||||
|
async fn configure_interfaces(
|
||||||
|
&self,
|
||||||
|
interfaces: Vec<(String, PortOperatingMode)>,
|
||||||
|
) -> Result<(), Error>;
|
||||||
|
|
||||||
|
/// Scans the existing configuration to find the next available (unused)
|
||||||
|
/// Port-Channel ID (`lag` or `trunk`) for assignment.
|
||||||
|
///
|
||||||
|
/// # Returns
|
||||||
|
///
|
||||||
|
/// The smallest, unassigned `PortChannelId` within the supported range.
|
||||||
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error>;
|
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error>;
|
||||||
|
|
||||||
|
/// Creates and configures a new Port-Channel (Link Aggregation Group or LAG)
|
||||||
|
/// using the specified channel ID and ports.
|
||||||
|
///
|
||||||
|
/// The resulting configuration must be persistent (saved to startup-config).
|
||||||
|
/// Assumes a static LAG configuration mode unless specified otherwise by the implementation.
|
||||||
|
///
|
||||||
|
/// # Parameters
|
||||||
|
///
|
||||||
|
/// * `channel_id`: The ID (e.g., 1-128) for the logical port channel.
|
||||||
|
/// * `channel_name`: A descriptive name for the LAG (used in configuration context).
|
||||||
|
/// * `ports`: A slice of `PortLocation` structs defining the physical member ports.
|
||||||
async fn create_port_channel(
|
async fn create_port_channel(
|
||||||
&self,
|
&self,
|
||||||
channel_id: PortChannelId,
|
channel_id: PortChannelId,
|
||||||
@@ -111,6 +235,15 @@ pub trait BrocadeClient {
|
|||||||
ports: &[PortLocation],
|
ports: &[PortLocation],
|
||||||
) -> Result<(), Error>;
|
) -> Result<(), Error>;
|
||||||
|
|
||||||
|
/// Removes all configuration associated with the specified Port-Channel name.
|
||||||
|
///
|
||||||
|
/// This operation should be idempotent; attempting to clear a non-existent
|
||||||
|
/// channel should succeed (or return a benign error).
|
||||||
|
///
|
||||||
|
/// # Parameters
|
||||||
|
///
|
||||||
|
/// * `channel_name`: The name of the Port-Channel (LAG) to delete.
|
||||||
|
///
|
||||||
async fn clear_port_channel(&self, channel_name: &str) -> Result<(), Error>;
|
async fn clear_port_channel(&self, channel_name: &str) -> Result<(), Error>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
306
brocade/src/network_operating_system.rs
Normal file
306
brocade/src/network_operating_system.rs
Normal file
@@ -0,0 +1,306 @@
|
|||||||
|
use std::str::FromStr;
|
||||||
|
|
||||||
|
use async_trait::async_trait;
|
||||||
|
use harmony_types::switch::{PortDeclaration, PortLocation};
|
||||||
|
use log::{debug, info};
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
BrocadeClient, BrocadeInfo, Error, ExecutionMode, InterSwitchLink, InterfaceInfo,
|
||||||
|
InterfaceStatus, InterfaceType, MacAddressEntry, PortChannelId, PortOperatingMode,
|
||||||
|
parse_brocade_mac_address, shell::BrocadeShell,
|
||||||
|
};
|
||||||
|
|
||||||
|
pub struct NetworkOperatingSystemClient {
|
||||||
|
shell: BrocadeShell,
|
||||||
|
version: BrocadeInfo,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl NetworkOperatingSystemClient {
|
||||||
|
pub fn init(mut shell: BrocadeShell, version_info: BrocadeInfo) -> Self {
|
||||||
|
shell.before_all(vec!["terminal length 0".into()]);
|
||||||
|
|
||||||
|
Self {
|
||||||
|
shell,
|
||||||
|
version: version_info,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn parse_mac_entry(&self, line: &str) -> Option<Result<MacAddressEntry, Error>> {
|
||||||
|
debug!("[Brocade] Parsing mac address entry: {line}");
|
||||||
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
|
if parts.len() < 5 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
let (vlan, mac_address, port) = match parts.len() {
|
||||||
|
5 => (
|
||||||
|
u16::from_str(parts[0]).ok()?,
|
||||||
|
parse_brocade_mac_address(parts[1]).ok()?,
|
||||||
|
parts[4].to_string(),
|
||||||
|
),
|
||||||
|
_ => (
|
||||||
|
u16::from_str(parts[0]).ok()?,
|
||||||
|
parse_brocade_mac_address(parts[1]).ok()?,
|
||||||
|
parts[5].to_string(),
|
||||||
|
),
|
||||||
|
};
|
||||||
|
|
||||||
|
let port =
|
||||||
|
PortDeclaration::parse(&port).map_err(|e| Error::UnexpectedError(format!("{e}")));
|
||||||
|
|
||||||
|
match port {
|
||||||
|
Ok(p) => Some(Ok(MacAddressEntry {
|
||||||
|
vlan,
|
||||||
|
mac_address,
|
||||||
|
port: p,
|
||||||
|
})),
|
||||||
|
Err(e) => Some(Err(e)),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn parse_inter_switch_link_entry(&self, line: &str) -> Option<Result<InterSwitchLink, Error>> {
|
||||||
|
debug!("[Brocade] Parsing inter switch link entry: {line}");
|
||||||
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
|
if parts.len() < 10 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
let local_port = PortLocation::from_str(parts[2]).ok()?;
|
||||||
|
let remote_port = PortLocation::from_str(parts[5]).ok()?;
|
||||||
|
|
||||||
|
Some(Ok(InterSwitchLink {
|
||||||
|
local_port,
|
||||||
|
remote_port: Some(remote_port),
|
||||||
|
}))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn parse_interface_status_entry(&self, line: &str) -> Option<Result<InterfaceInfo, Error>> {
|
||||||
|
debug!("[Brocade] Parsing interface status entry: {line}");
|
||||||
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
|
if parts.len() < 6 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
let interface_type = match parts[0] {
|
||||||
|
"Fo" => InterfaceType::Ethernet("FortyGigabitEthernet".to_string()),
|
||||||
|
"Te" => InterfaceType::Ethernet("TenGigabitEthernet".to_string()),
|
||||||
|
_ => return None,
|
||||||
|
};
|
||||||
|
let port_location = PortLocation::from_str(parts[1]).ok()?;
|
||||||
|
let status = match parts[2] {
|
||||||
|
"connected" => InterfaceStatus::Connected,
|
||||||
|
"notconnected" => InterfaceStatus::NotConnected,
|
||||||
|
"sfpAbsent" => InterfaceStatus::SfpAbsent,
|
||||||
|
_ => return None,
|
||||||
|
};
|
||||||
|
let operating_mode = match parts[3] {
|
||||||
|
"ISL" => Some(PortOperatingMode::Fabric),
|
||||||
|
"Trunk" => Some(PortOperatingMode::Trunk),
|
||||||
|
"Access" => Some(PortOperatingMode::Access),
|
||||||
|
"--" => None,
|
||||||
|
_ => return None,
|
||||||
|
};
|
||||||
|
|
||||||
|
Some(Ok(InterfaceInfo {
|
||||||
|
name: format!("{} {}", interface_type, port_location),
|
||||||
|
port_location,
|
||||||
|
interface_type,
|
||||||
|
operating_mode,
|
||||||
|
status,
|
||||||
|
}))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[async_trait]
|
||||||
|
impl BrocadeClient for NetworkOperatingSystemClient {
|
||||||
|
async fn version(&self) -> Result<BrocadeInfo, Error> {
|
||||||
|
Ok(self.version.clone())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error> {
|
||||||
|
let output = self
|
||||||
|
.shell
|
||||||
|
.run_command("show mac-address-table", ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
output
|
||||||
|
.lines()
|
||||||
|
.skip(1)
|
||||||
|
.filter_map(|line| self.parse_mac_entry(line))
|
||||||
|
.collect()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_stack_topology(&self) -> Result<Vec<InterSwitchLink>, Error> {
|
||||||
|
let output = self
|
||||||
|
.shell
|
||||||
|
.run_command("show fabric isl", ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
output
|
||||||
|
.lines()
|
||||||
|
.skip(6)
|
||||||
|
.filter_map(|line| self.parse_inter_switch_link_entry(line))
|
||||||
|
.collect()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_interfaces(&self) -> Result<Vec<InterfaceInfo>, Error> {
|
||||||
|
let output = self
|
||||||
|
.shell
|
||||||
|
.run_command(
|
||||||
|
"show interface status rbridge-id all",
|
||||||
|
ExecutionMode::Regular,
|
||||||
|
)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
output
|
||||||
|
.lines()
|
||||||
|
.skip(2)
|
||||||
|
.filter_map(|line| self.parse_interface_status_entry(line))
|
||||||
|
.collect()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn configure_interfaces(
|
||||||
|
&self,
|
||||||
|
interfaces: Vec<(String, PortOperatingMode)>,
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
info!("[Brocade] Configuring {} interface(s)...", interfaces.len());
|
||||||
|
|
||||||
|
let mut commands = vec!["configure terminal".to_string()];
|
||||||
|
|
||||||
|
for interface in interfaces {
|
||||||
|
commands.push(format!("interface {}", interface.0));
|
||||||
|
|
||||||
|
match interface.1 {
|
||||||
|
PortOperatingMode::Fabric => {
|
||||||
|
commands.push("fabric isl enable".into());
|
||||||
|
commands.push("fabric trunk enable".into());
|
||||||
|
}
|
||||||
|
PortOperatingMode::Trunk => {
|
||||||
|
commands.push("switchport".into());
|
||||||
|
commands.push("switchport mode trunk".into());
|
||||||
|
commands.push("no spanning-tree shutdown".into());
|
||||||
|
commands.push("no fabric isl enable".into());
|
||||||
|
commands.push("no fabric trunk enable".into());
|
||||||
|
}
|
||||||
|
PortOperatingMode::Access => {
|
||||||
|
commands.push("switchport".into());
|
||||||
|
commands.push("switchport mode access".into());
|
||||||
|
commands.push("switchport access vlan 1".into());
|
||||||
|
commands.push("no spanning-tree shutdown".into());
|
||||||
|
commands.push("no fabric isl enable".into());
|
||||||
|
commands.push("no fabric trunk enable".into());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
commands.push("no shutdown".into());
|
||||||
|
commands.push("exit".into());
|
||||||
|
}
|
||||||
|
|
||||||
|
commands.push("write memory".into());
|
||||||
|
|
||||||
|
self.shell
|
||||||
|
.run_commands(commands, ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
info!("[Brocade] Interfaces configured.");
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error> {
|
||||||
|
info!("[Brocade] Finding next available channel id...");
|
||||||
|
|
||||||
|
let output = self
|
||||||
|
.shell
|
||||||
|
.run_command("show port-channel", ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
let used_ids: Vec<u8> = output
|
||||||
|
.lines()
|
||||||
|
.skip(6)
|
||||||
|
.filter_map(|line| {
|
||||||
|
let parts: Vec<&str> = line.split_whitespace().collect();
|
||||||
|
if parts.len() < 8 {
|
||||||
|
return None;
|
||||||
|
}
|
||||||
|
|
||||||
|
u8::from_str(parts[0]).ok()
|
||||||
|
})
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
let mut next_id: u8 = 1;
|
||||||
|
loop {
|
||||||
|
if !used_ids.contains(&next_id) {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
next_id += 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
info!("[Brocade] Found channel id: {next_id}");
|
||||||
|
Ok(next_id)
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn create_port_channel(
|
||||||
|
&self,
|
||||||
|
channel_id: PortChannelId,
|
||||||
|
channel_name: &str,
|
||||||
|
ports: &[PortLocation],
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
info!(
|
||||||
|
"[Brocade] Configuring port-channel '{channel_name} {channel_id}' with ports: {ports:?}"
|
||||||
|
);
|
||||||
|
|
||||||
|
let interfaces = self.get_interfaces().await?;
|
||||||
|
|
||||||
|
let mut commands = vec![
|
||||||
|
"configure terminal".into(),
|
||||||
|
format!("interface port-channel {}", channel_id),
|
||||||
|
"no shutdown".into(),
|
||||||
|
"exit".into(),
|
||||||
|
];
|
||||||
|
|
||||||
|
for port in ports {
|
||||||
|
let interface = interfaces.iter().find(|i| i.port_location == *port);
|
||||||
|
let Some(interface) = interface else {
|
||||||
|
continue;
|
||||||
|
};
|
||||||
|
|
||||||
|
commands.push(format!("interface {}", interface.name));
|
||||||
|
commands.push("no switchport".into());
|
||||||
|
commands.push("no ip address".into());
|
||||||
|
commands.push("no fabric isl enable".into());
|
||||||
|
commands.push("no fabric trunk enable".into());
|
||||||
|
commands.push(format!("channel-group {} mode active", channel_id));
|
||||||
|
commands.push("no shutdown".into());
|
||||||
|
commands.push("exit".into());
|
||||||
|
}
|
||||||
|
|
||||||
|
commands.push("write memory".into());
|
||||||
|
|
||||||
|
self.shell
|
||||||
|
.run_commands(commands, ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
info!("[Brocade] Port-channel '{channel_name}' configured.");
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn clear_port_channel(&self, channel_name: &str) -> Result<(), Error> {
|
||||||
|
info!("[Brocade] Clearing port-channel: {channel_name}");
|
||||||
|
|
||||||
|
let commands = vec![
|
||||||
|
"configure terminal".into(),
|
||||||
|
format!("no interface port-channel {}", channel_name),
|
||||||
|
"exit".into(),
|
||||||
|
"write memory".into(),
|
||||||
|
];
|
||||||
|
|
||||||
|
self.shell
|
||||||
|
.run_commands(commands, ExecutionMode::Regular)
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
info!("[Brocade] Port-channel '{channel_name}' cleared.");
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -14,11 +14,13 @@ use russh::ChannelMsg;
|
|||||||
use tokio::time::timeout;
|
use tokio::time::timeout;
|
||||||
|
|
||||||
pub struct BrocadeShell {
|
pub struct BrocadeShell {
|
||||||
pub ip: IpAddr,
|
ip: IpAddr,
|
||||||
pub port: u16,
|
port: u16,
|
||||||
pub username: String,
|
username: String,
|
||||||
pub password: String,
|
password: String,
|
||||||
pub options: BrocadeOptions,
|
options: BrocadeOptions,
|
||||||
|
before_all_commands: Vec<String>,
|
||||||
|
after_all_commands: Vec<String>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl BrocadeShell {
|
impl BrocadeShell {
|
||||||
@@ -41,6 +43,8 @@ impl BrocadeShell {
|
|||||||
port,
|
port,
|
||||||
username: username.to_string(),
|
username: username.to_string(),
|
||||||
password: password.to_string(),
|
password: password.to_string(),
|
||||||
|
before_all_commands: vec![],
|
||||||
|
after_all_commands: vec![],
|
||||||
options,
|
options,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -66,14 +70,22 @@ impl BrocadeShell {
|
|||||||
>,
|
>,
|
||||||
{
|
{
|
||||||
let mut session = self.open_session(mode).await?;
|
let mut session = self.open_session(mode).await?;
|
||||||
|
|
||||||
|
let _ = session.run_commands(self.before_all_commands.clone()).await;
|
||||||
let result = callback(&mut session).await;
|
let result = callback(&mut session).await;
|
||||||
|
let _ = session.run_commands(self.after_all_commands.clone()).await;
|
||||||
|
|
||||||
session.close().await?;
|
session.close().await?;
|
||||||
result
|
result
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn run_command(&self, command: &str, mode: ExecutionMode) -> Result<String, Error> {
|
pub async fn run_command(&self, command: &str, mode: ExecutionMode) -> Result<String, Error> {
|
||||||
let mut session = self.open_session(mode).await?;
|
let mut session = self.open_session(mode).await?;
|
||||||
|
|
||||||
|
let _ = session.run_commands(self.before_all_commands.clone()).await;
|
||||||
let result = session.run_command(command).await;
|
let result = session.run_command(command).await;
|
||||||
|
let _ = session.run_commands(self.after_all_commands.clone()).await;
|
||||||
|
|
||||||
session.close().await?;
|
session.close().await?;
|
||||||
result
|
result
|
||||||
}
|
}
|
||||||
@@ -84,10 +96,22 @@ impl BrocadeShell {
|
|||||||
mode: ExecutionMode,
|
mode: ExecutionMode,
|
||||||
) -> Result<(), Error> {
|
) -> Result<(), Error> {
|
||||||
let mut session = self.open_session(mode).await?;
|
let mut session = self.open_session(mode).await?;
|
||||||
|
|
||||||
|
let _ = session.run_commands(self.before_all_commands.clone()).await;
|
||||||
let result = session.run_commands(commands).await;
|
let result = session.run_commands(commands).await;
|
||||||
|
let _ = session.run_commands(self.after_all_commands.clone()).await;
|
||||||
|
|
||||||
session.close().await?;
|
session.close().await?;
|
||||||
result
|
result
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn before_all(&mut self, commands: Vec<String>) {
|
||||||
|
self.before_all_commands = commands;
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn after_all(&mut self, commands: Vec<String>) {
|
||||||
|
self.after_all_commands = commands;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub struct BrocadeSession {
|
pub struct BrocadeSession {
|
||||||
@@ -148,6 +172,10 @@ impl BrocadeSession {
|
|||||||
}
|
}
|
||||||
|
|
||||||
pub async fn run_command(&mut self, command: &str) -> Result<String, Error> {
|
pub async fn run_command(&mut self, command: &str) -> Result<String, Error> {
|
||||||
|
if self.should_skip_command(command) {
|
||||||
|
return Ok(String::new());
|
||||||
|
}
|
||||||
|
|
||||||
debug!("[Brocade] Running command: '{command}'...");
|
debug!("[Brocade] Running command: '{command}'...");
|
||||||
|
|
||||||
self.channel
|
self.channel
|
||||||
@@ -170,7 +198,15 @@ impl BrocadeSession {
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn collect_command_output(&mut self) -> Result<Vec<u8>, Error> {
|
fn should_skip_command(&self, command: &str) -> bool {
|
||||||
|
if (command.starts_with("write") || command.starts_with("deploy")) && self.options.dry_run {
|
||||||
|
info!("[Brocade] Dry-run mode enabled, skipping command: {command}");
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
false
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn collect_command_output(&mut self) -> Result<Vec<u8>, Error> {
|
||||||
let mut output = Vec::new();
|
let mut output = Vec::new();
|
||||||
let start = Instant::now();
|
let start = Instant::now();
|
||||||
let read_timeout = Duration::from_millis(500);
|
let read_timeout = Duration::from_millis(500);
|
||||||
@@ -222,7 +258,7 @@ impl BrocadeSession {
|
|||||||
Ok(output)
|
Ok(output)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn check_for_command_errors(&self, output: &str, command: &str) -> Result<(), Error> {
|
fn check_for_command_errors(&self, output: &str, command: &str) -> Result<(), Error> {
|
||||||
const ERROR_PATTERNS: &[&str] = &[
|
const ERROR_PATTERNS: &[&str] = &[
|
||||||
"invalid input",
|
"invalid input",
|
||||||
"syntax error",
|
"syntax error",
|
||||||
@@ -254,7 +290,7 @@ impl BrocadeSession {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn wait_for_shell_ready(
|
async fn wait_for_shell_ready(
|
||||||
channel: &mut russh::Channel<russh::client::Msg>,
|
channel: &mut russh::Channel<russh::client::Msg>,
|
||||||
timeouts: &TimeoutConfig,
|
timeouts: &TimeoutConfig,
|
||||||
) -> Result<(), Error> {
|
) -> Result<(), Error> {
|
||||||
@@ -266,6 +302,7 @@ pub async fn wait_for_shell_ready(
|
|||||||
Ok(Some(ChannelMsg::Data { data })) => {
|
Ok(Some(ChannelMsg::Data { data })) => {
|
||||||
buffer.extend_from_slice(&data);
|
buffer.extend_from_slice(&data);
|
||||||
let output = String::from_utf8_lossy(&buffer);
|
let output = String::from_utf8_lossy(&buffer);
|
||||||
|
let output = output.trim();
|
||||||
if output.ends_with('>') || output.ends_with('#') {
|
if output.ends_with('>') || output.ends_with('#') {
|
||||||
debug!("[Brocade] Shell ready");
|
debug!("[Brocade] Shell ready");
|
||||||
return Ok(());
|
return Ok(());
|
||||||
@@ -279,7 +316,7 @@ pub async fn wait_for_shell_ready(
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
pub async fn try_elevate_session(
|
async fn try_elevate_session(
|
||||||
channel: &mut russh::Channel<russh::client::Msg>,
|
channel: &mut russh::Channel<russh::client::Msg>,
|
||||||
username: &str,
|
username: &str,
|
||||||
password: &str,
|
password: &str,
|
||||||
|
|||||||
14
examples/openbao/Cargo.toml
Normal file
14
examples/openbao/Cargo.toml
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
[package]
|
||||||
|
name = "example-openbao"
|
||||||
|
edition = "2024"
|
||||||
|
version.workspace = true
|
||||||
|
readme.workspace = true
|
||||||
|
license.workspace = true
|
||||||
|
|
||||||
|
[dependencies]
|
||||||
|
harmony = { path = "../../harmony" }
|
||||||
|
harmony_cli = { path = "../../harmony_cli" }
|
||||||
|
harmony_macros = { path = "../../harmony_macros" }
|
||||||
|
harmony_types = { path = "../../harmony_types" }
|
||||||
|
tokio.workspace = true
|
||||||
|
url.workspace = true
|
||||||
7
examples/openbao/README.md
Normal file
7
examples/openbao/README.md
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
To install an openbao instance with harmony simply `cargo run -p example-openbao` .
|
||||||
|
|
||||||
|
Depending on your environement configuration, it will either install a k3d cluster locally and deploy on it, or install to a remote cluster.
|
||||||
|
|
||||||
|
Then follow the openbao documentation to initialize and unseal, this will make openbao usable.
|
||||||
|
|
||||||
|
https://openbao.org/docs/platform/k8s/helm/run/
|
||||||
67
examples/openbao/src/main.rs
Normal file
67
examples/openbao/src/main.rs
Normal file
@@ -0,0 +1,67 @@
|
|||||||
|
use std::{collections::HashMap, str::FromStr};
|
||||||
|
|
||||||
|
use harmony::{
|
||||||
|
inventory::Inventory,
|
||||||
|
modules::helm::chart::{HelmChartScore, HelmRepository, NonBlankString},
|
||||||
|
topology::K8sAnywhereTopology,
|
||||||
|
};
|
||||||
|
use harmony_macros::hurl;
|
||||||
|
|
||||||
|
#[tokio::main]
|
||||||
|
async fn main() {
|
||||||
|
let values_yaml = Some(
|
||||||
|
r#"server:
|
||||||
|
standalone:
|
||||||
|
enabled: true
|
||||||
|
config: |
|
||||||
|
listener "tcp" {
|
||||||
|
tls_disable = true
|
||||||
|
address = "[::]:8200"
|
||||||
|
cluster_address = "[::]:8201"
|
||||||
|
}
|
||||||
|
|
||||||
|
storage "file" {
|
||||||
|
path = "/openbao/data"
|
||||||
|
}
|
||||||
|
|
||||||
|
service:
|
||||||
|
enabled: true
|
||||||
|
|
||||||
|
dataStorage:
|
||||||
|
enabled: true
|
||||||
|
size: 10Gi
|
||||||
|
storageClass: null
|
||||||
|
accessMode: ReadWriteOnce
|
||||||
|
|
||||||
|
auditStorage:
|
||||||
|
enabled: true
|
||||||
|
size: 10Gi
|
||||||
|
storageClass: null
|
||||||
|
accessMode: ReadWriteOnce"#
|
||||||
|
.to_string(),
|
||||||
|
);
|
||||||
|
let openbao = HelmChartScore {
|
||||||
|
namespace: Some(NonBlankString::from_str("openbao").unwrap()),
|
||||||
|
release_name: NonBlankString::from_str("openbao").unwrap(),
|
||||||
|
chart_name: NonBlankString::from_str("openbao/openbao").unwrap(),
|
||||||
|
chart_version: None,
|
||||||
|
values_overrides: None,
|
||||||
|
values_yaml,
|
||||||
|
create_namespace: true,
|
||||||
|
install_only: true,
|
||||||
|
repository: Some(HelmRepository::new(
|
||||||
|
"openbao".to_string(),
|
||||||
|
hurl!("https://openbao.github.io/openbao-helm"),
|
||||||
|
true,
|
||||||
|
)),
|
||||||
|
};
|
||||||
|
|
||||||
|
harmony_cli::run(
|
||||||
|
Inventory::autoload(),
|
||||||
|
K8sAnywhereTopology::from_env(),
|
||||||
|
vec![Box::new(openbao)],
|
||||||
|
None,
|
||||||
|
)
|
||||||
|
.await
|
||||||
|
.unwrap();
|
||||||
|
}
|
||||||
@@ -78,6 +78,7 @@ askama.workspace = true
|
|||||||
sqlx.workspace = true
|
sqlx.workspace = true
|
||||||
inquire.workspace = true
|
inquire.workspace = true
|
||||||
brocade = { path = "../brocade" }
|
brocade = { path = "../brocade" }
|
||||||
|
option-ext = "0.2.0"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
pretty_assertions.workspace = true
|
pretty_assertions.workspace = true
|
||||||
|
|||||||
@@ -513,6 +513,12 @@ impl HttpServer for HAClusterTopology {
|
|||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
impl Switch for HAClusterTopology {
|
impl Switch for HAClusterTopology {
|
||||||
|
async fn setup_switch(&self) -> Result<(), SwitchError> {
|
||||||
|
let client = self.get_switch_client().await?;
|
||||||
|
client.setup().await?;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
async fn get_port_for_mac_address(
|
async fn get_port_for_mac_address(
|
||||||
&self,
|
&self,
|
||||||
mac_address: &MacAddress,
|
mac_address: &MacAddress,
|
||||||
|
|||||||
@@ -1,13 +1,19 @@
|
|||||||
|
use std::time::Duration;
|
||||||
|
|
||||||
use derive_new::new;
|
use derive_new::new;
|
||||||
use k8s_openapi::{
|
use k8s_openapi::{
|
||||||
ClusterResourceScope, NamespaceResourceScope,
|
ClusterResourceScope, NamespaceResourceScope,
|
||||||
api::{apps::v1::Deployment, core::v1::Pod},
|
api::{
|
||||||
|
apps::v1::Deployment,
|
||||||
|
core::v1::{Pod, PodStatus},
|
||||||
|
},
|
||||||
};
|
};
|
||||||
use kube::{
|
use kube::{
|
||||||
Client, Config, Error, Resource,
|
Client, Config, Error, Resource,
|
||||||
api::{Api, AttachParams, DeleteParams, ListParams, Patch, PatchParams, ResourceExt},
|
api::{Api, AttachParams, DeleteParams, ListParams, Patch, PatchParams, ResourceExt},
|
||||||
config::{KubeConfigOptions, Kubeconfig},
|
config::{KubeConfigOptions, Kubeconfig},
|
||||||
core::ErrorResponse,
|
core::ErrorResponse,
|
||||||
|
error::DiscoveryError,
|
||||||
runtime::reflector::Lookup,
|
runtime::reflector::Lookup,
|
||||||
};
|
};
|
||||||
use kube::{api::DynamicObject, runtime::conditions};
|
use kube::{api::DynamicObject, runtime::conditions};
|
||||||
@@ -19,7 +25,7 @@ use log::{debug, error, trace};
|
|||||||
use serde::{Serialize, de::DeserializeOwned};
|
use serde::{Serialize, de::DeserializeOwned};
|
||||||
use serde_json::{Value, json};
|
use serde_json::{Value, json};
|
||||||
use similar::TextDiff;
|
use similar::TextDiff;
|
||||||
use tokio::io::AsyncReadExt;
|
use tokio::{io::AsyncReadExt, time::sleep};
|
||||||
|
|
||||||
#[derive(new, Clone)]
|
#[derive(new, Clone)]
|
||||||
pub struct K8sClient {
|
pub struct K8sClient {
|
||||||
@@ -153,6 +159,41 @@ impl K8sClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn wait_for_pod_ready(
|
||||||
|
&self,
|
||||||
|
pod_name: &str,
|
||||||
|
namespace: Option<&str>,
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
let mut elapsed = 0;
|
||||||
|
let interval = 5; // seconds between checks
|
||||||
|
let timeout_secs = 120;
|
||||||
|
loop {
|
||||||
|
let pod = self.get_pod(pod_name, namespace).await?;
|
||||||
|
|
||||||
|
if let Some(p) = pod {
|
||||||
|
if let Some(status) = p.status {
|
||||||
|
if let Some(phase) = status.phase {
|
||||||
|
if phase.to_lowercase() == "running" {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if elapsed >= timeout_secs {
|
||||||
|
return Err(Error::Discovery(DiscoveryError::MissingResource(format!(
|
||||||
|
"'{}' in ns '{}' did not become ready within {}s",
|
||||||
|
pod_name,
|
||||||
|
namespace.unwrap(),
|
||||||
|
timeout_secs
|
||||||
|
))));
|
||||||
|
}
|
||||||
|
|
||||||
|
sleep(Duration::from_secs(interval)).await;
|
||||||
|
elapsed += interval;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Will execute a commond in the first pod found that matches the specified label
|
/// Will execute a commond in the first pod found that matches the specified label
|
||||||
/// '{label}={name}'
|
/// '{label}={name}'
|
||||||
pub async fn exec_app_capture_output(
|
pub async fn exec_app_capture_output(
|
||||||
@@ -419,9 +460,12 @@ impl K8sClient {
|
|||||||
.as_str()
|
.as_str()
|
||||||
.expect("couldn't get kind as str");
|
.expect("couldn't get kind as str");
|
||||||
|
|
||||||
let split: Vec<&str> = api_version.splitn(2, "/").collect();
|
let mut it = api_version.splitn(2, '/');
|
||||||
let g = split[0];
|
let first = it.next().unwrap();
|
||||||
let v = split[1];
|
let (g, v) = match it.next() {
|
||||||
|
Some(second) => (first, second),
|
||||||
|
None => ("", first),
|
||||||
|
};
|
||||||
|
|
||||||
let gvk = GroupVersionKind::gvk(g, v, kind);
|
let gvk = GroupVersionKind::gvk(g, v, kind);
|
||||||
let api_resource = ApiResource::from_gvk(&gvk);
|
let api_resource = ApiResource::from_gvk(&gvk);
|
||||||
|
|||||||
@@ -178,6 +178,8 @@ impl FromStr for DnsRecordType {
|
|||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
pub trait Switch: Send + Sync {
|
pub trait Switch: Send + Sync {
|
||||||
|
async fn setup_switch(&self) -> Result<(), SwitchError>;
|
||||||
|
|
||||||
async fn get_port_for_mac_address(
|
async fn get_port_for_mac_address(
|
||||||
&self,
|
&self,
|
||||||
mac_address: &MacAddress,
|
mac_address: &MacAddress,
|
||||||
@@ -224,6 +226,18 @@ impl Error for SwitchError {}
|
|||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
pub trait SwitchClient: Send + Sync {
|
pub trait SwitchClient: Send + Sync {
|
||||||
|
/// Executes essential, idempotent, one-time initial configuration steps.
|
||||||
|
///
|
||||||
|
/// This is an opiniated procedure that setups a switch to provide high availability
|
||||||
|
/// capabilities as decided by the NationTech team.
|
||||||
|
///
|
||||||
|
/// This includes tasks like enabling switchport for all interfaces
|
||||||
|
/// except the ones intended for Fabric Networking, etc.
|
||||||
|
///
|
||||||
|
/// The implementation must ensure the operation is **idempotent** (safe to run multiple times)
|
||||||
|
/// and that it doesn't break existing configurations.
|
||||||
|
async fn setup(&self) -> Result<(), SwitchError>;
|
||||||
|
|
||||||
async fn find_port(
|
async fn find_port(
|
||||||
&self,
|
&self,
|
||||||
mac_address: &MacAddress,
|
mac_address: &MacAddress,
|
||||||
|
|||||||
@@ -1,10 +1,11 @@
|
|||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
use brocade::{BrocadeClient, BrocadeOptions};
|
use brocade::{BrocadeClient, BrocadeOptions, InterSwitchLink, InterfaceStatus, PortOperatingMode};
|
||||||
use harmony_secret::Secret;
|
use harmony_secret::Secret;
|
||||||
use harmony_types::{
|
use harmony_types::{
|
||||||
net::{IpAddress, MacAddress},
|
net::{IpAddress, MacAddress},
|
||||||
switch::{PortDeclaration, PortLocation},
|
switch::{PortDeclaration, PortLocation},
|
||||||
};
|
};
|
||||||
|
use option_ext::OptionExt;
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
use crate::topology::{SwitchClient, SwitchError};
|
use crate::topology::{SwitchClient, SwitchError};
|
||||||
@@ -27,13 +28,52 @@ impl BrocadeSwitchClient {
|
|||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
impl SwitchClient for BrocadeSwitchClient {
|
impl SwitchClient for BrocadeSwitchClient {
|
||||||
|
async fn setup(&self) -> Result<(), SwitchError> {
|
||||||
|
let stack_topology = self
|
||||||
|
.brocade
|
||||||
|
.get_stack_topology()
|
||||||
|
.await
|
||||||
|
.map_err(|e| SwitchError::new(e.to_string()))?;
|
||||||
|
|
||||||
|
let interfaces = self
|
||||||
|
.brocade
|
||||||
|
.get_interfaces()
|
||||||
|
.await
|
||||||
|
.map_err(|e| SwitchError::new(e.to_string()))?;
|
||||||
|
|
||||||
|
let interfaces: Vec<(String, PortOperatingMode)> = interfaces
|
||||||
|
.into_iter()
|
||||||
|
.filter(|interface| {
|
||||||
|
interface.operating_mode.is_none() && interface.status == InterfaceStatus::Connected
|
||||||
|
})
|
||||||
|
.filter(|interface| {
|
||||||
|
!stack_topology.iter().any(|link: &InterSwitchLink| {
|
||||||
|
link.local_port == interface.port_location
|
||||||
|
|| link.remote_port.contains(&interface.port_location)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
.map(|interface| (interface.name.clone(), PortOperatingMode::Access))
|
||||||
|
.collect();
|
||||||
|
|
||||||
|
if interfaces.is_empty() {
|
||||||
|
return Ok(());
|
||||||
|
}
|
||||||
|
|
||||||
|
self.brocade
|
||||||
|
.configure_interfaces(interfaces)
|
||||||
|
.await
|
||||||
|
.map_err(|e| SwitchError::new(e.to_string()))?;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
async fn find_port(
|
async fn find_port(
|
||||||
&self,
|
&self,
|
||||||
mac_address: &MacAddress,
|
mac_address: &MacAddress,
|
||||||
) -> Result<Option<PortLocation>, SwitchError> {
|
) -> Result<Option<PortLocation>, SwitchError> {
|
||||||
let table = self
|
let table = self
|
||||||
.brocade
|
.brocade
|
||||||
.show_mac_address_table()
|
.get_mac_address_table()
|
||||||
.await
|
.await
|
||||||
.map_err(|e| SwitchError::new(format!("{e}")))?;
|
.map_err(|e| SwitchError::new(format!("{e}")))?;
|
||||||
|
|
||||||
@@ -79,3 +119,267 @@ pub struct BrocadeSwitchAuth {
|
|||||||
pub username: String,
|
pub username: String,
|
||||||
pub password: String,
|
pub password: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[cfg(test)]
|
||||||
|
mod tests {
|
||||||
|
use std::sync::{Arc, Mutex};
|
||||||
|
|
||||||
|
use assertor::*;
|
||||||
|
use async_trait::async_trait;
|
||||||
|
use brocade::{
|
||||||
|
BrocadeClient, BrocadeInfo, Error, InterSwitchLink, InterfaceInfo, InterfaceStatus,
|
||||||
|
InterfaceType, MacAddressEntry, PortChannelId, PortOperatingMode,
|
||||||
|
};
|
||||||
|
use harmony_types::switch::PortLocation;
|
||||||
|
|
||||||
|
use crate::{infra::brocade::BrocadeSwitchClient, topology::SwitchClient};
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn setup_should_configure_ethernet_interfaces_as_access_ports() {
|
||||||
|
let first_interface = given_interface()
|
||||||
|
.with_port_location(PortLocation(1, 0, 1))
|
||||||
|
.build();
|
||||||
|
let second_interface = given_interface()
|
||||||
|
.with_port_location(PortLocation(1, 0, 4))
|
||||||
|
.build();
|
||||||
|
let brocade = Box::new(FakeBrocadeClient::new(
|
||||||
|
vec![],
|
||||||
|
vec![first_interface.clone(), second_interface.clone()],
|
||||||
|
));
|
||||||
|
let client = BrocadeSwitchClient {
|
||||||
|
brocade: brocade.clone(),
|
||||||
|
};
|
||||||
|
|
||||||
|
client.setup().await.unwrap();
|
||||||
|
|
||||||
|
let configured_interfaces = brocade.configured_interfaces.lock().unwrap();
|
||||||
|
assert_that!(*configured_interfaces).contains_exactly(vec![
|
||||||
|
(first_interface.name.clone(), PortOperatingMode::Access),
|
||||||
|
(second_interface.name.clone(), PortOperatingMode::Access),
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn setup_with_an_already_configured_interface_should_skip_configuration() {
|
||||||
|
let brocade = Box::new(FakeBrocadeClient::new(
|
||||||
|
vec![],
|
||||||
|
vec![
|
||||||
|
given_interface()
|
||||||
|
.with_operating_mode(Some(PortOperatingMode::Access))
|
||||||
|
.build(),
|
||||||
|
],
|
||||||
|
));
|
||||||
|
let client = BrocadeSwitchClient {
|
||||||
|
brocade: brocade.clone(),
|
||||||
|
};
|
||||||
|
|
||||||
|
client.setup().await.unwrap();
|
||||||
|
|
||||||
|
let configured_interfaces = brocade.configured_interfaces.lock().unwrap();
|
||||||
|
assert_that!(*configured_interfaces).is_empty();
|
||||||
|
}
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn setup_with_a_disconnected_interface_should_skip_configuration() {
|
||||||
|
let brocade = Box::new(FakeBrocadeClient::new(
|
||||||
|
vec![],
|
||||||
|
vec![
|
||||||
|
given_interface()
|
||||||
|
.with_status(InterfaceStatus::SfpAbsent)
|
||||||
|
.build(),
|
||||||
|
given_interface()
|
||||||
|
.with_status(InterfaceStatus::NotConnected)
|
||||||
|
.build(),
|
||||||
|
],
|
||||||
|
));
|
||||||
|
let client = BrocadeSwitchClient {
|
||||||
|
brocade: brocade.clone(),
|
||||||
|
};
|
||||||
|
|
||||||
|
client.setup().await.unwrap();
|
||||||
|
|
||||||
|
let configured_interfaces = brocade.configured_interfaces.lock().unwrap();
|
||||||
|
assert_that!(*configured_interfaces).is_empty();
|
||||||
|
}
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn setup_with_inter_switch_links_should_not_configure_interfaces_used_to_form_stack() {
|
||||||
|
let brocade = Box::new(FakeBrocadeClient::new(
|
||||||
|
vec![
|
||||||
|
given_inter_switch_link()
|
||||||
|
.between(PortLocation(1, 0, 1), PortLocation(2, 0, 1))
|
||||||
|
.build(),
|
||||||
|
given_inter_switch_link()
|
||||||
|
.between(PortLocation(2, 0, 2), PortLocation(3, 0, 1))
|
||||||
|
.build(),
|
||||||
|
],
|
||||||
|
vec![
|
||||||
|
given_interface()
|
||||||
|
.with_port_location(PortLocation(1, 0, 1))
|
||||||
|
.build(),
|
||||||
|
given_interface()
|
||||||
|
.with_port_location(PortLocation(2, 0, 1))
|
||||||
|
.build(),
|
||||||
|
given_interface()
|
||||||
|
.with_port_location(PortLocation(3, 0, 1))
|
||||||
|
.build(),
|
||||||
|
],
|
||||||
|
));
|
||||||
|
let client = BrocadeSwitchClient {
|
||||||
|
brocade: brocade.clone(),
|
||||||
|
};
|
||||||
|
|
||||||
|
client.setup().await.unwrap();
|
||||||
|
|
||||||
|
let configured_interfaces = brocade.configured_interfaces.lock().unwrap();
|
||||||
|
assert_that!(*configured_interfaces).is_empty();
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Clone)]
|
||||||
|
struct FakeBrocadeClient {
|
||||||
|
stack_topology: Vec<InterSwitchLink>,
|
||||||
|
interfaces: Vec<InterfaceInfo>,
|
||||||
|
configured_interfaces: Arc<Mutex<Vec<(String, PortOperatingMode)>>>,
|
||||||
|
}
|
||||||
|
|
||||||
|
#[async_trait]
|
||||||
|
impl BrocadeClient for FakeBrocadeClient {
|
||||||
|
async fn version(&self) -> Result<BrocadeInfo, Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_mac_address_table(&self) -> Result<Vec<MacAddressEntry>, Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_stack_topology(&self) -> Result<Vec<InterSwitchLink>, Error> {
|
||||||
|
Ok(self.stack_topology.clone())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn get_interfaces(&self) -> Result<Vec<InterfaceInfo>, Error> {
|
||||||
|
Ok(self.interfaces.clone())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn configure_interfaces(
|
||||||
|
&self,
|
||||||
|
interfaces: Vec<(String, PortOperatingMode)>,
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
let mut configured_interfaces = self.configured_interfaces.lock().unwrap();
|
||||||
|
*configured_interfaces = interfaces;
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn find_available_channel_id(&self) -> Result<PortChannelId, Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn create_port_channel(
|
||||||
|
&self,
|
||||||
|
_channel_id: PortChannelId,
|
||||||
|
_channel_name: &str,
|
||||||
|
_ports: &[PortLocation],
|
||||||
|
) -> Result<(), Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
async fn clear_port_channel(&self, _channel_name: &str) -> Result<(), Error> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl FakeBrocadeClient {
|
||||||
|
fn new(stack_topology: Vec<InterSwitchLink>, interfaces: Vec<InterfaceInfo>) -> Self {
|
||||||
|
Self {
|
||||||
|
stack_topology,
|
||||||
|
interfaces,
|
||||||
|
configured_interfaces: Arc::new(Mutex::new(vec![])),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct InterfaceInfoBuilder {
|
||||||
|
port_location: Option<PortLocation>,
|
||||||
|
interface_type: Option<InterfaceType>,
|
||||||
|
operating_mode: Option<PortOperatingMode>,
|
||||||
|
status: Option<InterfaceStatus>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl InterfaceInfoBuilder {
|
||||||
|
fn build(&self) -> InterfaceInfo {
|
||||||
|
let interface_type = self
|
||||||
|
.interface_type
|
||||||
|
.clone()
|
||||||
|
.unwrap_or(InterfaceType::Ethernet("TenGigabitEthernet".into()));
|
||||||
|
let port_location = self.port_location.clone().unwrap_or(PortLocation(1, 0, 1));
|
||||||
|
let name = format!("{interface_type} {port_location}");
|
||||||
|
let status = self.status.clone().unwrap_or(InterfaceStatus::Connected);
|
||||||
|
|
||||||
|
InterfaceInfo {
|
||||||
|
name,
|
||||||
|
port_location,
|
||||||
|
interface_type,
|
||||||
|
operating_mode: self.operating_mode.clone(),
|
||||||
|
status,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn with_port_location(self, port_location: PortLocation) -> Self {
|
||||||
|
Self {
|
||||||
|
port_location: Some(port_location),
|
||||||
|
..self
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn with_operating_mode(self, operating_mode: Option<PortOperatingMode>) -> Self {
|
||||||
|
Self {
|
||||||
|
operating_mode,
|
||||||
|
..self
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn with_status(self, status: InterfaceStatus) -> Self {
|
||||||
|
Self {
|
||||||
|
status: Some(status),
|
||||||
|
..self
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
struct InterSwitchLinkBuilder {
|
||||||
|
link: Option<(PortLocation, PortLocation)>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl InterSwitchLinkBuilder {
|
||||||
|
fn build(&self) -> InterSwitchLink {
|
||||||
|
let link = self
|
||||||
|
.link
|
||||||
|
.clone()
|
||||||
|
.unwrap_or((PortLocation(1, 0, 1), PortLocation(2, 0, 1)));
|
||||||
|
|
||||||
|
InterSwitchLink {
|
||||||
|
local_port: link.0,
|
||||||
|
remote_port: Some(link.1),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn between(self, local_port: PortLocation, remote_port: PortLocation) -> Self {
|
||||||
|
Self {
|
||||||
|
link: Some((local_port, remote_port)),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn given_interface() -> InterfaceInfoBuilder {
|
||||||
|
InterfaceInfoBuilder {
|
||||||
|
port_location: None,
|
||||||
|
interface_type: None,
|
||||||
|
operating_mode: None,
|
||||||
|
status: None,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn given_inter_switch_link() -> InterSwitchLinkBuilder {
|
||||||
|
InterSwitchLinkBuilder { link: None }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
|
use harmony_macros::hurl;
|
||||||
use kube::{Api, api::GroupVersionKind};
|
use kube::{Api, api::GroupVersionKind};
|
||||||
use log::{debug, warn};
|
use log::{debug, warn};
|
||||||
use non_blank_string_rs::NonBlankString;
|
use non_blank_string_rs::NonBlankString;
|
||||||
@@ -1051,7 +1052,7 @@ commitServer:
|
|||||||
install_only: false,
|
install_only: false,
|
||||||
repository: Some(HelmRepository::new(
|
repository: Some(HelmRepository::new(
|
||||||
"argo".to_string(),
|
"argo".to_string(),
|
||||||
url::Url::parse("https://argoproj.github.io/argo-helm").unwrap(),
|
hurl!("https://argoproj.github.io/argo-helm"),
|
||||||
true,
|
true,
|
||||||
)),
|
)),
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
use std::{collections::HashMap, str::FromStr};
|
use std::{collections::HashMap, str::FromStr};
|
||||||
|
|
||||||
|
use harmony_macros::hurl;
|
||||||
use non_blank_string_rs::NonBlankString;
|
use non_blank_string_rs::NonBlankString;
|
||||||
use serde::Serialize;
|
use serde::Serialize;
|
||||||
use url::Url;
|
use url::Url;
|
||||||
@@ -33,7 +34,7 @@ impl<T: Topology + HelmCommand> Score<T> for CertManagerHelmScore {
|
|||||||
install_only: true,
|
install_only: true,
|
||||||
repository: Some(HelmRepository::new(
|
repository: Some(HelmRepository::new(
|
||||||
"jetstack".to_string(),
|
"jetstack".to_string(),
|
||||||
Url::parse("https://charts.jetstack.io").unwrap(),
|
hurl!("https://charts.jetstack.io"),
|
||||||
true,
|
true,
|
||||||
)),
|
)),
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ use crate::score::Score;
|
|||||||
use crate::topology::{HelmCommand, Topology};
|
use crate::topology::{HelmCommand, Topology};
|
||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
use harmony_types::id::Id;
|
use harmony_types::id::Id;
|
||||||
|
use harmony_types::net::Url;
|
||||||
use helm_wrapper_rs;
|
use helm_wrapper_rs;
|
||||||
use helm_wrapper_rs::blocking::{DefaultHelmExecutor, HelmExecutor};
|
use helm_wrapper_rs::blocking::{DefaultHelmExecutor, HelmExecutor};
|
||||||
use log::{debug, info, warn};
|
use log::{debug, info, warn};
|
||||||
@@ -15,7 +16,6 @@ use std::path::Path;
|
|||||||
use std::process::{Command, Output, Stdio};
|
use std::process::{Command, Output, Stdio};
|
||||||
use std::str::FromStr;
|
use std::str::FromStr;
|
||||||
use temp_file::TempFile;
|
use temp_file::TempFile;
|
||||||
use url::Url;
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Serialize)]
|
#[derive(Debug, Clone, Serialize)]
|
||||||
pub struct HelmRepository {
|
pub struct HelmRepository {
|
||||||
@@ -78,7 +78,8 @@ impl HelmChartInterpret {
|
|||||||
repo.name, repo.url, repo.force_update
|
repo.name, repo.url, repo.force_update
|
||||||
);
|
);
|
||||||
|
|
||||||
let mut add_args = vec!["repo", "add", &repo.name, repo.url.as_str()];
|
let repo_url = repo.url.to_string();
|
||||||
|
let mut add_args = vec!["repo", "add", &repo.name, &repo_url];
|
||||||
if repo.force_update {
|
if repo.force_update {
|
||||||
add_args.push("--force-update");
|
add_args.push("--force-update");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,364 +0,0 @@
|
|||||||
use async_trait::async_trait;
|
|
||||||
use log::debug;
|
|
||||||
use serde::Serialize;
|
|
||||||
use std::collections::HashMap;
|
|
||||||
use std::io::ErrorKind;
|
|
||||||
use std::path::PathBuf;
|
|
||||||
use std::process::{Command, Output};
|
|
||||||
use temp_dir::{self, TempDir};
|
|
||||||
use temp_file::TempFile;
|
|
||||||
|
|
||||||
use crate::data::Version;
|
|
||||||
use crate::interpret::{Interpret, InterpretError, InterpretName, InterpretStatus, Outcome};
|
|
||||||
use crate::inventory::Inventory;
|
|
||||||
use crate::score::Score;
|
|
||||||
use crate::topology::{HelmCommand, K8sclient, Topology};
|
|
||||||
use harmony_types::id::Id;
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct HelmCommandExecutor {
|
|
||||||
pub env: HashMap<String, String>,
|
|
||||||
pub path: Option<PathBuf>,
|
|
||||||
pub args: Vec<String>,
|
|
||||||
pub api_versions: Option<Vec<String>>,
|
|
||||||
pub kube_version: String,
|
|
||||||
pub debug: Option<bool>,
|
|
||||||
pub globals: HelmGlobals,
|
|
||||||
pub chart: HelmChart,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Clone)]
|
|
||||||
pub struct HelmGlobals {
|
|
||||||
pub chart_home: Option<PathBuf>,
|
|
||||||
pub config_home: Option<PathBuf>,
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Serialize)]
|
|
||||||
pub struct HelmChart {
|
|
||||||
pub name: String,
|
|
||||||
pub version: Option<String>,
|
|
||||||
pub repo: Option<String>,
|
|
||||||
pub release_name: Option<String>,
|
|
||||||
pub namespace: Option<String>,
|
|
||||||
pub additional_values_files: Vec<PathBuf>,
|
|
||||||
pub values_file: Option<PathBuf>,
|
|
||||||
pub values_inline: Option<String>,
|
|
||||||
pub include_crds: Option<bool>,
|
|
||||||
pub skip_hooks: Option<bool>,
|
|
||||||
pub api_versions: Option<Vec<String>>,
|
|
||||||
pub kube_version: Option<String>,
|
|
||||||
pub name_template: String,
|
|
||||||
pub skip_tests: Option<bool>,
|
|
||||||
pub debug: Option<bool>,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl HelmCommandExecutor {
|
|
||||||
pub fn generate(mut self) -> Result<String, std::io::Error> {
|
|
||||||
if self.globals.chart_home.is_none() {
|
|
||||||
self.globals.chart_home = Some(PathBuf::from("charts"));
|
|
||||||
}
|
|
||||||
|
|
||||||
if self
|
|
||||||
.clone()
|
|
||||||
.chart
|
|
||||||
.clone()
|
|
||||||
.chart_exists_locally(self.clone().globals.chart_home.unwrap())
|
|
||||||
.is_none()
|
|
||||||
{
|
|
||||||
if self.chart.repo.is_none() {
|
|
||||||
return Err(std::io::Error::new(
|
|
||||||
ErrorKind::Other,
|
|
||||||
"Chart doesn't exist locally and no repo specified",
|
|
||||||
));
|
|
||||||
}
|
|
||||||
self.clone().run_command(
|
|
||||||
self.chart
|
|
||||||
.clone()
|
|
||||||
.pull_command(self.globals.chart_home.clone().unwrap()),
|
|
||||||
)?;
|
|
||||||
}
|
|
||||||
|
|
||||||
let out = self.clone().run_command(
|
|
||||||
self.chart
|
|
||||||
.clone()
|
|
||||||
.helm_args(self.globals.chart_home.clone().unwrap()),
|
|
||||||
)?;
|
|
||||||
|
|
||||||
// TODO: don't use unwrap here
|
|
||||||
let s = String::from_utf8(out.stdout).unwrap();
|
|
||||||
debug!("helm stderr: {}", String::from_utf8(out.stderr).unwrap());
|
|
||||||
debug!("helm status: {}", out.status);
|
|
||||||
debug!("helm output: {s}");
|
|
||||||
|
|
||||||
let clean = s.split_once("---").unwrap().1;
|
|
||||||
|
|
||||||
Ok(clean.to_string())
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn version(self) -> Result<String, std::io::Error> {
|
|
||||||
let out = self.run_command(vec![
|
|
||||||
"version".to_string(),
|
|
||||||
"-c".to_string(),
|
|
||||||
"--short".to_string(),
|
|
||||||
])?;
|
|
||||||
|
|
||||||
// TODO: don't use unwrap
|
|
||||||
Ok(String::from_utf8(out.stdout).unwrap())
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn run_command(mut self, mut args: Vec<String>) -> Result<Output, std::io::Error> {
|
|
||||||
if let Some(d) = self.debug {
|
|
||||||
if d {
|
|
||||||
args.push("--debug".to_string());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
let path = if let Some(p) = self.path {
|
|
||||||
p
|
|
||||||
} else {
|
|
||||||
PathBuf::from("helm")
|
|
||||||
};
|
|
||||||
|
|
||||||
let config_home = match self.globals.config_home {
|
|
||||||
Some(p) => p,
|
|
||||||
None => PathBuf::from(TempDir::new()?.path()),
|
|
||||||
};
|
|
||||||
|
|
||||||
if let Some(yaml_str) = self.chart.values_inline {
|
|
||||||
let tf: TempFile = temp_file::with_contents(yaml_str.as_bytes());
|
|
||||||
self.chart
|
|
||||||
.additional_values_files
|
|
||||||
.push(PathBuf::from(tf.path()));
|
|
||||||
};
|
|
||||||
|
|
||||||
self.env.insert(
|
|
||||||
"HELM_CONFIG_HOME".to_string(),
|
|
||||||
config_home.to_str().unwrap().to_string(),
|
|
||||||
);
|
|
||||||
self.env.insert(
|
|
||||||
"HELM_CACHE_HOME".to_string(),
|
|
||||||
config_home.to_str().unwrap().to_string(),
|
|
||||||
);
|
|
||||||
self.env.insert(
|
|
||||||
"HELM_DATA_HOME".to_string(),
|
|
||||||
config_home.to_str().unwrap().to_string(),
|
|
||||||
);
|
|
||||||
|
|
||||||
Command::new(path).envs(self.env).args(args).output()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl HelmChart {
|
|
||||||
pub fn chart_exists_locally(self, chart_home: PathBuf) -> Option<PathBuf> {
|
|
||||||
let chart_path =
|
|
||||||
PathBuf::from(chart_home.to_str().unwrap().to_string() + "/" + &self.name.to_string());
|
|
||||||
|
|
||||||
if chart_path.exists() {
|
|
||||||
Some(chart_path)
|
|
||||||
} else {
|
|
||||||
None
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn pull_command(self, chart_home: PathBuf) -> Vec<String> {
|
|
||||||
let mut args = vec![
|
|
||||||
"pull".to_string(),
|
|
||||||
"--untar".to_string(),
|
|
||||||
"--untardir".to_string(),
|
|
||||||
chart_home.to_str().unwrap().to_string(),
|
|
||||||
];
|
|
||||||
|
|
||||||
match self.repo {
|
|
||||||
Some(r) => {
|
|
||||||
if r.starts_with("oci://") {
|
|
||||||
args.push(
|
|
||||||
r.trim_end_matches("/").to_string() + "/" + self.name.clone().as_str(),
|
|
||||||
);
|
|
||||||
} else {
|
|
||||||
args.push("--repo".to_string());
|
|
||||||
args.push(r.to_string());
|
|
||||||
|
|
||||||
args.push(self.name);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
None => args.push(self.name),
|
|
||||||
};
|
|
||||||
|
|
||||||
if let Some(v) = self.version {
|
|
||||||
args.push("--version".to_string());
|
|
||||||
args.push(v.to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
args
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn helm_args(self, chart_home: PathBuf) -> Vec<String> {
|
|
||||||
let mut args: Vec<String> = vec!["template".to_string()];
|
|
||||||
|
|
||||||
match self.release_name {
|
|
||||||
Some(rn) => args.push(rn.to_string()),
|
|
||||||
None => args.push("--generate-name".to_string()),
|
|
||||||
}
|
|
||||||
|
|
||||||
args.push(
|
|
||||||
PathBuf::from(chart_home.to_str().unwrap().to_string() + "/" + self.name.as_str())
|
|
||||||
.to_str()
|
|
||||||
.unwrap()
|
|
||||||
.to_string(),
|
|
||||||
);
|
|
||||||
|
|
||||||
if let Some(n) = self.namespace {
|
|
||||||
args.push("--namespace".to_string());
|
|
||||||
args.push(n.to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(f) = self.values_file {
|
|
||||||
args.push("-f".to_string());
|
|
||||||
args.push(f.to_str().unwrap().to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
for f in self.additional_values_files {
|
|
||||||
args.push("-f".to_string());
|
|
||||||
args.push(f.to_str().unwrap().to_string());
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(vv) = self.api_versions {
|
|
||||||
for v in vv {
|
|
||||||
args.push("--api-versions".to_string());
|
|
||||||
args.push(v);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(kv) = self.kube_version {
|
|
||||||
args.push("--kube-version".to_string());
|
|
||||||
args.push(kv);
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(crd) = self.include_crds {
|
|
||||||
if crd {
|
|
||||||
args.push("--include-crds".to_string());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(st) = self.skip_tests {
|
|
||||||
if st {
|
|
||||||
args.push("--skip-tests".to_string());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(sh) = self.skip_hooks {
|
|
||||||
if sh {
|
|
||||||
args.push("--no-hooks".to_string());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if let Some(d) = self.debug {
|
|
||||||
if d {
|
|
||||||
args.push("--debug".to_string());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
args
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Clone, Serialize)]
|
|
||||||
pub struct HelmChartScoreV2 {
|
|
||||||
pub chart: HelmChart,
|
|
||||||
}
|
|
||||||
|
|
||||||
impl<T: Topology + K8sclient + HelmCommand> Score<T> for HelmChartScoreV2 {
|
|
||||||
fn create_interpret(&self) -> Box<dyn Interpret<T>> {
|
|
||||||
Box::new(HelmChartInterpretV2 {
|
|
||||||
score: self.clone(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
fn name(&self) -> String {
|
|
||||||
format!(
|
|
||||||
"{} {} HelmChartScoreV2",
|
|
||||||
self.chart
|
|
||||||
.release_name
|
|
||||||
.clone()
|
|
||||||
.unwrap_or("Unknown".to_string()),
|
|
||||||
self.chart.name
|
|
||||||
)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
#[derive(Debug, Serialize)]
|
|
||||||
pub struct HelmChartInterpretV2 {
|
|
||||||
pub score: HelmChartScoreV2,
|
|
||||||
}
|
|
||||||
impl HelmChartInterpretV2 {}
|
|
||||||
|
|
||||||
#[async_trait]
|
|
||||||
impl<T: Topology + K8sclient + HelmCommand> Interpret<T> for HelmChartInterpretV2 {
|
|
||||||
async fn execute(
|
|
||||||
&self,
|
|
||||||
_inventory: &Inventory,
|
|
||||||
_topology: &T,
|
|
||||||
) -> Result<Outcome, InterpretError> {
|
|
||||||
let _ns = self
|
|
||||||
.score
|
|
||||||
.chart
|
|
||||||
.namespace
|
|
||||||
.as_ref()
|
|
||||||
.unwrap_or_else(|| todo!("Get namespace from active kubernetes cluster"));
|
|
||||||
|
|
||||||
let helm_executor = HelmCommandExecutor {
|
|
||||||
env: HashMap::new(),
|
|
||||||
path: None,
|
|
||||||
args: vec![],
|
|
||||||
api_versions: None,
|
|
||||||
kube_version: "v1.33.0".to_string(),
|
|
||||||
debug: Some(false),
|
|
||||||
globals: HelmGlobals {
|
|
||||||
chart_home: None,
|
|
||||||
config_home: None,
|
|
||||||
},
|
|
||||||
chart: self.score.chart.clone(),
|
|
||||||
};
|
|
||||||
|
|
||||||
// let mut helm_options = Vec::new();
|
|
||||||
// if self.score.create_namespace {
|
|
||||||
// helm_options.push(NonBlankString::from_str("--create-namespace").unwrap());
|
|
||||||
// }
|
|
||||||
|
|
||||||
let res = helm_executor.generate();
|
|
||||||
|
|
||||||
let _output = match res {
|
|
||||||
Ok(output) => output,
|
|
||||||
Err(err) => return Err(InterpretError::new(err.to_string())),
|
|
||||||
};
|
|
||||||
|
|
||||||
// TODO: implement actually applying the YAML from the templating in the generate function to a k8s cluster, having trouble passing in straight YAML into the k8s client
|
|
||||||
|
|
||||||
// let k8s_resource = k8s_openapi::serde_json::from_str(output.as_str()).unwrap();
|
|
||||||
|
|
||||||
// let client = topology
|
|
||||||
// .k8s_client()
|
|
||||||
// .await
|
|
||||||
// .expect("Environment should provide enough information to instanciate a client")
|
|
||||||
// .apply_namespaced(&vec![output], Some(ns.to_string().as_str()));
|
|
||||||
// match client.apply_yaml(output) {
|
|
||||||
// Ok(_) => return Ok(Outcome::success("Helm chart deployed".to_string())),
|
|
||||||
// Err(e) => return Err(InterpretError::new(e)),
|
|
||||||
// }
|
|
||||||
|
|
||||||
Ok(Outcome::success("Helm chart deployed".to_string()))
|
|
||||||
}
|
|
||||||
|
|
||||||
fn get_name(&self) -> InterpretName {
|
|
||||||
InterpretName::HelmCommand
|
|
||||||
}
|
|
||||||
fn get_version(&self) -> Version {
|
|
||||||
todo!()
|
|
||||||
}
|
|
||||||
fn get_status(&self) -> InterpretStatus {
|
|
||||||
todo!()
|
|
||||||
}
|
|
||||||
fn get_children(&self) -> Vec<Id> {
|
|
||||||
todo!()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,2 +1 @@
|
|||||||
pub mod chart;
|
pub mod chart;
|
||||||
pub mod command;
|
|
||||||
|
|||||||
@@ -4,4 +4,5 @@ pub mod application_monitoring;
|
|||||||
pub mod grafana;
|
pub mod grafana;
|
||||||
pub mod kube_prometheus;
|
pub mod kube_prometheus;
|
||||||
pub mod ntfy;
|
pub mod ntfy;
|
||||||
|
pub mod okd;
|
||||||
pub mod prometheus;
|
pub mod prometheus;
|
||||||
|
|||||||
149
harmony/src/modules/monitoring/okd/enable_user_workload.rs
Normal file
149
harmony/src/modules/monitoring/okd/enable_user_workload.rs
Normal file
@@ -0,0 +1,149 @@
|
|||||||
|
use std::{collections::BTreeMap, sync::Arc};
|
||||||
|
|
||||||
|
use crate::{
|
||||||
|
data::Version,
|
||||||
|
interpret::{Interpret, InterpretError, InterpretName, InterpretStatus, Outcome},
|
||||||
|
inventory::Inventory,
|
||||||
|
score::Score,
|
||||||
|
topology::{K8sclient, Topology, k8s::K8sClient},
|
||||||
|
};
|
||||||
|
use async_trait::async_trait;
|
||||||
|
use harmony_types::id::Id;
|
||||||
|
use k8s_openapi::api::core::v1::ConfigMap;
|
||||||
|
use kube::api::ObjectMeta;
|
||||||
|
use serde::Serialize;
|
||||||
|
|
||||||
|
#[derive(Clone, Debug, Serialize)]
|
||||||
|
pub struct OpenshiftUserWorkloadMonitoring {}
|
||||||
|
|
||||||
|
impl<T: Topology + K8sclient> Score<T> for OpenshiftUserWorkloadMonitoring {
|
||||||
|
fn name(&self) -> String {
|
||||||
|
"OpenshiftUserWorkloadMonitoringScore".to_string()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn create_interpret(&self) -> Box<dyn Interpret<T>> {
|
||||||
|
Box::new(OpenshiftUserWorkloadMonitoringInterpret {})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
#[derive(Clone, Debug, Serialize)]
|
||||||
|
pub struct OpenshiftUserWorkloadMonitoringInterpret {}
|
||||||
|
|
||||||
|
#[async_trait]
|
||||||
|
impl<T: Topology + K8sclient> Interpret<T> for OpenshiftUserWorkloadMonitoringInterpret {
|
||||||
|
async fn execute(
|
||||||
|
&self,
|
||||||
|
_inventory: &Inventory,
|
||||||
|
topology: &T,
|
||||||
|
) -> Result<Outcome, InterpretError> {
|
||||||
|
let client = topology.k8s_client().await.unwrap();
|
||||||
|
self.update_cluster_monitoring_config_cm(&client).await?;
|
||||||
|
self.update_user_workload_monitoring_config_cm(&client)
|
||||||
|
.await?;
|
||||||
|
self.verify_user_workload(&client).await?;
|
||||||
|
Ok(Outcome::success(
|
||||||
|
"successfully enabled user-workload-monitoring".to_string(),
|
||||||
|
))
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_name(&self) -> InterpretName {
|
||||||
|
InterpretName::Custom("OpenshiftUserWorkloadMonitoring")
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_version(&self) -> Version {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_status(&self) -> InterpretStatus {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
|
||||||
|
fn get_children(&self) -> Vec<Id> {
|
||||||
|
todo!()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl OpenshiftUserWorkloadMonitoringInterpret {
|
||||||
|
pub async fn update_cluster_monitoring_config_cm(
|
||||||
|
&self,
|
||||||
|
client: &Arc<K8sClient>,
|
||||||
|
) -> Result<Outcome, InterpretError> {
|
||||||
|
let mut data = BTreeMap::new();
|
||||||
|
data.insert(
|
||||||
|
"config.yaml".to_string(),
|
||||||
|
r#"
|
||||||
|
enableUserWorkload: true
|
||||||
|
alertmanagerMain:
|
||||||
|
enableUserAlertmanagerConfig: true
|
||||||
|
"#
|
||||||
|
.to_string(),
|
||||||
|
);
|
||||||
|
|
||||||
|
let cm = ConfigMap {
|
||||||
|
metadata: ObjectMeta {
|
||||||
|
name: Some("cluster-monitoring-config".to_string()),
|
||||||
|
namespace: Some("openshift-monitoring".to_string()),
|
||||||
|
..Default::default()
|
||||||
|
},
|
||||||
|
data: Some(data),
|
||||||
|
..Default::default()
|
||||||
|
};
|
||||||
|
client.apply(&cm, Some("openshift-monitoring")).await?;
|
||||||
|
|
||||||
|
Ok(Outcome::success(
|
||||||
|
"updated cluster-monitoring-config-map".to_string(),
|
||||||
|
))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn update_user_workload_monitoring_config_cm(
|
||||||
|
&self,
|
||||||
|
client: &Arc<K8sClient>,
|
||||||
|
) -> Result<Outcome, InterpretError> {
|
||||||
|
let mut data = BTreeMap::new();
|
||||||
|
data.insert(
|
||||||
|
"config.yaml".to_string(),
|
||||||
|
r#"
|
||||||
|
alertmanager:
|
||||||
|
enabled: true
|
||||||
|
enableAlertmanagerConfig: true
|
||||||
|
"#
|
||||||
|
.to_string(),
|
||||||
|
);
|
||||||
|
let cm = ConfigMap {
|
||||||
|
metadata: ObjectMeta {
|
||||||
|
name: Some("user-workload-monitoring-config".to_string()),
|
||||||
|
namespace: Some("openshift-user-workload-monitoring".to_string()),
|
||||||
|
..Default::default()
|
||||||
|
},
|
||||||
|
data: Some(data),
|
||||||
|
..Default::default()
|
||||||
|
};
|
||||||
|
client
|
||||||
|
.apply(&cm, Some("openshift-user-workload-monitoring"))
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(Outcome::success(
|
||||||
|
"updated openshift-user-monitoring-config-map".to_string(),
|
||||||
|
))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub async fn verify_user_workload(
|
||||||
|
&self,
|
||||||
|
client: &Arc<K8sClient>,
|
||||||
|
) -> Result<Outcome, InterpretError> {
|
||||||
|
let namespace = "openshift-user-workload-monitoring";
|
||||||
|
let alertmanager_name = "alertmanager-user-workload-0";
|
||||||
|
let prometheus_name = "prometheus-user-workload-0";
|
||||||
|
client
|
||||||
|
.wait_for_pod_ready(alertmanager_name, Some(namespace))
|
||||||
|
.await?;
|
||||||
|
client
|
||||||
|
.wait_for_pod_ready(prometheus_name, Some(namespace))
|
||||||
|
.await?;
|
||||||
|
|
||||||
|
Ok(Outcome::success(format!(
|
||||||
|
"pods: {}, {} ready in ns: {}",
|
||||||
|
alertmanager_name, prometheus_name, namespace
|
||||||
|
)))
|
||||||
|
}
|
||||||
|
}
|
||||||
1
harmony/src/modules/monitoring/okd/mod.rs
Normal file
1
harmony/src/modules/monitoring/okd/mod.rs
Normal file
@@ -0,0 +1 @@
|
|||||||
|
pub mod enable_user_workload;
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
use async_trait::async_trait;
|
use async_trait::async_trait;
|
||||||
use harmony_types::id::Id;
|
use harmony_types::id::Id;
|
||||||
use log::{debug, info, warn};
|
use log::{debug, info};
|
||||||
use serde::Serialize;
|
use serde::Serialize;
|
||||||
|
|
||||||
use crate::{
|
use crate::{
|
||||||
@@ -34,6 +34,58 @@ pub struct HostNetworkConfigurationInterpret {
|
|||||||
score: HostNetworkConfigurationScore,
|
score: HostNetworkConfigurationScore,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl HostNetworkConfigurationInterpret {
|
||||||
|
async fn configure_network_for_host<T: Topology + Switch>(
|
||||||
|
&self,
|
||||||
|
topology: &T,
|
||||||
|
host: &PhysicalHost,
|
||||||
|
) -> Result<(), InterpretError> {
|
||||||
|
let switch_ports = self.collect_switch_ports_for_host(topology, host).await?;
|
||||||
|
if !switch_ports.is_empty() {
|
||||||
|
topology
|
||||||
|
.configure_host_network(host, HostNetworkConfig { switch_ports })
|
||||||
|
.await
|
||||||
|
.map_err(|e| InterpretError::new(format!("Failed to configure host: {e}")))?;
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
async fn collect_switch_ports_for_host<T: Topology + Switch>(
|
||||||
|
&self,
|
||||||
|
topology: &T,
|
||||||
|
host: &PhysicalHost,
|
||||||
|
) -> Result<Vec<SwitchPort>, InterpretError> {
|
||||||
|
let mut switch_ports = vec![];
|
||||||
|
|
||||||
|
for network_interface in &host.network {
|
||||||
|
let mac_address = network_interface.mac_address;
|
||||||
|
|
||||||
|
match topology.get_port_for_mac_address(&mac_address).await {
|
||||||
|
Ok(Some(port)) => {
|
||||||
|
switch_ports.push(SwitchPort {
|
||||||
|
interface: NetworkInterface {
|
||||||
|
name: network_interface.name.clone(),
|
||||||
|
mac_address,
|
||||||
|
speed_mbps: network_interface.speed_mbps,
|
||||||
|
mtu: network_interface.mtu,
|
||||||
|
},
|
||||||
|
port,
|
||||||
|
});
|
||||||
|
}
|
||||||
|
Ok(None) => debug!("No port found for host '{}', skipping", host.id),
|
||||||
|
Err(e) => {
|
||||||
|
return Err(InterpretError::new(format!(
|
||||||
|
"Failed to get port for host '{}': {}",
|
||||||
|
host.id, e
|
||||||
|
)));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(switch_ports)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
impl<T: Topology + Switch> Interpret<T> for HostNetworkConfigurationInterpret {
|
impl<T: Topology + Switch> Interpret<T> for HostNetworkConfigurationInterpret {
|
||||||
fn get_name(&self) -> InterpretName {
|
fn get_name(&self) -> InterpretName {
|
||||||
@@ -57,43 +109,25 @@ impl<T: Topology + Switch> Interpret<T> for HostNetworkConfigurationInterpret {
|
|||||||
_inventory: &Inventory,
|
_inventory: &Inventory,
|
||||||
topology: &T,
|
topology: &T,
|
||||||
) -> Result<Outcome, InterpretError> {
|
) -> Result<Outcome, InterpretError> {
|
||||||
|
if self.score.hosts.is_empty() {
|
||||||
|
return Ok(Outcome::noop("No hosts to configure".into()));
|
||||||
|
}
|
||||||
|
|
||||||
info!(
|
info!(
|
||||||
"Started network configuration for {} host(s)...",
|
"Started network configuration for {} host(s)...",
|
||||||
self.score.hosts.len()
|
self.score.hosts.len()
|
||||||
);
|
);
|
||||||
|
|
||||||
|
topology
|
||||||
|
.setup_switch()
|
||||||
|
.await
|
||||||
|
.map_err(|e| InterpretError::new(format!("Switch setup failed: {e}")))?;
|
||||||
|
|
||||||
let mut configured_host_count = 0;
|
let mut configured_host_count = 0;
|
||||||
|
|
||||||
for host in &self.score.hosts {
|
for host in &self.score.hosts {
|
||||||
let mut switch_ports = vec![];
|
// FIXME: Clear the previous config for host
|
||||||
|
self.configure_network_for_host(topology, host).await?;
|
||||||
for network_interface in &host.network {
|
configured_host_count += 1;
|
||||||
let mac_address = network_interface.mac_address;
|
|
||||||
|
|
||||||
match topology.get_port_for_mac_address(&mac_address).await {
|
|
||||||
Ok(Some(port)) => {
|
|
||||||
switch_ports.push(SwitchPort {
|
|
||||||
interface: NetworkInterface {
|
|
||||||
name: network_interface.name.clone(),
|
|
||||||
mac_address,
|
|
||||||
speed_mbps: network_interface.speed_mbps,
|
|
||||||
mtu: network_interface.mtu,
|
|
||||||
},
|
|
||||||
port,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
Ok(None) => debug!("No port found for host '{}', skipping", host.id),
|
|
||||||
Err(e) => warn!("Failed to get port for host '{}': {}", host.id, e),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if !switch_ports.is_empty() {
|
|
||||||
configured_host_count += 1;
|
|
||||||
topology
|
|
||||||
.configure_host_network(host, HostNetworkConfig { switch_ports })
|
|
||||||
.await
|
|
||||||
.map_err(|e| InterpretError::new(format!("Failed to configure host: {e}")))?;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if configured_host_count > 0 {
|
if configured_host_count > 0 {
|
||||||
@@ -151,6 +185,18 @@ mod tests {
|
|||||||
pub static ref ANOTHER_PORT: PortLocation = PortLocation(2, 0, 42);
|
pub static ref ANOTHER_PORT: PortLocation = PortLocation(2, 0, 42);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[tokio::test]
|
||||||
|
async fn should_setup_switch() {
|
||||||
|
let host = given_host(&HOST_ID, vec![EXISTING_INTERFACE.clone()]);
|
||||||
|
let score = given_score(vec![host]);
|
||||||
|
let topology = TopologyWithSwitch::new();
|
||||||
|
|
||||||
|
let _ = score.interpret(&Inventory::empty(), &topology).await;
|
||||||
|
|
||||||
|
let switch_setup = topology.switch_setup.lock().unwrap();
|
||||||
|
assert_that!(*switch_setup).is_true();
|
||||||
|
}
|
||||||
|
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
async fn host_with_one_mac_address_should_create_bond_with_one_interface() {
|
async fn host_with_one_mac_address_should_create_bond_with_one_interface() {
|
||||||
let host = given_host(&HOST_ID, vec![EXISTING_INTERFACE.clone()]);
|
let host = given_host(&HOST_ID, vec![EXISTING_INTERFACE.clone()]);
|
||||||
@@ -284,6 +330,7 @@ mod tests {
|
|||||||
struct TopologyWithSwitch {
|
struct TopologyWithSwitch {
|
||||||
available_ports: Arc<Mutex<Vec<PortLocation>>>,
|
available_ports: Arc<Mutex<Vec<PortLocation>>>,
|
||||||
configured_host_networks: Arc<Mutex<Vec<(Id, HostNetworkConfig)>>>,
|
configured_host_networks: Arc<Mutex<Vec<(Id, HostNetworkConfig)>>>,
|
||||||
|
switch_setup: Arc<Mutex<bool>>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl TopologyWithSwitch {
|
impl TopologyWithSwitch {
|
||||||
@@ -291,6 +338,7 @@ mod tests {
|
|||||||
Self {
|
Self {
|
||||||
available_ports: Arc::new(Mutex::new(vec![PORT.clone(), ANOTHER_PORT.clone()])),
|
available_ports: Arc::new(Mutex::new(vec![PORT.clone(), ANOTHER_PORT.clone()])),
|
||||||
configured_host_networks: Arc::new(Mutex::new(vec![])),
|
configured_host_networks: Arc::new(Mutex::new(vec![])),
|
||||||
|
switch_setup: Arc::new(Mutex::new(false)),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -298,6 +346,7 @@ mod tests {
|
|||||||
Self {
|
Self {
|
||||||
available_ports: Arc::new(Mutex::new(vec![])),
|
available_ports: Arc::new(Mutex::new(vec![])),
|
||||||
configured_host_networks: Arc::new(Mutex::new(vec![])),
|
configured_host_networks: Arc::new(Mutex::new(vec![])),
|
||||||
|
switch_setup: Arc::new(Mutex::new(false)),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -315,6 +364,12 @@ mod tests {
|
|||||||
|
|
||||||
#[async_trait]
|
#[async_trait]
|
||||||
impl Switch for TopologyWithSwitch {
|
impl Switch for TopologyWithSwitch {
|
||||||
|
async fn setup_switch(&self) -> Result<(), SwitchError> {
|
||||||
|
let mut switch_configured = self.switch_setup.lock().unwrap();
|
||||||
|
*switch_configured = true;
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
|
|
||||||
async fn get_port_for_mac_address(
|
async fn get_port_for_mac_address(
|
||||||
&self,
|
&self,
|
||||||
_mac_address: &MacAddress,
|
_mac_address: &MacAddress,
|
||||||
|
|||||||
Reference in New Issue
Block a user