Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions sunbeam-python/sunbeam/storage/backends/infinidat/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""INFINIDAT backend for Sunbeam storage."""
114 changes: 114 additions & 0 deletions sunbeam-python/sunbeam/storage/backends/infinidat/backend.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,114 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""INFINIDAT InfiniBox backend implementation using base step classes."""

import logging
from enum import StrEnum
from typing import Annotated

from pydantic import Field
from rich.console import Console

from sunbeam.core.manifest import StorageBackendConfig
from sunbeam.storage.base import StorageBackendBase
from sunbeam.storage.models import SecretDictField

LOG = logging.getLogger(__name__)
console = Console()


class Protocol(StrEnum):
"""Enumeration of valid storage protocol types."""

ISCSI = "iscsi"
FC = "fc"


class InfinidatConfig(StorageBackendConfig):
"""Configuration model for INFINIDAT InfiniBox backend.

This model includes ALL configuration options for the backend.
Additional configuration can be managed dynamically through the charm.
"""

# Mandatory connection parameters
san_ip: Annotated[str, Field(description="IP address of SAN controller")]
san_login: Annotated[
str,
Field(description="Username for SAN controller"),
SecretDictField(field="san-login"),
]
san_password: Annotated[
str,
Field(description="Password for SAN controller"),
SecretDictField(field="san-password"),
]

# Optional backend configuration
protocol: Annotated[
Protocol | None,
Field(description="Protocol selector: iscsi, fc."),
] = None
infinidat_pool_name: Annotated[
str | None,
Field(description="Name of the pool from which volumes are allocated"),
] = None
infinidat_storage_protocol: Annotated[
Protocol | None,
Field(
description="Protocol for transferring data between host and storage back-end." # noqa: E501
),
] = None
infinidat_iscsi_netspaces: Annotated[
str | None,
Field(
description="List of names of network spaces to use for iSCSI connectivity"
),
] = None
infinidat_use_compression: Annotated[
bool | None,
Field(
description="Specifies whether to enable (true) or disable (false) compression for all newly created volumes." # noqa: E501
),
] = None
san_thin_provision: Annotated[
bool | None,
Field(description="Use thin provisioning for SAN volumes?"),
] = None
use_multipath_for_image_xfer: Annotated[
bool | None,
Field(description="Enable multipathing for image transfer operations."),
] = None


class InfinidatBackend(StorageBackendBase):
"""INFINIDAT InfiniBox backend implementation."""

backend_type = "infinidat"
display_name = "INFINIDAT InfiniBox"
generally_available = True
Comment thread
ahmad-can marked this conversation as resolved.

@property
def charm_name(self) -> str:
"""Return the charm application name."""
return "cinder-volume-infinidat"

@property
def charm_channel(self) -> str:
"""Return the default charm channel."""
return "latest/edge"

@property
def charm_revision(self) -> str | None:
"""Return a pinned charm revision, if any."""
return None

@property
def charm_base(self) -> str:
"""Return the target base for this charm."""
return "ubuntu@24.04"

def config_type(self) -> type[StorageBackendConfig]:
"""Return the configuration model type for this backend."""
return InfinidatConfig
12 changes: 11 additions & 1 deletion sunbeam-python/tests/unit/sunbeam/storage/backends/conftest.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,6 +8,7 @@
from sunbeam.storage.backends.dellpowerstore.backend import DellPowerstoreBackend
from sunbeam.storage.backends.dellsc.backend import DellSCBackend
from sunbeam.storage.backends.hitachi.backend import HitachiBackend
from sunbeam.storage.backends.infinidat.backend import InfinidatBackend
from sunbeam.storage.backends.purestorage.backend import PureStorageBackend


Expand All @@ -29,19 +30,28 @@ def dellsc_backend():
return DellSCBackend()


@pytest.fixture
def infinidat_backend():
"""Provide an INFINIDAT backend instance."""
return InfinidatBackend()


@pytest.fixture
def dellpowerstore_backend():
"""Provide a Dell PowerStore backend instance."""
return DellPowerstoreBackend()


@pytest.fixture(params=["hitachi", "purestorage", "dellsc", "dellpowerstore"])
@pytest.fixture(
params=["hitachi", "purestorage", "dellsc", "infinidat", "dellpowerstore"]
)
def any_backend(request):
"""Parametrized fixture that provides each backend type."""
backends = {
"hitachi": HitachiBackend(),
"purestorage": PureStorageBackend(),
"dellsc": DellSCBackend(),
"infinidat": InfinidatBackend(),
"dellpowerstore": DellPowerstoreBackend(),
}
return backends[request.param]
16 changes: 14 additions & 2 deletions sunbeam-python/tests/unit/sunbeam/storage/backends/test_common.py
Original file line number Diff line number Diff line change
Expand Up @@ -157,13 +157,18 @@ def backend(self, any_backend):


def test_all_backends_have_unique_types(
hitachi_backend, purestorage_backend, dellsc_backend, dellpowerstore_backend
hitachi_backend,
purestorage_backend,
dellsc_backend,
infinidat_backend,
dellpowerstore_backend,
):
"""Test that all backends have unique type identifiers."""
backends = [
hitachi_backend,
purestorage_backend,
dellsc_backend,
infinidat_backend,
dellpowerstore_backend,
]
types = [b.backend_type for b in backends]
Expand All @@ -173,13 +178,18 @@ def test_all_backends_have_unique_types(


def test_all_backends_have_unique_charm_names(
hitachi_backend, purestorage_backend, dellsc_backend, dellpowerstore_backend
hitachi_backend,
purestorage_backend,
dellsc_backend,
infinidat_backend,
dellpowerstore_backend,
):
"""Test that all backends have unique charm names."""
backends = [
hitachi_backend,
purestorage_backend,
dellsc_backend,
infinidat_backend,
dellpowerstore_backend,
]
charm_names = [b.charm_name for b in backends]
Expand All @@ -196,6 +206,7 @@ def test_all_backends_have_unique_charm_names(
("hitachi", "hitachi"),
("purestorage", "purestorage"),
("dellsc", "dellsc"),
("infinidat", "infinidat"),
("dellpowerstore", "dellpowerstore"),
],
)
Expand All @@ -211,6 +222,7 @@ def test_backend_types_match_expected(any_backend, backend_type, expected_type):
("hitachi", "cinder-volume-hitachi"),
("purestorage", "cinder-volume-purestorage"),
("dellsc", "cinder-volume-dellsc"),
("infinidat", "cinder-volume-infinidat"),
("dellpowerstore", "cinder-volume-dellpowerstore"),
],
)
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
# SPDX-FileCopyrightText: 2026 - Canonical Ltd
# SPDX-License-Identifier: Apache-2.0

"""Tests for INFINIDAT backend."""

import pytest
from pydantic import ValidationError

from sunbeam.storage.models import SecretDictField
from tests.unit.sunbeam.storage.backends.test_common import BaseBackendTests


class TestInfinidatBackend(BaseBackendTests):
"""Tests for INFINIDAT backend."""

@pytest.fixture
def backend(self, infinidat_backend):
"""Provide INFINIDAT backend instance."""
return infinidat_backend

def test_backend_type_is_infinidat(self, backend):
"""Test that backend type is 'infinidat'."""
assert backend.backend_type == "infinidat"

def test_charm_name_is_infinidat_charm(self, backend):
"""Test that charm name is cinder-volume-infinidat."""
assert backend.charm_name == "cinder-volume-infinidat"

def test_config_has_required_fields(self, backend):
"""Test that INFINIDAT config has required fields."""
fields = backend.config_type().model_fields
for field in ("san_ip", "san_login", "san_password", "protocol"):
assert field in fields, f"Required field {field} not found in config"

def test_san_credentials_are_secret(self, backend):
"""Test that SAN login and password are marked as secrets."""
config_class = backend.config_type()
for field_name in ("san_login", "san_password"):
field = config_class.model_fields.get(field_name)
assert field is not None
assert any(isinstance(m, SecretDictField) for m in field.metadata), (
f"{field_name} should be marked as secret"
)


class TestInfinidatConfigValidation:
"""Test INFINIDAT config validation behavior."""

def test_protocol_rejects_invalid_value(self, infinidat_backend):
"""Test that protocol rejects values other than iscsi/fc."""
config_class = infinidat_backend.config_type()
with pytest.raises(ValidationError):
config_class.model_validate(
{
"san-ip": "192.168.1.1",
"san-login": "admin",
"san-password": "secret",
"protocol": "nvme",
}
)

def test_protocol_accepts_iscsi(self, infinidat_backend):
"""Test that protocol accepts iscsi."""
config_class = infinidat_backend.config_type()
config = config_class.model_validate(
{
"san-ip": "192.168.1.1",
"san-login": "admin",
"san-password": "secret",
"protocol": "iscsi",
}
)
assert config.protocol == "iscsi"
Loading