feat(systemd): Add revpi-iosbus.service files

Signed-off-by: Sven Sager <s.sager@kunbus.com>

.gitignore

@@ -1,3 +1,7 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]

.gitlab-ci.yml

@@ -0,0 +1,40 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
+default:
+  tags:
+    - self-hosted
+    - host-arm64
+    - high-perf
+
+include:
+  - project: "revolutionpi/infrastructure/ci-templates"
+    file: "base.yml"
+  - project: "revolutionpi/infrastructure/ci-templates"
+    file: "check-commit/lint-commit.yml"
+  - project: "revolutionpi/infrastructure/ci-templates"
+    file: "reuse-lint.yml"
+  - project: "revolutionpi/infrastructure/ci-templates"
+    file: "package-devel.yml"
+  - local: debian/gitlab-ci.yml
+    rules:
+      - exists:
+          - debian/gitlab-ci.yml
+
+run_tests:
+  stage: test
+  image: python:3.11-bookworm
+  script:
+    - apt-get update
+    - apt-get -y install dbus libgirepository1.0-dev
+    - dbus-uuidgen --ensure=/etc/machine-id
+    - pip install -r requirements.txt
+    - PYTHONPATH=src dbus-run-session -- pytest -v --junitxml=report.xml --cov=src --cov-report term --cov-report xml:coverage.xml
+  coverage: '/(?i)total.*? (100(?:\.0+)?\%|[1-9]?\d(?:\.\d+)?\%)$/'
+  artifacts:
+    reports:
+      junit: ${CI_PROJECT_DIR}/report.xml
+      coverage_report:
+        coverage_format: cobertura
+        path: coverage.xml

MANIFEST.in

@@ -1,3 +1,7 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
 recursive-include .reuse *
 recursive-include data *
 recursive-include LICENSES *

Makefile

@@ -1,3 +1,7 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
 SHELL        := bash
 MAKEFLAGS     = --no-print-directory --no-builtin-rules
 .DEFAULT_GOAL = all

README.md

@@ -1,3 +1,14 @@
+<!--
+SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+
+SPDX-License-Identifier: GPL-2.0-or-later
+-->
+
 # Middleware for Revolution Pi
 
 This middleware will support D-Bus as IPC interface.
+
+## D-Bus
+
+See [docs/dbus.md](docs/dbus.md) for an overview of the standard D-Bus data
+types.

data/dbus-policy/com.revolutionpi.ios1.conf

@@ -0,0 +1,19 @@
+<!-- /usr/share/dbus-1/system.d/com.revolutionpi.ios1.conf -->
+<busconfig>
+    <!-- Allow full access to root as the bus owner -->
+    <policy user="root">
+        <allow own="com.revolutionpi.ios1"/>
+        <allow send_destination="com.revolutionpi.ios1"/>
+        <allow receive_sender="com.revolutionpi.ios1"/>
+    </policy>
+
+    <!-- System group picontrol -->
+    <policy group="picontrol">
+        <allow send_destination="com.revolutionpi.ios1"/>
+    </policy>
+
+    <!-- Standard-Policy -->
+    <policy context="default">
+        <deny send_destination="com.revolutionpi.ios1"/>
+    </policy>
+</busconfig>

data/dbus-policy/com.revolutionpi.middleware1.conf

@@ -1,4 +1,4 @@
-<!-- /etc/dbus-1/system.d/revpi-middleware.conf -->
+<!-- /usr/share/dbus-1/system.d/com.revolutionpi.middleware1.conf -->
 <busconfig>
     <!-- Allow full access to root as the bus owner -->
     <policy user="root">
@@ -12,7 +12,7 @@
         <allow send_destination="com.revolutionpi.middleware1"
                send_interface="org.freedesktop.DBus.Introspectable"/>
         <allow send_destination="com.revolutionpi.middleware1"
-               send_interface="com.revolutionpi.middleware1.picontrol"/>
+               send_interface="com.revolutionpi.middleware1.PiControl"/>
     </policy>
 
     <!-- Standard-Policy -->

data/etc/default/revpi-ios

@@ -0,0 +1,8 @@
+# Additional options that are passed to revpi-ios.
+#   add '-f /var/log/revpi-ios.log' to write logs to own log file
+#   add '-v' or '-vv' for verbose logging
+
+DAEMON_OPTS=""
+
+# In addition to journalctl, use your own additional log file
+# DAEMON_OPTS="-f /var/log/revpi-ios.log"

data/etc/logrotate/revpi-ios

@@ -0,0 +1,14 @@
+/var/log/revpi-ios.log
+{
+    rotate 6
+    weekly
+    maxsize 1M
+    compress
+    delaycompress
+    missingok
+    notifempty
+    sharedscripts
+    postrotate
+        systemctl kill --signal=SIGUSR1 revpi-ios > /dev/null 2>&1 || true
+    endscript
+}

data/examples/io_controller.py

@@ -0,0 +1,65 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""Switches 14 outputs on a DIO to the same value as the first input."""
+
+from time import perf_counter
+
+from gi.repository import GLib
+from pydbus import SystemBus
+
+detected_signal = False
+timestamp = perf_counter()
+
+# Get system bus
+bus = SystemBus()
+
+# Get IoManager interface on ios1 bus
+iface_io_manager = bus.get(
+    "com.revolutionpi.ios1",
+    "/com/revolutionpi/ios1",
+)["com.revolutionpi.ios1.IoManager"]
+
+# Query object path of RevPiLED output
+path_revpi_led = iface_io_manager.Get("RevPiLED")
+
+# Get Output interface in the queried object path.
+out_RevPiLED = bus.get("com.revolutionpi.ios1", path_revpi_led)["com.revolutionpi.ios1.Output"]
+
+# Get all 14 outputs
+lst_path_outputs = [iface_io_manager.Get(f"O_{i}") for i in range(1, 15)]
+lst_out_outputs = [
+    bus.get("com.revolutionpi.ios1", path)["com.revolutionpi.ios1.Output"]
+    for path in lst_path_outputs
+]
+
+
+def signal_handler(io_name, io_value):
+    global timestamp
+
+    print(f"Signal received: {io_name} = {io_value}")
+
+    if io_name == "O_14":
+        print(f"Time since input detection: {perf_counter() - timestamp}")
+
+    elif io_name == "I_1":
+        timestamp = perf_counter()
+
+        out_RevPiLED.SetValue(GLib.Variant("i", io_value))
+        for output in lst_out_outputs:
+            output.SetValue(GLib.Variant("b", io_value))
+
+
+# Start change detection to fire signals on dbus
+iface_io_manager.ActivateIoSignals()
+
+iface_io_manager.onIoChanged = signal_handler
+
+try:
+    loop = GLib.MainLoop()
+    loop.run()
+except KeyboardInterrupt:
+    pass
+
+# Stop change detection
+iface_io_manager.DeactivateIoSignals()

data/systemd/before_253/revpi-ios.service

@@ -0,0 +1,12 @@
+[Unit]
+Description=D-Bus interface for Inputs/Outputs of Revolution Pi
+
+[Service]
+EnvironmentFile=-/etc/default/revpi-ios
+Type=notify
+NotifyAccess=all
+ExecStart=/usr/sbin/revpi-middleware ios $DAEMON_OPTS
+ExecReload=/bin/kill -HUP $MAINPID
+
+[Install]
+WantedBy=multi-user.target

data/systemd/from_253/revpi-ios.service

@@ -0,0 +1,11 @@
+[Unit]
+Description=D-Bus interface for Inputs/Outputs of Revolution Pi
+
+[Service]
+EnvironmentFile=-/etc/default/revpi-ios
+Type=notify-reload
+NotifyAccess=all
+ExecStart=/usr/sbin/revpi-middleware ios $DAEMON_OPTS
+
+[Install]
+WantedBy=multi-user.target

docs/dbus.md

@@ -0,0 +1,51 @@
+<!--
+SPDX-FileCopyrightText: 2026 KUNBUS GmbH <support@kunbus.com>
+
+SPDX-License-Identifier: GPL-2.0-or-later
+-->
+
+# D-Bus
+
+## Datentypen
+
+Hier ist eine **Liste der standardisierten D‑Bus-Datentypen** (Signaturen), wie
+sie u. a. in Introspection/XML (`type="..."`) verwendet werden.
+
+## Basis-Typen (Basic Types)
+
+| Signatur | Bedeutung                           |
+|----------|-------------------------------------|
+| `y`      | Byte (unsigned 8-bit)               |
+| `b`      | Boolean                             |
+| `n`      | Int16 (signed)                      |
+| `q`      | UInt16 (unsigned)                   |
+| `i`      | Int32 (signed)                      |
+| `u`      | UInt32 (unsigned)                   |
+| `x`      | Int64 (signed)                      |
+| `t`      | UInt64 (unsigned)                   |
+| `d`      | Double (IEEE 754)                   |
+| `s`      | String (UTF‑8)                      |
+| `o`      | Object Path                         |
+| `g`      | Signature (Typ-Signatur als String) |
+
+## Container-Typen (Compound/Container)
+
+| Form       | Bedeutung                                       | Beispiel                        |
+|------------|-------------------------------------------------|---------------------------------|
+| `aX`       | Array von `X`                                   | `as` = Array von Strings        |
+| `(XYZ...)` | Struct/Tupel                                    | `(is)` = (Int32, String)        |
+| `{KV}`     | Dict-Entry (nur innerhalb eines Arrays erlaubt) | `a{sv}` = Dict String → Variant |
+
+## Spezial-Typ
+
+| Signatur | Bedeutung                                         |
+|----------|---------------------------------------------------|
+| `v`      | Variant (beliebiger Typ, zur Laufzeit festgelegt) |
+
+## Häufig genutzte Kombis (Praxis)
+
+- `as` → Liste von Strings
+- `ao` → Liste von Object Paths
+- `a{sv}` → „Properties“-Map (String → Variant), sehr verbreitet bei
+  `org.freedesktop.DBus.Properties`
+- `a{ss}` → String → String Map

examples/revpi-config

@@ -0,0 +1,100 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+from argparse import ArgumentParser, SUPPRESS
+from typing import NamedTuple
+
+from pydbus import SessionBus, SystemBus
+
+FeatureMapping = NamedTuple("FeatureMapping", [("dbus_interface", str), ("name", str)])
+
+REVPI_DBUS_NAME = "com.revolutionpi.middleware1"
+REVPI_DBUS_BASE_PATH = "/com/revolutionpi/middleware1"
+IFACE_SOFTWARE_SERVICES = "com.revolutionpi.middleware1.SoftwareServices"
+IFACE_REVPI_CONFIG = "com.revolutionpi.middleware1.RevpiConfig"
+
+REVPI_FEATURE_MAPPINGS = {
+    "gui": FeatureMapping(IFACE_REVPI_CONFIG, "gui"),
+    "revpi-con-can": FeatureMapping(IFACE_REVPI_CONFIG, "revpi-con-can"),
+    "dphys-swapfile": FeatureMapping(IFACE_REVPI_CONFIG, "swapfile"),
+    "pimodbus-master": FeatureMapping(IFACE_SOFTWARE_SERVICES, "pimodbus-master"),
+    "pimodbus-slave": FeatureMapping(IFACE_SOFTWARE_SERVICES, "pimodbus-slave"),
+    "systemd-timesyncd": FeatureMapping(IFACE_SOFTWARE_SERVICES, "ntp"),
+    "ssh": FeatureMapping(IFACE_SOFTWARE_SERVICES, "ssh"),
+    "nodered": FeatureMapping(IFACE_SOFTWARE_SERVICES, "nodered"),
+    "noderedrevpinodes-server": FeatureMapping(IFACE_SOFTWARE_SERVICES, "noderedrevpinodes-server"),
+    "revpipyload": FeatureMapping(IFACE_SOFTWARE_SERVICES, "revpipyload"),
+    "bluetooth": FeatureMapping(IFACE_REVPI_CONFIG, "bluetooth"),
+    "ieee80211": FeatureMapping(IFACE_REVPI_CONFIG, "wlan"),
+    "avahi": FeatureMapping(IFACE_SOFTWARE_SERVICES, "avahi"),
+    "external-antenna": FeatureMapping(IFACE_REVPI_CONFIG, "external-antenna"),
+}
+
+# Generate command arguments
+parser = ArgumentParser(
+    prog="revpi-config",
+    description="Configuration tool for Revolution Pi.",
+)
+parser.add_argument(
+    "--use-session-bus",
+    dest="use_session_bus",
+    action="store_true",
+    default=False,
+    help=SUPPRESS,
+)
+parser.add_argument(
+    "action",
+    choices=["enable", "disable", "status", "available", "availstat"],
+    help="Action to be executed: enable, disable, status or available.",
+)
+parser.add_argument(
+    "feature",
+    nargs="*",
+    help="Name of the feature to configure.",
+)
+args = parser.parse_args()
+
+# Init dbus
+bus = SessionBus() if args.use_session_bus else SystemBus()
+revpi_middleware = bus.get(REVPI_DBUS_NAME, REVPI_DBUS_BASE_PATH)
+
+lst_results = []
+for feature in args.feature:
+
+    # Get the mappings
+    feature_mapping = REVPI_FEATURE_MAPPINGS.get(feature, None)
+
+    if feature_mapping is None:
+        if args.action in ("enable", "disable"):
+            # Missing feature with action enable/disable will return 5
+            lst_results.append(5)
+        elif args.action == "availstat":
+            # Missing feature with action availstat will return 2
+            lst_results.append(2)
+        else:
+            # Missing feature with action status/available will return 0
+            lst_results.append(0)
+
+        continue
+
+    dbus_interface = revpi_middleware[feature_mapping.dbus_interface]
+
+    if args.action == "enable":
+        dbus_interface.Enable(feature_mapping.name)
+        lst_results.append(0)
+
+    elif args.action == "disable":
+        dbus_interface.Disable(feature_mapping.name)
+        lst_results.append(0)
+
+    elif args.action in ("status", "availstat"):
+        status = dbus_interface.GetStatus(feature_mapping.name)
+        lst_results.append(int(status))
+
+    elif args.action == "available":
+        availability = dbus_interface.GetAvailability(feature_mapping.name)
+        lst_results.append(int(availability))
+
+if lst_results:
+    print(" ".join(map(str, lst_results)))

pyproject.toml

@@ -1,2 +1,6 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
 [tool.black]
 line-length = 100

requirements.txt

@@ -1,3 +1,7 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH <support@kunbus.com>
+#
+# SPDX-License-Identifier: GPL-2.0-or-later
+
 # Build dependencies
 pip-licenses
 Pyinstaller

src/revpi_middleware/__about__.py

@@ -2,6 +2,7 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """Metadata of package."""
+
 __author__ = "Sven Sager"
 __copyright__ = "Copyright (C) 2025 KUNBUS GmbH"
 __license__ = " GPL-2.0-or-later"

src/revpi_middleware/__init__.py

@@ -2,4 +2,5 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """Package: revpi_middleware."""
+
 from .__about__ import __author__, __copyright__, __license__, __version__

src/revpi_middleware/cli_commands/__init__.py

@@ -2,4 +2,5 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """CLI commands to control revpi_middleware."""
+
 from ..__about__ import __author__, __copyright__, __license__, __version__

src/revpi_middleware/cli_commands/cli_base.py

@@ -5,12 +5,12 @@
 This module provides the foundation for the RevPi middleware CLI commands
 and argument parsing setup.
 """
-from argparse import ArgumentParser
+
 from logging import getLogger
 
-from revpi_middleware.cli_commands import cli_picontrol
+from . import cli_config, cli_picontrol
-from revpi_middleware.proginit import StdLogOutput
 from .. import proginit as pi
+from ..proginit import StdLogOutput
 
 log = getLogger(__name__)
 
@@ -30,6 +30,11 @@ def setup_command_line_arguments():
         help="RevPi PiControl object",
     )
     cli_picontrol.add_subparsers(obj_picontrol)
+    obj_config = rpictl_obj.add_parser(
+        "config",
+        help="RevPi configuration object (revpi-config)",
+    )
+    cli_config.add_subparsers(obj_config)
 
 
 def main() -> int:
@@ -40,6 +45,9 @@ def main() -> int:
     if obj == "picontrol":
         rc = cli_picontrol.main()
 
+    elif obj == "config":
+        rc = cli_config.main()
+
     else:
         log.error(f"Unknown object: {obj}")
         rc = 1

src/revpi_middleware/cli_commands/cli_config.py

@@ -0,0 +1,94 @@
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""Command-Line for the picontrol object of CLI."""
+
+from argparse import ArgumentParser
+from logging import getLogger
+
+from .dbus_helper import BusType, get_properties, simple_call
+from .. import proginit as pi
+from ..dbus_middleware1 import extend_interface
+
+log = getLogger(__name__)
+
+
+def add_subparsers(parent_parser: ArgumentParser):
+    parent_parser.add_argument(
+        "action",
+        choices=["enable", "disable", "status", "available", "list-features"],
+        help="Action to be executed: enable, disable, status or available. "
+        "To get all available features, use 'list-features'.",
+    )
+    parent_parser.add_argument(
+        "feature",
+        nargs="?",
+        default="",
+        help="Name of the feature to configer. To list all features use 'list-features' as action.",
+    )
+
+
+def main() -> int:
+    action = pi.pargs.action
+    dbus_value = False
+    try:
+
+        if action == "list-features":
+            dbus_value = get_properties(
+                "available_features",
+                interface=extend_interface("RevpiConfig"),
+                bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
+            )
+            for feature in dbus_value:
+                print(feature)
+
+            return 0
+
+        # For the following actions, a feature name is required
+        if pi.pargs.feature == "":
+            raise Exception("Feature name is required")
+
+        if action == "enable":
+            simple_call(
+                "Enable",
+                pi.pargs.feature,
+                interface=extend_interface("RevpiConfig"),
+                bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
+            )
+
+        elif action == "disable":
+            simple_call(
+                "Disable",
+                pi.pargs.feature,
+                interface=extend_interface("RevpiConfig"),
+                bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
+            )
+
+        elif action == "status":
+            dbus_value = simple_call(
+                "GetStatus",
+                pi.pargs.feature,
+                interface=extend_interface("RevpiConfig"),
+                bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
+            )
+
+        elif action == "available":
+            dbus_value = simple_call(
+                "GetAvailability",
+                pi.pargs.feature,
+                interface=extend_interface("RevpiConfig"),
+                bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
+            )
+
+        else:
+            raise Exception(f"Unknown action: {action}")
+
+    except Exception as e:
+        log.error(f"Error: {e}")
+        return 1
+
+    log.debug(
+        f"D-Bus call of method {action} for feature {pi.pargs.feature} returned: {dbus_value}"
+    )
+    print(int(dbus_value))
+
+    return 0

src/revpi_middleware/cli_commands/cli_picontrol.py

@@ -1,6 +1,7 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """Command-Line for the picontrol object of CLI."""
+
 from argparse import ArgumentParser
 from logging import getLogger
 
@@ -38,7 +39,7 @@ def method_reset():
     log.debug("D-Bus call of method ResetDriver")
     simple_call(
         "ResetDriver",
-        interface=extend_interface("picontrol"),
+        interface=extend_interface("PiControl"),
         bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
     )
     log.info("ResetDriver called via D-Bus")
@@ -48,7 +49,7 @@ def method_await_reset(timeout: int = 0):
     detected_signal = await_signal(
         "NotifyDriverReset",
         timeout,
-        extend_interface("picontrol"),
+        extend_interface("PiControl"),
         bus_type=BusType.SESSION if pi.pargs.use_session_bus else BusType.SYSTEM,
     )
     if detected_signal:

src/revpi_middleware/cli_commands/dbus_helper.py

@@ -1,6 +1,7 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """D-Bus helper functions for cli commands."""
+
 from enum import Enum
 from threading import Thread
 from time import sleep
@@ -17,6 +18,18 @@ class BusType(Enum):
     SYSTEM = "system"
 
 
+def get_properties(
+    property_name: str,
+    interface: str,
+    object_path=REVPI_DBUS_BASE_PATH,
+    bus_type=BusType.SYSTEM,
+):
+    bus = SessionBus() if bus_type is BusType.SESSION else SystemBus()
+    revpi = bus.get(REVPI_DBUS_NAME, object_path)
+    iface = revpi[interface]
+    return getattr(iface, property_name)
+
+
 def simple_call(
     method: str,
     *args,

src/revpi_middleware/daemon.py

@@ -3,29 +3,43 @@
 # SPDX-License-Identifier: GPL-2.0-or-later
 """Main daemon of revpi-middleware."""
 
+from enum import Enum
 from logging import getLogger
+from os import environ
 from threading import Event
 from time import perf_counter
 
+from gi.repository import Gio
+
 from . import proginit as pi
-from .dbus_middleware1.bus_provider import BusProvider
+from .dbus_ios1 import BusProviderIos1
+from .dbus_middleware1 import BusProviderMiddleware1
+from .dbus_middleware1.process_image.process_image_helper import ResetDriverWatchdog
 
 log = getLogger(__name__)
 
 
+class BusProvider(Enum):
+    middleware = "middleware"
+    ios = "ios"
+
+
 class MiddlewareDaemon:
     """Main program of MiddlewareDaemon class."""
 
-    def __init__(self):
+    def __init__(self, bus_provider: BusProvider):
         """Init MiddlewareDaemon class."""
         log.debug("enter MiddlewareDaemon.__init__")
 
         self._cycle_time = 1.0
         self.do_cycle = Event()
+        self._force_dbus_restart = False
         self._reconfigure = False
         self._running = True
 
         self.bus_provider = None
+        self.bus_provider_selected = bus_provider
+        self.wd_reset = ResetDriverWatchdog("")
 
         self._configure()
         log.debug("leave MiddlewareDaemon.__init__")
@@ -35,15 +49,57 @@ class MiddlewareDaemon:
         log.debug("enter MiddlewareDaemon._configure")
         pi.reload_conf()
 
+        if self._force_dbus_restart:
+            self.dbus_stop()
+        self._force_dbus_restart = False
+
+        if pi.pargs.procimg != self.wd_reset.procimg:
+            self.dbus_stop()
+
+            self.wd_reset.stop()
+            self.wd_reset = ResetDriverWatchdog(pi.pargs.procimg)
+            self.wd_reset.register_call(self._reset_driver_callack)
+
         log.debug("leave MiddlewareDaemon._configure")
 
+    @staticmethod
+    def _get_bus_address() -> str:
+        if pi.pargs.use_session_bus:
+            environ_name = "DBUS_SESSION_BUS_ADDRESS"
+            bus_address = Gio.dbus_address_get_for_bus_sync(Gio.BusType.SESSION)
+        else:
+            environ_name = "DBUS_SYSTEM_BUS_ADDRESS"
+            bus_address = Gio.dbus_address_get_for_bus_sync(Gio.BusType.SYSTEM)
+
+        return environ.get(environ_name, bus_address)
+
+    def _reset_driver_callack(self, *args) -> None:
+        log.debug("enter MiddlewareDaemon._reset_driver_callack")
+
+        if self.bus_provider_selected is BusProvider.ios:
+            self._force_dbus_restart = True
+            self.reload_config()
+
+        log.debug("leave MiddlewareDaemon._reset_driver_callack")
+
     def dbus_start(self):
         log.debug("enter MiddlewareDaemon.dbus_start")
-        if self.bus_provider and self.bus_provider.is_alive():
-            return
 
-        self.bus_provider = BusProvider(use_system_bus=not pi.pargs.use_session_bus)
+        dbus_running = self.bus_provider and self.bus_provider.is_alive()
-        self.bus_provider.start()
+        if not dbus_running:
+            if self.bus_provider_selected is BusProvider.middleware:
+                self.bus_provider = BusProviderMiddleware1(
+                    dbus_address=self._get_bus_address(),
+                    picontrol_device=pi.pargs.procimg,
+                )
+            elif self.bus_provider_selected is BusProvider.ios:
+                self.bus_provider = BusProviderIos1(
+                    dbus_address=self._get_bus_address(),
+                    picontrol_device=pi.pargs.procimg,
+                )
+            else:
+                raise ValueError("Unknown bus provider")
+            self.bus_provider.start()
 
         log.debug("leave MiddlewareDaemon.dbus_start")
 
@@ -54,7 +110,7 @@ class MiddlewareDaemon:
             self.bus_provider.stop()
             self.bus_provider.join(timeout=10.0)
             if self.bus_provider.is_alive():
-                log.warning("dbus provider thread is still alive")
+                log.warning(f"dbus {self.bus_provider.name} thread is still alive")
 
         log.debug("leave MiddlewareDaemon.dbus_stop")
 
@@ -85,7 +141,6 @@ class MiddlewareDaemon:
         # Startup tasks
         self.dbus_start()
 
-        pi.startup_complete()
         # Go into mainloop of daemon
         while self._running:
             ot = perf_counter()
@@ -95,6 +150,13 @@ class MiddlewareDaemon:
             if self._reconfigure:
                 self._configure()
                 self._reconfigure = False
+
+            # Monitor bus providers for errors and restart them
+            if not (self.bus_provider and self.bus_provider.is_alive()):
+                log.warning(f"dbus {self.bus_provider.name} thread is not alive - restarting")
+                self.dbus_start()
+
+            if self.bus_provider and self.bus_provider.published.is_set():
                 pi.startup_complete()
 
             # Cycle time calculation

src/revpi_middleware/dbus_ios1/__init__.py

@@ -0,0 +1,8 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus ios version 1 of revpi_middleware."""
+
+from .ios1_helper import REVPI_DBUS_BASE_PATH, REVPI_DBUS_NAME
+
+from .bus_provider_ios1 import BusProviderIos1

src/revpi_middleware/dbus_ios1/bus_provider_ios1.py

@@ -0,0 +1,121 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus bus provider for revpi_middleware."""
+
+from logging import getLogger
+from threading import Thread, Event
+
+import revpimodio2
+from gi.repository import GLib
+from pydbus import connect
+
+from . import REVPI_DBUS_NAME
+from .interface_devices import (
+    InterfaceDeviceManager,
+    InterfaceDevice,
+)
+from .interface_ios import (
+    InterfaceIoManager,
+    InterfaceInput,
+    InterfaceOutput,
+)
+
+log = getLogger(__name__)
+
+
+class BusProviderIos1(Thread):
+
+    def __init__(
+        self,
+        dbus_address: str,
+        picontrol_device="/dev/piControl0",
+        config_rsc="/etc/revpi/config.rsc",
+    ):
+        log.debug("enter BusProviderIos1.__init__")
+        super().__init__()
+
+        self._bus_address = dbus_address
+        self._loop = GLib.MainLoop()
+        self._lst_device_interfaces = []
+        self._lst_io_interfaces = []
+        self._modio = revpimodio2.RevPiModIO(
+            procimg=picontrol_device,
+            configrsc=config_rsc,
+            shared_procimg=True,
+        )
+
+        self.picontrol_device = picontrol_device
+        self.published = Event()
+        self.config_rsc = config_rsc
+
+    def run(self):
+        log.debug("enter BusProviderIos1.run")
+        bus = connect(self._bus_address)
+
+        self._lst_device_interfaces.clear()
+        self._lst_io_interfaces.clear()
+
+        for device in self._modio.device:
+            self._lst_device_interfaces.append(
+                InterfaceDevice(bus, device),
+            )
+
+        for io in self._modio.io:
+            interface = None
+            try:
+                if io.type == revpimodio2.INP:
+                    interface = InterfaceInput(bus, io)
+                elif io.type == revpimodio2.OUT:
+                    interface = InterfaceOutput(bus, io)
+                elif io.type == revpimodio2.MEM:
+                    # todo: Implement memory
+                    pass
+            except Exception as e:
+                log.warning(f"can not create dbus interface for {io.name}: {e}")
+
+            if interface is not None:
+                self._lst_io_interfaces.append(interface)
+
+        lst_interfaces = []
+        lst_interfaces += [
+            (interface.object_path, interface) for interface in self._lst_device_interfaces
+        ]
+        lst_interfaces += [
+            (interface.object_path, interface) for interface in self._lst_io_interfaces
+        ]
+        try:
+            bus.publish(
+                REVPI_DBUS_NAME,
+                InterfaceDeviceManager(self._lst_device_interfaces),
+                InterfaceIoManager(self._lst_io_interfaces, self._modio),
+                *lst_interfaces,
+            )
+            self.published.set()
+            log.info(f"published {REVPI_DBUS_NAME} on {self._bus_address}")
+        except Exception as e:
+            log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}")
+
+        try:
+            self._loop.run()
+        except Exception as e:
+            log.error(f"can not run dbus mainloop: {e}")
+
+        bus.con.close()
+        self._modio.cleanup()
+        log.info(f"closed {REVPI_DBUS_NAME} connection to {self._bus_address}")
+
+        log.debug("leave BusProviderIos1.run")
+
+    def stop(self):
+        log.debug("enter BusProviderIos1.stop")
+        self._loop.quit()
+        log.debug("leave BusProviderIos1.stop")
+
+    @property
+    def name(self) -> str:
+        return REVPI_DBUS_NAME
+
+    @property
+    def running(self):
+        return self._loop.is_running()

src/revpi_middleware/dbus_ios1/interface_devices.py

@@ -0,0 +1,133 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus interfaces for IOs."""
+
+from pydbus.bus import Bus
+from pydbus.generic import signal
+from revpimodio2.device import Device
+
+from .ios1_helper import get_io_object_path, get_device_object_path
+
+
+class InterfaceDevice:
+    """
+    <node>
+        <interface name="com.revolutionpi.ios1.Device">
+            <method name="GetDeviceInputs">
+                <arg name="object-path-list" type="ao" direction="out"/>
+            </method>
+            <method name="GetDeviceOutputs">
+                <arg name="object-path-list" type="ao" direction="out"/>
+            </method>
+            <property name="bmk" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="catalognr" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="comment" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="id" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="name" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="position" type="n" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="type" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+        </interface>
+    </node>
+    """
+
+    interface_name = "com.revolutionpi.ios1.Device"
+    PropertiesChanged = signal()
+
+    def __init__(self, dbus: Bus, device: Device):
+        self.dbus = dbus
+        self.device = device
+        self.object_path = get_device_object_path(device)
+
+    def GetDeviceInputs(self) -> list[str]:
+        return [get_io_object_path(io) for io in self.device.get_inputs()]
+
+    def GetDeviceOutputs(self) -> list[str]:
+        return [get_io_object_path(io) for io in self.device.get_outputs()]
+
+    @property
+    def bmk(self) -> str:
+        return self.device.bmk
+
+    @property
+    def catalognr(self):
+        return self.device.catalognr
+
+    @property
+    def comment(self):
+        return self.device.comment
+
+    @property
+    def id(self):
+        return self.device.id
+
+    @property
+    def name(self) -> str:
+        return self.device.name
+
+    @property
+    def position(self) -> int:
+        return self.device.position
+
+    @property
+    def type(self):
+        return self.device.type
+
+
+class InterfaceDeviceManager:
+    """
+    <node>
+        <interface name="com.revolutionpi.ios1.DeviceManager">
+            <method name="GetAllDevices">
+                <arg type="ao" direction="out"/>
+            </method>
+            <method name="GetByName">
+                <arg name="device-name" type="s" direction="in"/>
+                <arg name="object-path" type="o" direction="out"/>
+            </method>
+            <method name="GetByPosition">
+                <arg name="device-position" type="n" direction="in"/>
+                <arg name="object-path" type="o" direction="out"/>
+            </method>
+        </interface>
+    </node>
+    """
+
+    interface_name = "com.revolutionpi.ios1.DeviceManager"
+
+    def __init__(
+        self,
+        device_interfaces: list[InterfaceDevice],
+    ):
+        self._lst_device_interfaces = device_interfaces
+
+    def GetAllDevices(self) -> list[str]:
+        return [interface.object_path for interface in self._lst_device_interfaces]
+
+    def GetByName(self, device_name) -> str:
+        for interface in self._lst_device_interfaces:
+            if interface.device.name == device_name:
+                return interface.object_path
+
+        raise KeyError(f"No device with name '{device_name}' found.")
+
+    def GetByPosition(self, device_position) -> str:
+        for interface in self._lst_device_interfaces:
+            if interface.device.position == device_position:
+                return interface.object_path
+
+        raise KeyError(f"No device on position '{device_position}' found.")

src/revpi_middleware/dbus_ios1/interface_ios.py

@@ -0,0 +1,306 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus interfaces for IOs."""
+
+from typing import Union, List
+
+from pydbus import Variant
+from pydbus.bus import Bus
+from pydbus.generic import signal
+from revpimodio2 import RevPiModIO, Cycletools, INP, OUT
+from revpimodio2.io import IOBase
+
+from .ios1_helper import get_io_object_path, get_variant_type
+
+
+class InterfaceInput:
+    """
+    <node>
+        <interface name="com.revolutionpi.ios1.Input">
+            <method name="SetByteorder">
+                <arg name="order" type="s" direction="in"/>
+            </method>
+            <method name="SetSigned">
+                <arg name="signed" type="b" direction="in"/>
+            </method>
+            <property name="address" type="n" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="bmk" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="bitaddress" type="n" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="byteorder" type="s" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="invalidates"/>
+            </property>
+            <property name="defaultvalue" type="v" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="length" type="q" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="name" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="signed" type="b" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="invalidates"/>
+            </property>
+            <property name="value" type="v" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="true"/>
+            </property>
+        </interface>
+    </node>
+    """
+
+    interface_name = "com.revolutionpi.ios1.Input"
+    PropertiesChanged = signal()
+
+    def __init__(self, dbus: Bus, io: IOBase):
+        self._raw = False
+        self.dbus = dbus
+        self.io = io
+        self.object_path = get_io_object_path(io)
+        try:
+            self.variant_type = get_variant_type(self.io)
+        except ValueError:
+            # Fallback to bytes if the integer is too large
+            self._raw = True
+            self.variant_type = "ay"
+
+    def emit_io_change(self):
+        self.PropertiesChanged(
+            self.interface_name,
+            {
+                "value": Variant(
+                    self.variant_type,
+                    self.io.get_value() if self._raw else self.io.value,
+                ),
+            },
+            [],
+        )
+
+    def SetByteorder(self, order: str) -> None:
+        self.byteorder = order
+
+    def SetSigned(self, signed: bool) -> None:
+        self.signed = signed
+
+    @property
+    def address(self) -> int:
+        return self.io.address
+
+    @property
+    def bmk(self) -> str:
+        return self.io.bmk
+
+    @property
+    def bitaddress(self) -> int:
+        return self.io._bitaddress
+
+    @property
+    def byteorder(self) -> str:
+        return self.io.byteorder
+
+    @byteorder.setter
+    def byteorder(self, value: str) -> None:
+        if hasattr(self.io, "_set_byteorder"):
+            self.io._set_byteorder(value)
+            self.variant_type = get_variant_type(self.io)
+
+            # Changing the byteorder can change the value, but we do NOT send a signal for that
+            # because the real value of the process image was not changed. But we inform the client
+            # about the changed byteorder property.
+            self.PropertiesChanged(
+                self.interface_name,
+                {},
+                ["byteorder"],
+            )
+
+    @property
+    def defaultvalue(self) -> Variant:
+        return Variant(
+            self.variant_type,
+            self.io.get_value() if self._raw else self.io.defaultvalue,
+        )
+
+    @property
+    def length(self) -> int:
+        # 0 length for boolean
+        return 0 if self.variant_type == "b" else self.io.length
+
+    @property
+    def name(self) -> str:
+        return self.io.name
+
+    @property
+    def signed(self) -> bool:
+        if hasattr(self.io, "signed"):
+            return self.io.signed
+        return False
+
+    @signed.setter
+    def signed(self, value: bool) -> None:
+        if hasattr(self.io, "_set_signed"):
+            self.io._set_signed(value)
+            self.variant_type = get_variant_type(self.io)
+
+            # Changing the signedness can change the value, but we do NOT send a signal for that
+            # because the real value of the process image was not changed. But we inform the client
+            # about the changed signedness property.
+            self.PropertiesChanged(
+                self.interface_name,
+                {},
+                ["signed"],
+            )
+
+    @property
+    def value(self) -> Variant:
+        if not self.io._parentdevice._selfupdate:
+            self.io._parentdevice.readprocimg()
+
+        return Variant(
+            self.variant_type,
+            self.io.get_value() if self._raw else self.io.value,
+        )
+
+
+class InterfaceOutput(InterfaceInput):
+    """
+    <node>
+        <interface name="com.revolutionpi.ios1.Output">
+            <method name="SetByteorder">
+                <arg name="order" type="s" direction="in"/>
+            </method>
+            <method name="SetSigned">
+                <arg name="signed" type="b" direction="in"/>
+            </method>
+            <method name="SetValue">
+                <arg name="value" type="v" direction="in"/>
+            </method>
+            <property name="address" type="n" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="bmk" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="bitaddress" type="n" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="byteorder" type="s" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="invalidates"/>
+            </property>
+            <property name="defaultvalue" type="v" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="length" type="q" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="name" type="s" access="read">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="const"/>
+            </property>
+            <property name="signed" type="b" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="invalidates"/>
+            </property>
+            <property name="value" type="v" access="readwrite">
+                <annotation name="org.freedesktop.DBus.Property.EmitsChangedSignal" value="true"/>
+            </property>
+        </interface>
+    </node>
+    """
+
+    interface_name = "com.revolutionpi.ios1.Output"
+
+    def SetValue(self, value: Variant) -> None:
+        self.value = value
+
+    @property
+    def value(self) -> Variant:
+        return super().value
+
+    @value.setter
+    def value(self, value: Variant) -> None:
+        if self._raw:
+            self.io.set_value(value)
+        else:
+            self.io.value = value
+        if not self.io._parentdevice._selfupdate:
+            self.io._parentdevice.writeprocimg()
+
+
+class InterfaceIoManager:
+    """
+    <node>
+        <interface name="com.revolutionpi.ios1.IoManager">
+            <method name="GetAllInputs">
+                <arg name="object-path-list" type="ao" direction="out"/>
+            </method>
+            <method name="GetAllOutputs">
+                <arg name="object-path-list" type="ao" direction="out"/>
+            </method>
+            <method name="GetByName">
+                <arg name="name" type="s" direction="in"/>
+                <arg name="object-path" type="o" direction="out"/>
+            </method>
+            <method name="ActivateIoSignals">
+            </method>
+            <method name="DeactivateIoSignals">
+            </method>
+            <signal name="IoChanged">
+                <arg name="name" type="s" direction="out"/>
+                <arg name="value" type="v" direction="out"/>
+            </signal>
+        </interface>
+    </node>
+    """
+
+    interface_name = "com.revolutionpi.ios1.IoManager"
+    IoChanged = signal()
+
+    def __init__(
+        self,
+        io_interfaces: List[Union[InterfaceInput, InterfaceOutput]],
+        modio: RevPiModIO,
+    ):
+        self._dc_io_interfaces = {interface.name: interface for interface in io_interfaces}
+        self.modio = modio
+
+        self.lst_inp_object_path = []
+        self.lst_out_object_path = []
+        for interface in io_interfaces:
+            if interface.io.type == INP:
+                self.lst_inp_object_path.append(interface.object_path)
+            elif interface.io.type == OUT:
+                self.lst_out_object_path.append(interface.object_path)
+
+    def _modio_cycle(self, ct: Cycletools) -> None:
+        for io_name in self._dc_io_interfaces:
+            interface = self._dc_io_interfaces[io_name]
+            if ct.changed(interface.io):
+                interface.emit_io_change()
+                self.IoChanged(
+                    interface.io.name,
+                    Variant(interface.variant_type, interface.io.value),
+                )
+
+    def GetAllInputs(self) -> list[str]:
+        return self.lst_inp_object_path
+
+    def GetAllOutputs(self) -> list[str]:
+        return self.lst_out_object_path
+
+    def GetByName(self, io_name) -> str:
+        if io_name in self._dc_io_interfaces:
+            return self._dc_io_interfaces[io_name].object_path
+
+        raise KeyError(f"No IO with name '{io_name}' found.")
+
+    def ActivateIoSignals(self) -> None:
+        if not self.modio._looprunning:
+            self.modio.autorefresh_all()
+            self.modio.cycleloop(self._modio_cycle, cycletime=50, blocking=False)
+
+    def DeactivateIoSignals(self) -> None:
+        self.modio.exit(False)

src/revpi_middleware/dbus_ios1/ios1_helper.py

@@ -0,0 +1,51 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""Helper for io read and write."""
+
+from logging import getLogger
+
+from revpimodio2.device import Device
+from revpimodio2.io import IOBase
+
+log = getLogger(__name__)
+
+REVPI_DBUS_NAME = "com.revolutionpi.ios1"
+REVPI_DBUS_BASE_PATH = "/com/revolutionpi/ios1"
+
+
+def get_io_object_path(io: IOBase) -> str:
+    return f"{REVPI_DBUS_BASE_PATH}/io/{io.name}"
+
+
+def get_device_object_path(device: Device) -> str:
+    return f"{REVPI_DBUS_BASE_PATH}/device/{device.position}"
+
+
+def get_variant_type(io: IOBase) -> str:
+    value_type = type(io.value)
+    byte_length = io.length
+    signed = io._signed
+
+    if value_type is bool:
+        return "b"
+
+    if value_type is float:
+        return "d"
+
+    if value_type is int:
+        if byte_length <= 2:
+            return "n" if signed else "q"
+        if byte_length <= 4:
+            return "i" if signed else "u"
+        if byte_length <= 8:
+            return "x" if signed else "t"
+        raise ValueError(f"Unsupported byte length: {byte_length}")
+
+    if value_type is str:
+        return "s"
+
+    if value_type is bytes:
+        return "ay"
+
+    raise TypeError(f"Unsupported type: {value_type}")

src/revpi_middleware/dbus_middleware1/__init__.py

@@ -2,7 +2,8 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """D-Bus middleware version 1 of revpi_middleware."""
+
 from .dbus_helper import REVPI_DBUS_BASE_PATH, REVPI_DBUS_NAME
 from .dbus_helper import extend_interface
 
-from .bus_provider import BusProvider
+from .bus_provider_middleware1 import BusProviderMiddleware1

src/revpi_middleware/dbus_middleware1/bus_provider_middleware1.py

@@ -2,37 +2,41 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """D-Bus bus provider for revpi_middleware."""
+
 from logging import getLogger
-from threading import Thread
+from threading import Thread, Event
 
 from gi.repository import GLib
-from pydbus import SessionBus, SystemBus
+from pydbus import connect
 
 from . import REVPI_DBUS_NAME
 from .process_image import InterfacePiControl
+from .system_config import InterfaceRevpiConfig, InterfaceSoftwareServices
 
 log = getLogger(__name__)
 
 
-class BusProvider(Thread):
+class BusProviderMiddleware1(Thread):
 
     def __init__(
         self,
+        dbus_address: str,
         picontrol_device="/dev/piControl0",
         config_rsc="/etc/revpi/config.rsc",
-        use_system_bus=True,
     ):
-        log.debug("enter BusProvider.__init__")
+        log.debug("enter BusProviderMiddleware1.__init__")
         super().__init__()
 
-        self._bus = SystemBus() if use_system_bus else SessionBus()
+        self._bus_address = dbus_address
         self._loop = GLib.MainLoop()
 
         self.picontrol_device = picontrol_device
+        self.published = Event()
         self.config_rsc = config_rsc
 
     def run(self):
-        log.debug("enter BusProvider.run")
+        log.debug("enter BusProviderMiddleware1.run")
+        bus = connect(self._bus_address)
 
         # The 2nd, 3rd, ... arguments can be objects or tuples of a path and an object
         #   Example(),
@@ -40,14 +44,18 @@ class BusProvider(Thread):
         #   ("Subdir2", Example()),
         #   ("Subdir2/Whatever", Example())
         lst_interfaces = [
-            InterfacePiControl(self.picontrol_device, self.config_rsc),
+            InterfacePiControl(bus, self.picontrol_device, self.config_rsc),
+            InterfaceRevpiConfig(bus),
+            InterfaceSoftwareServices(bus),
         ]
 
         try:
-            self._bus.publish(
+            bus.publish(
                 REVPI_DBUS_NAME,
                 *lst_interfaces,
             )
+            self.published.set()
+            log.info(f"published {REVPI_DBUS_NAME} on {self._bus_address}")
         except Exception as e:
             log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}")
 
@@ -56,18 +64,25 @@ class BusProvider(Thread):
         except Exception as e:
             log.error(f"can not run dbus mainloop: {e}")
 
+        bus.con.close()
+        log.info(f"closed {REVPI_DBUS_NAME} connection to {self._bus_address}")
+
         # Clean up all interfaces
         for interface in lst_interfaces:
             if type(interface) is tuple:
                 _, interface = interface
             interface.cleanup()
 
-        log.debug("leave BusProvider.run")
+        log.debug("leave BusProviderMiddleware1.run")
 
     def stop(self):
-        log.debug("enter BusProvider.stop")
+        log.debug("enter BusProviderMiddleware1.stop")
         self._loop.quit()
-        log.debug("leave BusProvider.stop")
+        log.debug("leave BusProviderMiddleware1.stop")
+
+    @property
+    def name(self) -> str:
+        return REVPI_DBUS_NAME
 
     @property
     def running(self):

src/revpi_middleware/dbus_middleware1/dbus_helper.py

@@ -5,6 +5,8 @@
 
 from logging import getLogger
 
+from pydbus.bus import Bus
+
 log = getLogger(__name__)
 
 REVPI_DBUS_NAME = "com.revolutionpi.middleware1"
@@ -13,6 +15,9 @@ REVPI_DBUS_BASE_PATH = "/com/revolutionpi/middleware1"
 
 class DbusInterface:
 
+    def __init__(self, bus: Bus):
+        self.bus = bus
+
     def cleanup(self):
         """
         Represents a method responsible for performing cleanup operations. This method is executed to properly
@@ -41,3 +46,38 @@ def extend_interface(*args) -> str:
             the provided segments.
     """
     return ".".join([REVPI_DBUS_NAME, *args])
+
+
+def grep(pattern, filename):
+    """
+    Searches for lines in a file that contain a given pattern and returns them as a list.
+
+    The function reads lines from the specified file and checks whether each line
+    contains the provided pattern. It returns a list of lines that match the
+    pattern. If the file is not found, an empty list is returned. Any other
+    exceptions during the file reading process are caught and logged.
+
+    Args:
+        pattern (str): The substring to search for within the file's lines.
+        filename (str): The path to the file that will be searched.
+
+    Returns:
+        list[str]: A list containing lines that include the provided pattern, with
+        leading and trailing spaces removed.
+
+    Raises:
+        FileNotFoundError: This error is caught if the file specified is not
+        found.
+        Exception: Any unforeseen exception during file operations is caught and
+        logged.
+    """
+    try:
+        with open(filename, "r") as file:
+            # Gibt alle Zeilen zurück, die das Muster enthalten
+            matching_lines = [line.strip() for line in file if pattern in line]
+            return matching_lines
+    except FileNotFoundError:
+        return []
+    except Exception as e:
+        log.error(f"Error reading file: {e}")
+        return []

src/revpi_middleware/dbus_middleware1/process_image/__init__.py

@@ -2,4 +2,5 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """D-Bus interfaces for piControl driver."""
+
 from .interface_picontrol import InterfacePiControl

src/revpi_middleware/dbus_middleware1/process_image/interface_picontrol.py

@@ -2,8 +2,10 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """D-Bus interfaces for piControl."""
+
 from logging import getLogger
 
+from pydbus.bus import Bus
 from pydbus.generic import signal
 
 from .process_image_helper import PiControlIoctl, ResetDriverWatchdog
@@ -15,7 +17,7 @@ log = getLogger(__name__)
 class InterfacePiControl(DbusInterface):
     """
     <node>
-        <interface name='com.revolutionpi.middleware1.picontrol'>
+        <interface name='com.revolutionpi.middleware1.PiControl'>
             <signal name="NotifyDriverReset">
             </signal>
             <method name='ResetDriver'>
@@ -26,7 +28,9 @@ class InterfacePiControl(DbusInterface):
 
     NotifyDriverReset = signal()
 
-    def __init__(self, picontrol_device: str, config_rsc: str):
+    def __init__(self, bus: Bus, picontrol_device: str, config_rsc: str):
+        super().__init__(bus)
+
         self.picontrol_device = picontrol_device
         self.config_rsc = config_rsc
 

src/revpi_middleware/dbus_middleware1/process_image/process_image_helper.py

@@ -7,6 +7,7 @@ Helper for the process image.
 The ResetDriverWatchdog class is a copy of revpipyload project module "watchdogs"
 https://github.com/naruxde/revpipyload/blob/b51c2b617a57cc7d96fd67e1da9f090a0624eacb/src/revpipyload/watchdogs.py
 """
+
 import os
 from ctypes import c_int
 from fcntl import ioctl

src/revpi_middleware/dbus_middleware1/system_config/__init__.py

@@ -0,0 +1,7 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus interfaces for system configuration."""
+
+from .interface_config import InterfaceRevpiConfig
+from .interface_services import InterfaceSoftwareServices

src/revpi_middleware/dbus_middleware1/system_config/interface_config.py

@@ -0,0 +1,104 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus interfaces for hardware configuration."""
+
+from collections import namedtuple
+from logging import getLogger
+
+from pydbus.generic import signal
+
+from .revpi_config import (
+    ConfigActions,
+    configure_bluetooth,
+    configure_con_can,
+    configure_dphys_swapfile,
+    configure_external_antenna,
+    configure_gui,
+    configure_wlan,
+)
+from ..dbus_helper import DbusInterface
+
+log = getLogger(__name__)
+
+FeatureFunction = namedtuple("FeatureFunction", ["function", "args"])
+
+
+class InterfaceRevpiConfig(DbusInterface):
+    """
+    <node>
+        <interface name="com.revolutionpi.middleware1.RevpiConfig">
+            <method name="Disable">
+                <arg name="feature" type="s" direction="in"/>
+            </method>
+            <method name="Enable">
+                <arg name="feature" type="s" direction="in"/>
+            </method>
+            <method name="GetStatus">
+                <arg name="feature" type="s" direction="in"/>
+                <arg name="status" type="b" direction="out"/>
+            </method>
+            <method name="GetAvailability">
+                <arg name="feature" type="s" direction="in"/>
+                <arg name="available" type="b" direction="out"/>
+            </method>
+            <property name="available_features" type="as" access="read"/>
+            <signal name="StatusChanged">
+                <arg name="feature" type="s"/>
+                <arg name="status" type="b"/>
+            </signal>
+            <signal name="AvailabilityChanged">
+                <arg name="feature" type="s"/>
+                <arg name="available" type="b"/>
+            </signal>
+        </interface>
+    </node>
+    """
+
+    AvailabilityChanged = signal()
+    StatusChanged = signal()
+
+    def Disable(self, feature: str) -> None:
+        """Disable the feature."""
+        feature_function = get_feature(feature)
+        feature_function.function(ConfigActions.DISABLE, *feature_function.args)
+        self.StatusChanged(feature, False)
+
+    def Enable(self, feature: str) -> None:
+        """Enable the feature."""
+        feature_function = get_feature(feature)
+        feature_function.function(ConfigActions.ENABLE, *feature_function.args)
+        self.StatusChanged(feature, True)
+
+    def GetStatus(self, feature: str) -> bool:
+        """Get feature status."""
+        feature_function = get_feature(feature)
+        return feature_function.function(ConfigActions.STATUS, *feature_function.args)
+
+    def GetAvailability(self, feature: str) -> bool:
+        """Get feature availability on the RevPi."""
+        feature_function = get_feature(feature)
+        return feature_function.function(ConfigActions.AVAILABLE, *feature_function.args)
+
+    @property
+    def available_features(self) -> list[str]:
+        return list(AVAILABLE_FEATURES.keys())
+
+
+def get_feature(feature: str) -> FeatureFunction:
+    if feature not in AVAILABLE_FEATURES:
+        raise ValueError(f"feature {feature} does not exist")
+    feature_function = AVAILABLE_FEATURES[feature]
+    if not feature_function:
+        raise NotImplementedError(f"feature {feature} is not implemented")
+    return feature_function
+
+
+AVAILABLE_FEATURES = {
+    "gui": FeatureFunction(configure_gui, []),
+    "revpi-con-can": FeatureFunction(configure_con_can, []),
+    "swapfile": FeatureFunction(configure_dphys_swapfile, []),
+    "bluetooth": FeatureFunction(configure_bluetooth, []),
+    "wlan": FeatureFunction(configure_wlan, []),
+    "external-antenna": FeatureFunction(configure_external_antenna, []),
+}

src/revpi_middleware/dbus_middleware1/system_config/interface_services.py

@@ -0,0 +1,207 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+"""D-Bus interfaces for software services."""
+
+from logging import getLogger
+from typing import List
+
+from pydbus.bus import Bus
+from pydbus.generic import signal
+
+from ..dbus_helper import DbusInterface
+from ..systemd_helper import simple_systemd, ServiceActions
+
+log = getLogger(__name__)
+
+
+class InterfaceSoftwareServices(DbusInterface):
+    """
+    <node>
+        <interface name="com.revolutionpi.middleware1.SoftwareServices">
+            <method name="Disable">
+                <arg name="feature" type="s" direction="in"/>
+            </method>
+            <method name="Enable">
+                <arg name="feature" type="s" direction="in"/>
+            </method>
+            <method name="GetStatus">
+                <arg name="feature" type="s" direction="in"/>
+                <arg name="status" type="b" direction="out"/>
+            </method>
+            <method name="GetAvailability">
+                <arg name="feature" type="s" direction="in"/>
+                <arg name="available" type="b" direction="out"/>
+            </method>
+            <property name="available_features" type="as" access="read"/>
+            <signal name="StatusChanged">
+                <arg name="feature" type="s"/>
+                <arg name="status" type="b"/>
+            </signal>
+            <signal name="AvailabilityChanged">
+                <arg name="feature" type="s"/>
+                <arg name="available" type="b"/>
+            </signal>
+        </interface>
+    </node>
+    """
+
+    AvailabilityChanged = signal()
+    StatusChanged = signal()
+
+    def __init__(self, bus: Bus):
+        super().__init__(bus)
+
+        self.mrk_available = {}
+        self.mrk_status = {}
+
+        self.services = {
+            "pimodbus-master": ["pimodbus-master.service"],
+            "pimodbus-slave": ["pimodbus-slave.service"],
+            "ntp": ["systemd-timesyncd.service"],
+            "ssh": ["ssh.service"],
+            "nodered": ["nodered.service"],
+            "noderedrevpinodes-server": ["noderedrevpinodes-server.service"],
+            "revpipyload": ["revpipyload.service"],
+            "avahi": ["avahi-daemon.service", "avahi-daemon.socket"],
+        }
+
+        # Create a systemd manager interface object
+        systemd = self.bus.get(
+            "org.freedesktop.systemd1",
+            "/org/freedesktop/systemd1",
+        )
+        systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
+
+        # Load all unit paths and subscribe to properties changed signal
+        self.object_paths = {}
+        for feature in self.services:
+
+            # Get the status and availability of the feature
+            self.mrk_available[feature] = self.GetAvailability(feature)
+            self.mrk_status[feature] = self.GetStatus(feature)
+
+            # Subscribe to properties changed signal for each unit
+            for unit_name in self.services[feature]:
+                unit_path = systemd_manager.LoadUnit(unit_name)
+                self.object_paths[unit_path] = feature
+
+                self.bus.subscribe(
+                    iface="org.freedesktop.DBus.Properties",
+                    signal="PropertiesChanged",
+                    object=unit_path,
+                    signal_fired=self._callback_properties_changed,
+                )
+
+        # Subscribe to the reloading signal to update the availability of the feature
+        self.bus.subscribe(
+            iface="org.freedesktop.systemd1.Manager",
+            signal="Reloading",
+            object="/org/freedesktop/systemd1",
+            signal_fired=self._callback_reloading_signal,
+        )
+
+    def _callback_reloading_signal(self, sender, object_path, interface, signal, parameters):
+        """
+        Handles the signal emitted for reloading and checks for changes in availability
+        and status for a set of services. If changes are identified, corresponding
+        update methods are triggered to reflect the new states.
+
+        Args:
+            sender: The entity sending the signal.
+            object_path: Path to the object emitting the signal.
+            interface: Interface through which the signal is sent.
+            signal: The signal being received.
+            parameters: A list of parameters associated with the signal.
+
+        Raises:
+            None
+        """
+        if parameters[0]:
+            return
+
+        for feature in self.services:
+            availability = self.GetAvailability(feature)
+            if self.mrk_available[feature] != availability:
+                self.mrk_available[feature] = availability
+                self.AvailabilityChanged(feature, availability)
+
+            status = self.GetStatus(feature)
+            if self.mrk_status[feature] != status:
+                self.mrk_status[feature] = status
+                self.StatusChanged(feature, status)
+
+    def _callback_properties_changed(self, sender, object_path, interface, signal, parameters):
+        """
+        Handles the 'PropertiesChanged' signal callback by updating internal status tracking for given
+        features and invoking status change notifications if necessary.
+
+        Args:
+            sender (Any): Information about the signal sender.
+            object_path (str): The path of the object emitting the signal.
+            interface (str): The interface where the signal was emitted.
+            signal (str): The name of the emitted signal.
+            parameters (tuple): Signal parameters containing interface name, changed properties, and
+                invalidated properties.
+
+        Raises:
+            TypeError: If the 'parameters' argument does not unpack to three expected values.
+        """
+        interface, changed_properties, invalidated_properties = parameters
+        if "ActiveState" not in changed_properties:
+            return
+
+        feature = self.object_paths[object_path]
+        status = self.GetStatus(feature)
+        if self.mrk_status[feature] != status:
+            self.mrk_status[feature] = status
+            self.StatusChanged(feature, status)
+
+    def _get_unit_names(self, feature: str) -> List[str]:
+        if feature not in self.services:
+            raise ValueError(f"feature {feature} does not exist")
+        return self.services[feature]
+
+    def Disable(self, feature: str) -> None:
+        """Disable the feature."""
+        action = ServiceActions.DISABLE
+        unit_names = self._get_unit_names(feature)
+
+        for unit_name in unit_names:
+            simple_systemd(action, unit_name)
+
+    def Enable(self, feature: str) -> None:
+        """Enable the feature."""
+        action = ServiceActions.ENABLE
+        unit_names = self._get_unit_names(feature)
+
+        for unit_name in unit_names:
+            simple_systemd(action, unit_name)
+
+    def GetStatus(self, feature: str) -> bool:
+        """Get feature status."""
+        unit_names = self._get_unit_names(feature)
+        rc_status = True
+
+        for unit_name in unit_names:
+            if not simple_systemd(ServiceActions.STATUS, unit_name):
+                rc_status = False
+                break
+
+        return rc_status
+
+    def GetAvailability(self, feature: str) -> bool:
+        """Get feature availability on the RevPi."""
+        unit_names = self._get_unit_names(feature)
+        rc_available = True
+
+        for unit_name in unit_names:
+            if not simple_systemd(ServiceActions.AVAILABLE, unit_name):
+                rc_available = False
+                break
+
+        return rc_available
+
+    @property
+    def available_features(self) -> list[str]:
+        return list(self.services.keys())

src/revpi_middleware/dbus_middleware1/system_config/revpi_config.py

@@ -0,0 +1,650 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+import re
+import shutil
+import subprocess
+from collections import namedtuple
+from enum import Enum, IntEnum
+from glob import glob
+from logging import getLogger
+from os import X_OK, access
+from os.path import exists, join
+from typing import List, Optional
+
+from pydbus import SystemBus
+
+from ..dbus_helper import grep
+from ..systemd_helper import simple_systemd, ServiceActions
+
+log = getLogger(__name__)
+
+ConfigVariable = namedtuple("ConfigVariable", ["name", "value", "line_index"])
+
+LINUX_BT_CLASS_PATH = "/sys/class/bluetooth"
+LINUX_WLAN_CLASS_PATH = "/sys/class/ieee80211"
+CONFIG_TXT_LOCATIONS = ("/boot/firmware/config.txt", "/boot/config.txt")
+
+
+class ComputeModuleTypes(IntEnum):
+    """
+    Enumeration class to represent compute module types.
+
+    This class is an enumeration that defines various types of compute
+    modules and assigns them associated integer values for identifying
+    different module types.
+
+    Attributes:
+        UNKNOWN (int): Represents an unknown or undefined compute module type.
+        CM1 (int): Represents a Compute Module 1.
+        CM3 (int): Represents a Compute Module 3.
+        CM4 (int): Represents a Compute Module 4.
+        CM4S (int): Represents a Compute Module 4S.
+        CM5 (int): Represents a Compute Module 5.
+    """
+
+    UNKNOWN = 0
+    CM1 = 6
+    CM3 = 10
+    CM4 = 20
+    CM4S = 21
+    CM5 = 24
+
+
+class ConfigActions(Enum):
+    """
+    Enumeration class for defining configuration actions.
+
+    This enumeration provides predefined constants for common configuration
+    actions. It can be used to ensure consistency when working with or defining
+    such actions in a system.
+    """
+
+    ENABLE = "enable"
+    DISABLE = "disable"
+    STATUS = "status"
+    AVAILABLE = "available"
+
+
+class RevPiConfig:
+    """
+    Represents the configuration and hardware details of a Revolution Pi system.
+
+    This class provides methods and properties to initialize and fetch
+    information related to the Revolution Pi device, such as model, serial
+    number, compute module type, WLAN capability, and the presence of a
+    connection bridge. The class works by parsing system-level files (e.g.,
+    `/proc/cpuinfo`) and using this data to identify hardware characteristics
+    and features.
+
+    Attributes:
+        serial (str): The serial number of the Revolution Pi device.
+        model (str): The model name of the Revolution Pi device.
+    """
+
+    def __init__(self):
+        self._cm_type = ComputeModuleTypes.UNKNOWN
+
+        self._revpi_with_con_bridge = False
+        self._wlan_class_path = ""
+
+        self.serial = ""
+        self.model = ""
+
+        self._init_device_info()
+
+    def _init_device_info(self):
+        """
+        Initialize and retrieve detailed hardware information, including CPU details,
+        device type, WLAN interface, and connectivity features.
+
+        This method gathers information from system files and other sources to
+        initialize device-specific attributes such as model, serial number,
+        compute module type, and optional features like integrated WLAN
+        or ConBridge support. It performs checks specific to the detected
+        module type to accurately populate necessary device details.
+
+        Attributes
+        ----------
+        model : str
+            The model of the CPU based on information from /proc/cpuinfo.
+        serial : str
+            The serial number extracted from /proc/cpuinfo.
+        _cm_type : ComputeModuleTypes, optional
+            The type of the compute module derived from the hardware revision value.
+        _wlan_class_path : str, optional
+            Filesystem path to the detected WLAN interface, if any.
+        _revpi_with_con_bridge : bool
+            Indicates whether the device supports the ConBridge feature.
+        """
+        dc_cpuinfo = {}
+
+        # Extract CPU information
+        with open("/proc/cpuinfo", "r") as f:
+            line = "\n"
+            while line:
+                line = f.readline()
+                if line.startswith(("Revision", "Serial", "Model")):
+                    key, value = line.split(":", 1)
+                    key = key.strip().lower()
+                    value = value.strip()
+                    dc_cpuinfo[key] = value
+
+        self.model = dc_cpuinfo.get("model", "")
+        self.serial = dc_cpuinfo.get("serial", "")
+
+        # Detect Compute Module type
+        revision = dc_cpuinfo.get("revision", "")
+        if revision:
+            revision = int(revision, 16)
+            mask = 4080  # 0xFF0 in dezimal
+            try:
+                self._cm_type = ComputeModuleTypes((revision & mask) >> 4)
+            except ValueError:
+                pass
+
+        # Detect WLAN on CM module
+        could_have_wlan = self._cm_type in (ComputeModuleTypes.CM4, ComputeModuleTypes.CM5)
+        if could_have_wlan:
+            wlan_interface = join(LINUX_WLAN_CLASS_PATH, "phy0")
+            if grep("DRIVER=brcmfmac", join(wlan_interface, "device", "uevent")):
+                self._wlan_class_path = wlan_interface
+
+        # If no build in WLAN on the CM, detect third party WLAN on RevPi Flat
+        if not self._wlan_class_path and grep("revpi-flat", "/proc/device-tree/compatible"):
+            lst_wlan_interfaces = glob("/sys/class/ieee80211/*")
+            for wlan_interface in lst_wlan_interfaces:
+                if grep("DRIVER=mwifiex_sdio", join(wlan_interface, "device", "uevent")):
+                    self._wlan_class_path = wlan_interface
+
+        # Detect ConBridge
+        could_have_con_bridge = self._cm_type in (ComputeModuleTypes.CM3, ComputeModuleTypes.CM4S)
+        if could_have_con_bridge:
+            lst_grep = grep("kunbus,revpi-connect", "/proc/device-tree/compatible")
+            self._revpi_with_con_bridge = len(lst_grep) > 0
+
+    @property
+    def class_path_wlan(self) -> str:
+        """
+        Provides access to the WLAN class path.
+
+        This property retrieves the stored WLAN class path, allowing the user to access it when
+        needed.
+
+        Returns:
+            str: The WLAN class path.
+        """
+        return self._wlan_class_path
+
+    @property
+    def cm_type(self) -> ComputeModuleTypes:
+        """
+        Gets the type of the compute module.
+
+        The property provides access to the type of the compute
+        module used. The type is represented as an instance of
+        the `ComputeModuleTypes` class.
+
+        Returns
+        -------
+        ComputeModuleTypes
+            The type of the compute module.
+        """
+        return self._cm_type
+
+    @property
+    def with_con_bridge(self) -> bool:
+        """
+        Indicates if the device is configured with a connection bridge.
+
+        This property checks the internal status and determines whether the device setup
+        includes a connection bridge functionality. It is read-only.
+
+        Returns:
+            bool: True if the connection bridge is configured, False otherwise.
+        """
+        return self._revpi_with_con_bridge
+
+    @property
+    def with_wlan(self) -> bool:
+        """
+        Checks if WLAN is available.
+
+        This property evaluates whether WLAN is enabled or available by checking
+        the presence or value of the internal attribute `_wlan_class_path`.
+
+        Returns:
+            bool: True if WLAN is available, False otherwise.
+        """
+        return bool(self._wlan_class_path)
+
+
+class ConfigTxt:
+    """
+    Configuration file handler for managing 'config.txt'.
+
+    This class provides an interface to read, modify, save, and reload
+    Raspbian's configuration file `config.txt`. It includes functionalities
+    to manipulate specific parameters within the configuration and supports
+    managing dtoverlay and dtparam entries. The primary aim of this class
+    is to abstract file operations and make modifications user-friendly.
+
+    Attributes:
+        _config_txt_path (str): The path to the configuration file `config.txt`.
+        _config_txt_lines (list[str]): Contains all lines of the configuration
+            file as a list of strings, where each string represents a line.
+    """
+
+    re_name_value = re.compile(r"^\s*(?!#)(?P<name>[^=\s].+?)\s*=\s*(?P<value>\S+)\s*$")
+
+    def __init__(self):
+        self._config_txt_path = ""
+        for path in CONFIG_TXT_LOCATIONS:
+            if exists(path):
+                self._config_txt_path = path
+                break
+
+        if not self._config_txt_path:
+            raise FileNotFoundError("no config.txt found")
+
+        self._config_txt_lines = []
+
+    def _clear_name_values(self, name: str, values: str or list) -> int:
+        """
+        Removes all occurrences of specified name-value pairs from the configuration.
+
+        This method searches for all name-value pairs in the configuration and
+        removes those that match the given name and value(s). It returns the
+        number of occurrences removed.
+
+        Arguments:
+            name: str
+                The name of the configuration variable to search for.
+            values: str or list
+                The value or list of values to match the configuration variable
+                against.
+
+        Returns:
+            int: The number of name-value pairs removed from the configuration.
+
+        """
+        counter = 0
+        if type(values) is str:
+            values = [values]
+
+        for config_var in self._get_all_name_values():
+            if config_var.name == name and config_var.value in values:
+                self._config_txt_lines.pop(config_var.line_index)
+                counter += 1
+
+        return counter
+
+    def _get_all_name_values(self) -> List[ConfigVariable]:
+        """
+        Retrieves all name-value pairs from the configuration text lines.
+
+        This method parses the configuration text lines to extract all name-value
+        pairs. If the configuration text lines are not loaded, it reloads the
+        configuration before processing. Each extracted name-value pair is added to a
+        list as a ConfigVariable object, which also holds the index of the match in
+        the text lines. The method returns the compiled list of these ConfigVariable
+        objects.
+
+        Returns:
+            List[ConfigVariable]: A list of ConfigVariable objects representing the
+            name-value pairs found in the configuration text lines, along with their
+            corresponding indexes.
+        """
+        if not self._config_txt_lines:
+            self.reload_config()
+
+        lst_return = []
+
+        for i in range(len(self._config_txt_lines)):
+            match = self.re_name_value.match(self._config_txt_lines[i])
+            if match:
+                lst_return.append(ConfigVariable(match.group("name"), match.group("value"), i))
+
+        return lst_return
+
+    def reload_config(self):
+        """
+        Reloads the configuration file and updates the list of configuration lines.
+
+        This method reads the content of the configuration file specified by the
+        attribute `_config_txt_path` and updates `_config_txt_lines` with the file
+        contents as a list of strings, where each string represents a line.
+
+        Returns:
+            None
+        """
+        with open(self._config_txt_path, "r") as f:
+            self._config_txt_lines = f.readlines()
+
+    def save_config(self):
+        """
+        Saves the current configuration to a file. The method ensures atomicity by first writing
+        to a temporary file and then moving it to the desired path. After the configuration is
+        saved, the internal list of configuration lines is cleared.
+
+        Raises:
+            OSError: If there is an issue writing to or moving the file.
+        """
+        if not self._config_txt_lines:
+            return
+
+        tmp_path = f"{self._config_txt_path}.tmp"
+        with open(tmp_path, "w") as f:
+            f.writelines(self._config_txt_lines)
+        shutil.move(tmp_path, self._config_txt_path)
+
+        self._config_txt_lines.clear()
+
+    def add_name_value(self, name: str, value: str):
+        """
+        Adds a name-value pair to the configuration if it does not already exist.
+
+        This method checks if the given name-value pair is already present in
+        the configuration. If it is not present, the pair is appended to the
+        configuration text lines.
+
+        Parameters:
+            name (str): The name to be added to the configuration.
+            value (str): The value corresponding to the name to be added.
+
+        Returns:
+            None
+        """
+        # Check weather name and value already exists
+        for config_var in self._get_all_name_values():
+            if config_var.name == name and config_var.value == value:
+                return
+
+        self._config_txt_lines.append(f"{name}={value}\n")
+
+    def clear_dtoverlays(self, dtoverlays: str or list) -> int:
+        """
+        Clears the specified device tree overlays. This method removes one or more
+        device tree overlays by clearing their corresponding name-value pairs.
+
+        Args:
+            dtoverlays (str or list): A device tree overlay name as a string, or a
+            list of such overlay names to be cleared.
+
+        Returns:
+            int: The number of device tree overlay name-value pairs successfully
+            cleared.
+        """
+        return self._clear_name_values("dtoverlay", dtoverlays)
+
+    def clear_dtparams(self, dtparams: str or list) -> int:
+        """
+        Clears the specified device tree parameters.
+
+        This method removes the given device tree parameters by utilizing
+        the underlying `_clear_name_values` function with a predefined
+        parameter type.
+
+        Parameters:
+        dtparams: str or list
+            A string or list of strings specifying the device tree
+            parameters to remove.
+
+        Returns:
+        int
+            The number of parameters cleared.
+        """
+        return self._clear_name_values("dtparam", dtparams)
+
+    def get_values(self, var_name: str) -> list:
+        """
+        Get all values associated with a given variable name.
+
+        This method retrieves a list of values corresponding to the specified
+        variable name by iterating through a collection of configuration
+        variables. Each configuration variable is checked for a matching name,
+        and its value is appended to the resulting list if a match is found.
+
+        Parameters:
+        var_name (str): The name of the variable for which values are to
+                        be retrieved.
+
+        Returns:
+        list: A list of values associated with the specified variable name.
+        """
+        var_values = []
+
+        for config_var in self._get_all_name_values():
+            if config_var.name == var_name:
+                var_values.append(config_var.value)
+
+        return var_values
+
+    @property
+    def config_txt_path(self) -> str:
+        """
+        Get the file path for the configuration text file.
+
+        This property provides access to the private attribute `_config_txt_path` which
+        stores the file path to the configuration text file.
+
+        Returns:
+        str
+            The file path to the configuration text file.
+        """
+        return self._config_txt_path
+
+
+def configure_bluetooth(action: ConfigActions):
+    hci_device = join(LINUX_BT_CLASS_PATH, "hci0")
+    bt_rfkill_index = get_rfkill_index(hci_device)
+
+    # If the bluetooth device is not present, the device should have been
+    # brought up by revpi-bluetooth's udev rules or vendor magic (devices
+    # based on CM4 and newer). Nothing we can do here, so treat the interface
+    # as disabled.
+
+    if action is ConfigActions.ENABLE:
+        if bt_rfkill_index is not None:
+            with open(f"/sys/class/rfkill/rfkill{bt_rfkill_index}/soft", "w") as f:
+                f.write("0")
+
+    elif action is ConfigActions.DISABLE:
+        if bt_rfkill_index is not None:
+            with open(f"/sys/class/rfkill/rfkill{bt_rfkill_index}/soft", "w") as f:
+                f.write("1")
+
+    elif action is ConfigActions.STATUS:
+        if bt_rfkill_index is None:
+            return False
+
+        with open(f"/sys/class/rfkill/rfkill{bt_rfkill_index}/soft", "r") as f:
+            buffer = f.read().strip()
+            return buffer == "0"
+
+    elif action is ConfigActions.AVAILABLE:
+        return bt_rfkill_index is not None
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+    return None
+
+
+def configure_con_can(action: ConfigActions):
+    revpi = RevPiConfig()
+    if action is ConfigActions.AVAILABLE:
+        return revpi.with_con_bridge
+
+    dt_overlay = "revpi-con-can"
+    config_txt = ConfigTxt()
+
+    if action is ConfigActions.ENABLE and revpi.with_con_bridge:
+        config_txt.clear_dtoverlays([dt_overlay])
+        config_txt.add_name_value("dtoverlay", dt_overlay)
+        config_txt.save_config()
+        subprocess.call(["/usr/bin/dtoverlay", dt_overlay])
+
+    elif action is ConfigActions.DISABLE and revpi.with_con_bridge:
+        config_txt.clear_dtoverlays([dt_overlay])
+        config_txt.save_config()
+        subprocess.call(["/usr/bin/dtoverlay", "-r", dt_overlay])
+
+    elif action is ConfigActions.STATUS:
+        return revpi.with_con_bridge and dt_overlay in config_txt.get_values("dtparam")
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+    return None
+
+
+def configure_dphys_swapfile(action: ConfigActions):
+    # Translate config action to systemd action
+    if action is ConfigActions.ENABLE:
+        systemd_action = ServiceActions.ENABLE
+    elif action is ConfigActions.DISABLE:
+        systemd_action = ServiceActions.DISABLE
+    elif action is ConfigActions.STATUS:
+        systemd_action = ServiceActions.STATUS
+    else:
+        systemd_action = ServiceActions.AVAILABLE
+
+    return_value = simple_systemd(systemd_action, "dphys-swapfile.service")
+
+    # Post actions for dphys-swapfile
+    if action is ConfigActions.DISABLE:
+        # Remove swapfile afer disabling the service unit
+        subprocess.call(
+            ["/sbin/dphys-swapfile", "uninstall"],
+            stdout=subprocess.DEVNULL,
+            stderr=subprocess.DEVNULL,
+        )
+
+    return return_value
+
+
+def configure_external_antenna(action: ConfigActions):
+    revpi = RevPiConfig()
+    if action is ConfigActions.AVAILABLE:
+        return revpi.with_wlan
+
+    config_txt = ConfigTxt()
+
+    if action is ConfigActions.ENABLE and revpi.with_wlan:
+        config_txt.clear_dtparams(["ant1", "ant2"])
+        config_txt.add_name_value("dtparam", "ant2")
+        config_txt.save_config()
+
+    elif action is ConfigActions.DISABLE and revpi.with_wlan:
+        config_txt.clear_dtparams(["ant1", "ant2"])
+        config_txt.save_config()
+
+    elif action is ConfigActions.STATUS:
+        return revpi.with_wlan and "ant2" in config_txt.get_values("dtparam")
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+    return None
+
+
+def configure_gui(action: ConfigActions):
+    gui_available = access("/usr/bin/startx", X_OK)
+
+    if action is ConfigActions.AVAILABLE:
+        return gui_available
+
+    bus = SystemBus()
+    systemd = bus.get(
+        "org.freedesktop.systemd1",
+        "/org/freedesktop/systemd1",
+    )
+    systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
+
+    if action is ConfigActions.ENABLE:
+        systemd_manager.SetDefaultTarget("graphical.target", True)
+
+    elif action is ConfigActions.DISABLE:
+        systemd_manager.SetDefaultTarget("multi-user.target", True)
+
+    elif action is ConfigActions.STATUS:
+        return systemd_manager.GetDefaultTarget() == "graphical.target"
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+
+def configure_wlan(action: ConfigActions):
+    revpi = RevPiConfig()
+
+    if action is ConfigActions.ENABLE:
+        if revpi.with_wlan:
+            wlan_rfkill_index = get_rfkill_index(revpi.class_path_wlan)
+            with open(f"/sys/class/rfkill/rfkill{wlan_rfkill_index}/soft", "w") as f:
+                f.write("0")
+
+    elif action is ConfigActions.DISABLE:
+        if revpi.with_wlan:
+            wlan_rfkill_index = get_rfkill_index(revpi.class_path_wlan)
+            with open(f"/sys/class/rfkill/rfkill{wlan_rfkill_index}/soft", "w") as f:
+                f.write("1")
+
+    elif action is ConfigActions.AVAILABLE:
+        return revpi.with_wlan
+
+    elif action is ConfigActions.STATUS:
+        if not revpi.with_wlan:
+            return False
+
+        wlan_rfkill_index = get_rfkill_index(revpi.class_path_wlan)
+        with open(f"/sys/class/rfkill/rfkill{wlan_rfkill_index}/soft", "r") as f:
+            buffer = f.read().strip()
+            return buffer == "0"
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+    return None
+
+
+def get_rfkill_index(device_class_path: str) -> Optional[int]:
+    """
+    Get the rfkill index for a device under a specific device class path.
+
+    This function searches for and extracts the rfkill index associated with
+    devices located under the given device class path. It uses a regular
+    expression to identify and parse the rfkill index from the paths
+    of matching rfkill device files.
+
+    Parameters:
+        device_class_path: str
+            The path to the device class directory where rfkill entries
+            are located.
+
+    Returns:
+        Optional[int]:
+            The index of the rfkill device if found, otherwise None.
+    """
+    re_rfkill_index = re.compile(r"^/.+/rfkill(?P<index>\d+)$")
+    for rfkill_path in glob(join(device_class_path, "rfkill*")):
+        match_index = re_rfkill_index.match(rfkill_path)
+        if match_index:
+            return int(match_index.group("index"))
+
+    return None
+
+
+if __name__ == "__main__":
+    rc = RevPiConfig()
+    print("Model:", rc.model)
+    print("Serial:         ", rc.serial)
+    print("CM Type:        ", rc.cm_type.name)
+    print("With WLAN:      ", rc.with_wlan)
+    if rc.with_wlan:
+        print("    class path: ", rc.class_path_wlan)
+        print("  rfkill index: ", get_rfkill_index(rc.class_path_wlan))
+    print("With con-bridge:", rc.with_con_bridge)
+
+    config_txt = ConfigTxt()
+    print("Config file:    ", config_txt.config_txt_path)

src/revpi_middleware/dbus_middleware1/systemd_helper.py

@@ -0,0 +1,121 @@
+# -*- coding: utf-8 -*-
+# SPDX-FileCopyrightText: 2025 KUNBUS GmbH
+# SPDX-License-Identifier: GPL-2.0-or-later
+from enum import Enum
+from logging import getLogger
+from threading import Thread
+from typing import Optional
+
+from pydbus import SystemBus
+
+log = getLogger(__name__)
+
+
+class ServiceActions(Enum):
+    """
+    Enumeration class for defining configuration actions.
+
+    This enumeration provides predefined constants for common configuration
+    actions. It can be used to ensure consistency when working with or defining
+    such actions in a system.
+    """
+
+    ENABLE = "enable"
+    DISABLE = "disable"
+    STATUS = "status"
+    AVAILABLE = "available"
+
+
+def simple_systemd(action: ServiceActions, unit: str, unmask: bool = False) -> Optional[bool]:
+    """
+    Perform systemd service actions such as enable, disable, check status, or availability.
+
+    This function interacts with the systemd D-Bus API to manage and query the
+    state of services on a system. The supported actions include enabling a systemd
+    unit, disabling it, starting/stopping a unit, and checking its status or
+    availability. The function supports asynchronous configuration changes through
+    threads where applicable.
+
+    Parameters:
+        action (ServiceActions): The action to perform on the systemd service.
+            Supported actions are ENABLE, DISABLE, STATUS, and AVAILABLE.
+        unit (str): The name of the systemd unit to operate on (e.g., "example.service").
+        unmask (bool): When enabling a unit, if True, any masked unit file will
+            first be unmasked before proceeding with the operation. Defaults to False.
+
+    Returns:
+        Optional[bool]: The return value depends on the action. For STATUS or
+            AVAILABLE actions, it returns True if the unit satisfies the condition
+            (e.g., enabled and active, or available and loaded), False otherwise.
+            For other actions, it returns None.
+    """
+    bus = SystemBus()
+    systemd = bus.get(
+        "org.freedesktop.systemd1",
+        "/org/freedesktop/systemd1",
+    )
+    systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
+
+    if action is ServiceActions.ENABLE:
+
+        def thread_unit_config():
+            """Change configuration asynchronously."""
+            lst_change_unmask = []
+            if unmask:
+                # Dbus call: UnmaskUnitFiles(in as files, in b runtime, out a(sss) changes
+                lst_change_unmask = systemd_manager.UnmaskUnitFiles([unit], False)
+
+            # Dbus call: EnableUnitFiles(in as files, in b runtime, in b force,
+            #                            out b carries_install_info, out a(sss) changes
+            lst_change_enable = systemd_manager.EnableUnitFiles([unit], False, False)
+            if lst_change_unmask or lst_change_enable:
+                # Reload systemd after modified unit property
+                systemd_manager.Reload()
+
+        Thread(target=thread_unit_config, daemon=True).start()
+
+        # Dbus call: StartUnit(in s name, in s mode, out o job
+        systemd_manager.StartUnit(unit, "replace")
+
+    elif action is ServiceActions.DISABLE:
+
+        def thread_unit_config():
+            """Change configuration asynchronously."""
+            # Dbus call: DisableUnitFiles (in as files, in b runtime, out a(sss) changes)
+            change = systemd_manager.DisableUnitFiles([unit], False)
+            if change:
+                # Reload systemd after modified unit property
+                systemd_manager.Reload()
+
+        Thread(target=thread_unit_config, daemon=True).start()
+
+        # Dbus call: StopUnit(in s name,in s mode, out o job
+        systemd_manager.StopUnit(unit, "replace")
+
+    elif action is ServiceActions.STATUS:
+        try:
+            unit_path = systemd_manager.LoadUnit(unit)
+            properties = bus.get("org.freedesktop.systemd1", unit_path)
+        except Exception:
+            log.warning(f"could not get systemd unit {unit}")
+            return False
+
+        return properties.UnitFileState == "enabled" and properties.ActiveState in (
+            "active",
+            "activating",
+        )
+
+    elif action is ServiceActions.AVAILABLE:
+        try:
+            unit_path = systemd_manager.LoadUnit(unit)
+            properties = bus.get("org.freedesktop.systemd1", unit_path)
+        except Exception:
+            log.warning(f"could not get systemd unit {unit}")
+            return False
+
+        return properties.LoadState != "not-found"
+
+    else:
+        raise ValueError(f"action {action} not supported")
+
+    return None

src/revpi_middleware/main_application.py

@@ -2,9 +2,10 @@
 # SPDX-FileCopyrightText: 2025 KUNBUS GmbH
 # SPDX-License-Identifier: GPL-2.0-or-later
 """Main application of revpi-middleware daemon."""
+
 from logging import getLogger
 
-from .daemon import MiddlewareDaemon
+from .daemon import MiddlewareDaemon, BusProvider
 from . import proginit as pi
 
 log = getLogger(__name__)
@@ -26,6 +27,19 @@ pi.parser.add_argument(
     default="/etc/{0}/{0}.conf".format(pi.programname),
     help="application configuration file",
 )
+pi.parser.add_argument(
+    "--procimg",
+    dest="procimg",
+    default="/dev/piControl0",
+    help="Path to process image",
+)
+pi.parser.add_argument(
+    "bus_provider",
+    default="middleware",
+    nargs="?",
+    choices=["middleware", "ios"],
+    help="bus provider to use",
+)
 
 
 def main() -> int:
@@ -34,7 +48,7 @@ def main() -> int:
     # Parse command line arguments
     pi.init_app()
 
-    root = MiddlewareDaemon()
+    root = MiddlewareDaemon(BusProvider(pi.pargs.bus_provider))
 
     # Set signals
     signal.signal(signal.SIGHUP, lambda n, f: root.reload_config())

src/revpi_middleware/proginit.py

@@ -2,6 +2,7 @@
 # SPDX-FileCopyrightText: 2018-2023 Sven Sager
 # SPDX-License-Identifier: LGPL-2.0-or-later
 """Global program initialization."""
+
 __author__ = "Sven Sager"
 __copyright__ = "Copyright (C) 2018-2023 Sven Sager"
 __license__ = "LGPL-2.0-or-later"

tests/dbus_middleware1/bus_provider.py

@@ -3,6 +3,8 @@
 # SPDX-License-Identifier: GPL-2.0-or-later
 from time import sleep
 
+from gi.repository.Gio import dbus_address_get_for_bus_sync, BusType
+
 from tests.dbus_middleware1.fake_devices import PiControlDeviceMockup
 
 
@@ -12,12 +14,13 @@ class TestBusProvider(PiControlDeviceMockup):
         super().setUp()
 
         # Do not import things on top of the module. Some classes or functions need to be mocked up first.
-        from revpi_middleware.dbus_middleware1 import BusProvider
+        from revpi_middleware.dbus_middleware1 import BusProviderMiddleware1
 
         # Prepare the bus provider and start it
-        self.bp = BusProvider(
+        bus_address = dbus_address_get_for_bus_sync(BusType.SESSION)
-            self.picontrol.name,
+        self.bp = BusProviderMiddleware1(
-            use_system_bus=False,
+            bus_address,
+            picontrol_device=self.picontrol.name,
         )
         self.bp.start()
 

tests/dbus_middleware1/process_image/test_interface_picontrol.py

@@ -18,7 +18,7 @@ class TestObjectPicontrol(TestBusProvider):
     def test_reset_driver(self):
         simple_call(
             "ResetDriver",
-            interface=extend_interface("picontrol"),
+            interface=extend_interface("PiControl"),
             bus_type=BusType.SESSION,
         )
         ioctl_call = IOCTL_QUEUE.get(timeout=2.0)
@@ -37,7 +37,7 @@ class TestObjectPicontrol(TestBusProvider):
         result = await_signal(
             "NotifyDriverReset",
             timeout,
-            extend_interface("picontrol"),
+            extend_interface("PiControl"),
             bus_type=BusType.SESSION,
         )
         self.assertTrue(result)