dev->main

nodescraper/base/__init__.py

@@ -26,13 +26,15 @@
 from .inbandcollectortask import InBandDataCollector
 from .inbanddataplugin import InBandDataPlugin
 from .oobanddataplugin import OOBandDataPlugin
+from .oobsshdataplugin import OOBSSHDataPlugin
 from .redfishcollectortask import RedfishDataCollector
 from .regexanalyzer import RegexAnalyzer
 
 __all__ = [
     "InBandDataCollector",
     "InBandDataPlugin",
     "OOBandDataPlugin",
+    "OOBSSHDataPlugin",
     "RedfishDataCollector",
     "RegexAnalyzer",
 ]

nodescraper/base/oobsshdataplugin.py

@@ -0,0 +1,54 @@
+###############################################################################
+#
+# MIT License
+#
+# Copyright (c) 2026 Advanced Micro Devices, Inc.
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+#
+###############################################################################
+from __future__ import annotations
+
+from typing import Generic
+
+from nodescraper.connection.redfish import (
+    RedfishConnectionManager,
+    RedfishConnectionParams,
+)
+from nodescraper.generictypes import TAnalyzeArg, TCollectArg, TDataModel
+from nodescraper.interfaces import DataPlugin
+
+
+class OOBSSHDataPlugin(
+    DataPlugin[
+        RedfishConnectionManager,
+        RedfishConnectionParams,
+        TDataModel,
+        TCollectArg,
+        TAnalyzeArg,
+    ],
+    Generic[TDataModel, TCollectArg, TAnalyzeArg],
+):
+    """Base class for out-of-band (OOB) plugins that run shell commands on the BMC.
+
+    Configure the BMC using ``RedfishConnectionManager`` in the connection config.
+    Commands are executed over SSH (port 22) using the same host/username/password.
+    """
+
+    CONNECTION_TYPE = RedfishConnectionManager

nodescraper/configbuilder.py

@@ -109,6 +109,13 @@ def _process_value(cls, value: Any) -> Optional[Union[dict, str, int, float, lis
             return_dict = {}
             for key, val in value.items():
                 return_dict[key] = cls._process_value(val)
+            return return_dict
+
+        if isinstance(value, list):
+            return_list = []
+            for item in value:
+                return_list.append(cls._process_value(item))
+            return return_list
 
         elif not isinstance(
             value,

nodescraper/connection/oob_ssh/__init__.py

@@ -0,0 +1,28 @@
+###############################################################################
+#
+# MIT License
+#
+# Copyright (c) 2026 Advanced Micro Devices, Inc.
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+#
+###############################################################################
+from .oob_ssh_connection_manager import OobSshConnectionManager
+
+__all__ = ["OobSshConnectionManager"]

nodescraper/connection/oob_ssh/oob_ssh_connection_manager.py

@@ -0,0 +1,124 @@
+###############################################################################
+#
+# MIT License
+#
+# Copyright (c) 2026 Advanced Micro Devices, Inc.
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+#
+###############################################################################
+from __future__ import annotations
+
+from logging import Logger
+from typing import Optional, Union
+
+from nodescraper.enums import EventCategory, EventPriority, ExecutionStatus
+from nodescraper.interfaces.connectionmanager import ConnectionManager
+from nodescraper.interfaces.taskresulthook import TaskResultHook
+from nodescraper.models import SystemInfo, TaskResult
+from nodescraper.utils import get_exception_traceback
+
+from ..inband.inband import InBandConnection
+from ..inband.inbandremote import RemoteShell, SSHConnectionError
+from ..redfish.redfish_params import RedfishConnectionParams, redfish_params_to_ssh
+
+
+class OobSshConnectionManager(ConnectionManager[InBandConnection, RedfishConnectionParams]):
+    """SSH to the BMC using the same host and credentials as Redfish (OOB shell)."""
+
+    def __init__(
+        self,
+        system_info: SystemInfo,
+        logger: Optional[Logger] = None,
+        max_event_priority_level: Union[EventPriority, str] = EventPriority.CRITICAL,
+        parent: Optional[str] = None,
+        task_result_hooks: Optional[list[TaskResultHook]] = None,
+        connection_args: Optional[RedfishConnectionParams] = None,
+        **kwargs,
+    ):
+        super().__init__(
+            system_info,
+            logger,
+            max_event_priority_level,
+            parent,
+            task_result_hooks,
+            connection_args,
+            **kwargs,
+        )
+
+    def connect(self) -> TaskResult:
+        if not self.connection_args:
+            self._log_event(
+                category=EventCategory.RUNTIME,
+                description="No Redfish connection parameters provided for OOB SSH",
+                priority=EventPriority.CRITICAL,
+                console_log=True,
+            )
+            self.result.status = ExecutionStatus.EXECUTION_FAILURE
+            return self.result
+
+        raw = self.connection_args
+        if isinstance(raw, dict):
+            params = RedfishConnectionParams.model_validate(raw)
+        elif isinstance(raw, RedfishConnectionParams):
+            params = raw
+        else:
+            self._log_event(
+                category=EventCategory.RUNTIME,
+                description="Redfish connection_args must be dict or RedfishConnectionParams",
+                priority=EventPriority.CRITICAL,
+                console_log=True,
+            )
+            self.result.status = ExecutionStatus.EXECUTION_FAILURE
+            return self.result
+
+        try:
+            ssh_params = redfish_params_to_ssh(params)
+            self.logger.info("Initializing OOB SSH to BMC host %s", ssh_params.hostname)
+            self.connection = RemoteShell(ssh_params)
+            self.connection.connect_ssh()
+        except SSHConnectionError as exception:
+            self._log_event(
+                category=EventCategory.SSH,
+                description=str(exception),
+                priority=EventPriority.CRITICAL,
+                console_log=True,
+            )
+            self.result.status = ExecutionStatus.EXECUTION_FAILURE
+            self.connection = None
+        except Exception as exception:
+            self._log_event(
+                category=EventCategory.SSH,
+                description=f"Exception during OOB SSH: {exception!s}",
+                data=get_exception_traceback(exception),
+                priority=EventPriority.CRITICAL,
+                console_log=True,
+            )
+            self.result.status = ExecutionStatus.EXECUTION_FAILURE
+            self.connection = None
+        return self.result
+
+    def disconnect(self) -> None:
+        conn = self.connection
+        super().disconnect()
+        if isinstance(conn, RemoteShell):
+            try:
+                conn.client.close()
+            except Exception:
+                pass

nodescraper/connection/redfish/__init__.py

@@ -39,7 +39,7 @@
     collect_oem_diagnostic_data,
     get_oem_diagnostic_allowable_values,
 )
-from .redfish_params import RedfishConnectionParams
+from .redfish_params import RedfishConnectionParams, redfish_params_to_ssh
 from .redfish_path import RedfishPath
 
 __all__ = [
@@ -48,6 +48,7 @@
     "RedfishGetResult",
     "RedfishConnectionManager",
     "RedfishConnectionParams",
+    "redfish_params_to_ssh",
     "RedfishPath",
     "collect_oem_diagnostic_data",
     "get_oem_diagnostic_allowable_values",

nodescraper/connection/redfish/redfish_params.py

@@ -23,11 +23,15 @@
 # SOFTWARE.
 #
 ###############################################################################
+from __future__ import annotations
+
 from typing import Optional, Union
 
 from pydantic import BaseModel, ConfigDict, Field, SecretStr
 from pydantic.networks import IPvAnyAddress
 
+from nodescraper.connection.inband.sshparams import SSHConnectionParams
+
 from .redfish_connection import DEFAULT_REDFISH_API_ROOT
 
 
@@ -51,3 +55,28 @@ class RedfishConnectionParams(BaseModel):
         default=DEFAULT_REDFISH_API_ROOT,
         description="Redfish API path (e.g. 'redfish/v1'). Override for a different API version.",
     )
+
+
+def redfish_params_to_ssh(
+    params: Union[RedfishConnectionParams, dict],
+    *,
+    ssh_port: Optional[int] = None,
+    key_filename: Optional[str] = None,
+) -> SSHConnectionParams:
+    """Map Redfish BMC credentials to SSH connection params for shell access."""
+    if isinstance(params, dict):
+        data = dict(params)
+        ssh_port = data.pop("ssh_port", ssh_port if ssh_port is not None else 22)
+        key_filename = data.pop("key_filename", key_filename)
+        params = RedfishConnectionParams.model_validate(data)
+    else:
+        if ssh_port is None:
+            ssh_port = 22
+
+    return SSHConnectionParams(
+        hostname=str(params.host),
+        username=params.username,
+        password=params.password,
+        port=ssh_port,
+        key_filename=key_filename,
+    )

nodescraper/interfaces/connectionmanager.py

@@ -126,7 +126,7 @@ def __init__(
     def __init_subclass__(cls, **kwargs) -> None:
         super().__init_subclass__(**kwargs)
 
-        if hasattr(cls, "connect"):
+        if "connect" in cls.__dict__:
             cls.connect = connect_decorator(cls.connect)
 
     def __enter__(self):