proxmox-ve-rs/proxmox-ve-config/tests/sdn/main.rs

use std::{
    net::{IpAddr, Ipv4Addr, Ipv6Addr},
    str::FromStr,
};

use proxmox_ve_config::{
    firewall::types::{address::IpRange, Cidr},
    guest::vm::MacAddress,
    sdn::{
        config::{
            RunningConfig, SdnConfig, SdnConfigError, SubnetConfig, VnetConfig, ZoneConfig,
            ZoneType,
        },
        ipam::{Ipam, IpamDataVm, IpamEntry, IpamJson},
        SubnetName, VnetName, ZoneName,
    },
};

#[test]
fn parse_running_config() {
    let running_config: RunningConfig =
        serde_json::from_str(include_str!("resources/running-config.json")).unwrap();

    let parsed_config = SdnConfig::try_from(running_config).unwrap();

    let sdn_config = SdnConfig::from_zones([ZoneConfig::from_vnets(
        ZoneName::from_str("zone0").unwrap(),
        ZoneType::Simple,
        [
            VnetConfig::from_subnets(
                VnetName::from_str("vnet0").unwrap(),
                [
                    SubnetConfig::new(
                        SubnetName::from_str("zone0-fd80::-64").unwrap(),
                        Some(Ipv6Addr::new(0xFD80, 0, 0, 0, 0, 0, 0, 0x1).into()),
                        true,
                        [IpRange::new_v6(
                            [0xFD80, 0, 0, 0, 0, 0, 0, 0x1000],
                            [0xFD80, 0, 0, 0, 0, 0, 0, 0xFFFF],
                        )
                        .unwrap()],
                    )
                    .unwrap(),
                    SubnetConfig::new(
                        SubnetName::from_str("zone0-10.101.0.0-16").unwrap(),
                        Some(Ipv4Addr::new(10, 101, 1, 1).into()),
                        true,
                        [
                            IpRange::new_v4([10, 101, 98, 100], [10, 101, 98, 200]).unwrap(),
                            IpRange::new_v4([10, 101, 99, 100], [10, 101, 99, 200]).unwrap(),
                        ],
                    )
                    .unwrap(),
                ],
            )
            .unwrap(),
            VnetConfig::from_subnets(
                VnetName::from_str("vnet1").unwrap(),
                [SubnetConfig::new(
                    SubnetName::from_str("zone0-10.102.0.0-16").unwrap(),
                    None,
                    false,
                    [],
                )
                .unwrap()],
            )
            .unwrap(),
        ],
    )
    .unwrap()])
    .unwrap();

    assert_eq!(sdn_config, parsed_config);
}

#[test]
fn sdn_config() {
    let mut sdn_config = SdnConfig::new();

    let zone0_name = ZoneName::new("zone0".to_string()).unwrap();
    let zone1_name = ZoneName::new("zone1".to_string()).unwrap();

    let vnet0_name = VnetName::new("vnet0".to_string()).unwrap();
    let vnet1_name = VnetName::new("vnet1".to_string()).unwrap();

    let zone0 = ZoneConfig::new(zone0_name.clone(), ZoneType::Qinq);
    sdn_config.add_zone(zone0).unwrap();

    let vnet0 = VnetConfig::new(vnet0_name.clone());
    assert_eq!(
        sdn_config.add_vnet(&zone1_name, vnet0.clone()),
        Err(SdnConfigError::ZoneNotFound)
    );

    sdn_config.add_vnet(&zone0_name, vnet0.clone()).unwrap();

    let subnet = SubnetConfig::new(
        SubnetName::new(zone0_name.clone(), Cidr::new_v4([10, 0, 0, 0], 16).unwrap()),
        IpAddr::V4(Ipv4Addr::new(10, 0, 0, 1)),
        true,
        [],
    )
    .unwrap();

    assert_eq!(
        sdn_config.add_subnet(&zone0_name, &vnet1_name, subnet.clone()),
        Err(SdnConfigError::VnetNotFound),
    );

    sdn_config
        .add_subnet(&zone0_name, &vnet0_name, subnet)
        .unwrap();

    let zone1 = ZoneConfig::from_vnets(
        zone1_name.clone(),
        ZoneType::Evpn,
        [VnetConfig::from_subnets(
            vnet1_name.clone(),
            [SubnetConfig::new(
                SubnetName::new(
                    zone0_name.clone(),
                    Cidr::new_v4([192, 168, 0, 0], 24).unwrap(),
                ),
                None,
                false,
                [],
            )
            .unwrap()],
        )
        .unwrap()],
    )
    .unwrap();

    assert_eq!(
        sdn_config.add_zones([zone1]),
        Err(SdnConfigError::MismatchedSubnetZone),
    );

    let zone1 = ZoneConfig::new(zone1_name.clone(), ZoneType::Evpn);
    sdn_config.add_zone(zone1).unwrap();

    assert_eq!(
        sdn_config.add_vnet(&zone1_name, vnet0.clone()),
        Err(SdnConfigError::DuplicateVnetName),
    )
}

#[test]
fn parse_ipam() {
    let ipam_json: IpamJson = serde_json::from_str(include_str!("resources/ipam.db")).unwrap();
    let ipam = Ipam::try_from(ipam_json).unwrap();

    let zone_name = ZoneName::new("zone0".to_string()).unwrap();

    assert_eq!(
        Ipam::from_entries([
            IpamEntry::new(
                SubnetName::new(
                    zone_name.clone(),
                    Cidr::new_v6([0xFD80, 0, 0, 0, 0, 0, 0, 0], 64).unwrap()
                ),
                IpamDataVm::new(
                    Ipv6Addr::new(0xFD80, 0, 0, 0, 0, 0, 0, 0x1000),
                    1000,
                    MacAddress::new([0xBC, 0x24, 0x11, 0, 0, 0x01]),
                    "test0".to_string()
                )
                .into()
            )
            .unwrap(),
            IpamEntry::new(
                SubnetName::new(
                    zone_name.clone(),
                    Cidr::new_v4([10, 101, 0, 0], 16).unwrap()
                ),
                IpamDataVm::new(
                    Ipv4Addr::new(10, 101, 99, 101),
                    1000,
                    MacAddress::new([0xBC, 0x24, 0x11, 0, 0, 0x01]),
                    "test0".to_string()
                )
                .into()
            )
            .unwrap(),
        ])
        .unwrap(),
        ipam
    )
}