Compare commits
62 Commits
debian/boo
...
f3ffdd8eaa
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f3ffdd8eaa | ||
|
|
f4eff16ab6 | ||
|
|
d95a65c18c | ||
|
|
2b22c103c8 | ||
|
|
794089a5b5 | ||
|
|
5dfd8b9f2f | ||
|
|
4ea8d6bc9a | ||
|
|
fdaf7b3ac6 | ||
|
|
3dbad93975 | ||
|
|
cf90b2dd55 | ||
|
|
4bd8fa74a9 | ||
|
|
bf5bef114c | ||
|
|
2c08829a13 | ||
|
|
ce1a25ac0e | ||
|
|
f387b0a836 | ||
|
|
10ad65a62c | ||
|
|
0e69ef432b | ||
|
|
35dbed0798 | ||
|
|
1842bbd2f5 | ||
|
|
3d64cd5837 | ||
|
|
5528f6dff4 | ||
|
|
6372ed4e7f | ||
|
|
710d7b2078 | ||
|
|
8ee5e0836f | ||
|
|
6f1bd7f7ea | ||
|
|
785569c86b | ||
|
|
415e8502f7 | ||
|
|
b16331cf84 | ||
|
|
a2d1531e77 | ||
|
|
bbbbd3e0e1 | ||
|
|
a43fc764c6 | ||
|
|
0716169a03 | ||
|
|
77a3fbb16c | ||
|
|
037e9c05ac | ||
|
|
66c8c9851b | ||
|
|
afdae78336 | ||
|
|
4dd4c814b5 | ||
|
|
b8b99ed3b0 | ||
|
|
b68f1ffb36 | ||
|
|
ffd04a0410 | ||
|
|
549cddf594 | ||
|
|
f56db7ab1c | ||
|
|
208b391aa9 | ||
|
|
917ab7ab1f | ||
|
|
b4f817b477 | ||
|
|
66046b6a9d | ||
|
|
9ec1e04d2b | ||
|
|
1cb1062138 | ||
|
|
8d01eee66d | ||
|
|
40059d6068 | ||
|
|
50789853e9 | ||
|
|
d2e2f1c7f3 | ||
|
|
32574e0815 | ||
|
|
a29979ad78 | ||
|
|
431f9308de | ||
|
|
dc2d1ab3a0 | ||
|
|
983c6cefea | ||
|
|
a977884e17 | ||
|
|
20fb85a3f0 | ||
|
|
f4efb1daae | ||
|
|
fb181f8810 | ||
|
|
3dee7784e2 |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -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]
|
||||
|
||||
40
.gitlab-ci.yml
Normal file
40
.gitlab-ci.yml
Normal file
@@ -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
|
||||
@@ -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 *
|
||||
|
||||
4
Makefile
4
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
|
||||
|
||||
11
README.md
11
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.
|
||||
|
||||
19
data/dbus-policy/com.revolutionpi.ios1.conf
Normal file
19
data/dbus-policy/com.revolutionpi.ios1.conf
Normal file
@@ -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>
|
||||
65
data/examples/io_controller.py
Normal file
65
data/examples/io_controller.py
Normal file
@@ -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()
|
||||
96
debian/changelog
vendored
96
debian/changelog
vendored
@@ -1,96 +0,0 @@
|
||||
revpi-middleware (0.0.5-1+deb12+1) bookworm; urgency=medium
|
||||
|
||||
* fix(revpiconfig): Ensure systemd reloads after unit changes
|
||||
* feat(revpiconfig): Make unit config changes asynchronous
|
||||
* Update changelog for 0.0.4-1+deb12+1 release
|
||||
|
||||
-- Sven Sager <s.sager@kunbus.com> Tue, 22 Apr 2025 13:44:45 +0200
|
||||
|
||||
revpi-middleware (0.0.4-1+deb12+1) bookworm; urgency=medium
|
||||
|
||||
* fix(dbus): Update DBus policy file path and interface name
|
||||
* fix(dbus): Update systemd interface and path handling
|
||||
* doc(revpiconfig): Add detailed docstrings to ConfigTxt methods
|
||||
* doc(revpiconfig): Add docstrings to `RevPiConfig` class and methods
|
||||
* doc(revpiconfig): Add docstrings to enums in `revpi_config.py`
|
||||
* doc(revpiconfig): Docstrings for `get_rfkill_index` and `simple_systemd`
|
||||
|
||||
-- Sven Sager <s.sager@kunbus.com> Tue, 22 Apr 2025 13:43:53 +0200
|
||||
|
||||
revpi-middleware (0.0.3-1+deb12+1) bookworm; urgency=medium
|
||||
|
||||
* refactor: Update interface name from 'picontrol' to 'PiControl'
|
||||
* feat(dbus): Add `grep` function to search for patterns in a file
|
||||
* fix(cli): Change absolute imports to relative imports
|
||||
* feat(dbus): Add D-Bus interface for system configuration in middleware
|
||||
* feat(dbus): Add GUI configuration handling to interface_config.py
|
||||
* feat(revpiconfig): Add RevPiConfig class for device information handling
|
||||
* refactor(dbus): Move system configuration methods to revpi_config.py
|
||||
* feat(dbus): Remove 'var-log.mount' feature
|
||||
* feat(dbus): Add avahi-daemon configuration to system services
|
||||
* feat(dbus): Add dphys-swapfile configuration functionality
|
||||
* feat(revpiconfig): Add ConfigTxt class for managing config.txt file
|
||||
* feat(dbus): Add support for configuring the external antenna
|
||||
* feat(dbus): Add support for configuring 'revpi-con-can' feature
|
||||
* feat(revpiconfig): Enhance Wi-Fi detection and add rfkill index support
|
||||
* feat(dbus): Add Wi-Fi configuration support to the system config
|
||||
* refactor(revpiconfig: Change Wi-Fi detection and rfkill index logic
|
||||
* feat(dbus): Add Bluetooth configuration functionality
|
||||
* feat(dbus): Add InterfaceRevpiConfig to DBus interfaces list
|
||||
* feat(cli): Add `get_properties` helper function for DBus interactions
|
||||
* feat(cli): Add CLI command for configuring Revpi features
|
||||
* feat(cli): Add CLI support for RevPi configuration object (revpi-config)
|
||||
* feat(revpiconfig): Replace rfkill subprocess calls with sysfs writes
|
||||
* refactor: Rename WiFi to WLAN for consistent terminology
|
||||
* feat(deb): Add dependencies for `dtoverlay` command
|
||||
|
||||
-- Sven Sager <s.sager@kunbus.com> Mon, 21 Apr 2025 13:44:18 +0200
|
||||
|
||||
revpi-middleware (0.0.2-1+deb12+1) bookworm; urgency=medium
|
||||
|
||||
* refactor(dbus): Move D-Bus helper functions to a dedicated file
|
||||
* refactor(dbus): Move ResetDriverWatchdog to process_image_helper.py
|
||||
* refactor(dbus): Parameterize `picontrol_device` and `config_rsc`
|
||||
* feat: Add session bus option for local testing and development
|
||||
* feat(dbus): Add import for BusProvider in dbus_middleware1 module
|
||||
* feat(dbus): Add `running` property to `BusProvider`
|
||||
* refactor(cli): D-Bus helpers support session and system bus types
|
||||
* fix(dbus): Add error handling for DBus publishing and main loop
|
||||
* refactor(dbus): piControl driver reset with PiControlIoctl class
|
||||
* test(dbus): Add unit test framework for dbus_middleware1 module
|
||||
* test(dbus): Add unit tests for PiControl D-Bus interface
|
||||
* refactor(dbus): Fix typo and remove unused thread instance
|
||||
* refactor(dbus): D-Bus interface management with cleanup support.
|
||||
* test(dbus): Add support for testing driver reset notification
|
||||
* feat(deb): Add dbus for testing to build dependencies
|
||||
* fix(deb): Skip tests because of missing SystemBus in build container
|
||||
|
||||
-- Sven Sager <s.sager@kunbus.com> Sat, 19 Apr 2025 16:34:20 +0200
|
||||
|
||||
revpi-middleware (0.0.1-1+deb12+1) bookworm; urgency=medium
|
||||
|
||||
* docs: Start git project with python git-ignore and Readme
|
||||
* docs: Use 'reuse' for SPDX Headers and Licenses
|
||||
* feat: Add python base project files
|
||||
* feat: Add proginit application basic module
|
||||
* feat: Add the data directory for additional data files for the project
|
||||
* test: Add tests directory with a dummy test
|
||||
* build: Add all necessary files for the build system
|
||||
* feat: Add dummy main application script
|
||||
* feat: Add systemd file and data to integrate the app as a daemon
|
||||
* chore: Update proginit to 1.4.0
|
||||
* feat(dbus): Add ResetDriverWatchdog helper as global dbus helper
|
||||
* feat(process_image): Add D-Bus interface for piControl driver
|
||||
* feat(dbus): Add initial D-Bus middleware implementation
|
||||
* feat(dbus): Add `extend_interface` function for dynamic interface naming
|
||||
* feat(dbus): Add DBus policy configuration for revpi-middleware
|
||||
* feat: Add MiddlewareDaemon implementation to revpi-middleware
|
||||
* feat: Add daemon mode and signal handling to main application
|
||||
* feat(cli): Add D-Bus helper functions for CLI commands.
|
||||
* feat(cli): Add await_signal function to handle D-Bus signals
|
||||
* feat(cli): Add `await-reset` to wait for piControl reset signal
|
||||
* chore(build): Update requirements for this project
|
||||
* feat(cli): Add new CLI tool entry point for `revpictl`
|
||||
* feat(deb): Start packaging branch
|
||||
|
||||
-- Sven Sager <s.sager@kunbus.com> Fri, 18 Apr 2025 19:02:20 +0200
|
||||
39
debian/control
vendored
39
debian/control
vendored
@@ -1,39 +0,0 @@
|
||||
Source: revpi-middleware
|
||||
Section: python
|
||||
Priority: optional
|
||||
Maintainer: KUNBUS GmbH <support@kunbus.com>
|
||||
Rules-Requires-Root: no
|
||||
Homepage: https://revolutionpi.com/
|
||||
Vcs-Browser: https://gitlab.com/revolutionpi/revpi-middleware
|
||||
Vcs-Git: https://gitlab.com/revolutionpi/revpi-middleware.git -b debian/bookworm
|
||||
Build-Depends:
|
||||
dbus,
|
||||
dbus-x11,
|
||||
debhelper-compat (= 13),
|
||||
dh-python,
|
||||
python3-all,
|
||||
python3-gi (>= 3.42.2),
|
||||
python3-pydbus (>= 0.6.0),
|
||||
python3-setuptools,
|
||||
Standards-Version: 4.6.2
|
||||
|
||||
Package: revpi-middleware
|
||||
Architecture: all
|
||||
Pre-Depends: ${misc:Pre-Depends}
|
||||
Depends:
|
||||
raspi-utils-dt | libraspberrypi-bin,
|
||||
${python3:Depends},
|
||||
${misc:Depends}
|
||||
Description: Revolution Pi middleware with D-Bus interface
|
||||
The Revolution Pi middleware provides a robust communication interface for
|
||||
Revolution Pi industrial computers. It enables seamless integration between
|
||||
hardware components and applications through a D-Bus interface. The middleware
|
||||
serves as a bridge for data exchange, device configuration, and system
|
||||
monitoring.
|
||||
.
|
||||
Key features:
|
||||
* Hardware abstraction layer for Revolution Pi I/O modules
|
||||
* Real-time data processing and event handling
|
||||
* Simplified API for accessing Revolution Pi hardware features
|
||||
* Extensive configuration options for industrial automation tasks
|
||||
* Built-in monitoring and diagnostic capabilities
|
||||
27
debian/copyright
vendored
27
debian/copyright
vendored
@@ -1,27 +0,0 @@
|
||||
Format: https://www.debian.org/doc/packaging-manuals/copyright-format/1.0/
|
||||
Source: https://gitlab.com/revolutionpi/opcua-revpi-server
|
||||
|
||||
Files: *
|
||||
Copyright: 2025 KUNBUS GmbH
|
||||
License: GPL-2+
|
||||
|
||||
Files: debian/*
|
||||
Copyright: 2025 KUNBUS GmbH
|
||||
License: GPL-2+
|
||||
|
||||
License: GPL-2+
|
||||
This package is free software; you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation; either version 2 of the License, or
|
||||
(at your option) any later version.
|
||||
.
|
||||
This package is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
.
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program. If not, see <https://www.gnu.org/licenses/>
|
||||
.
|
||||
On Debian systems, the complete text of the GNU General
|
||||
Public License version 2 can be found in "/usr/share/common-licenses/GPL-2".
|
||||
7
debian/gbp.conf
vendored
7
debian/gbp.conf
vendored
@@ -1,7 +0,0 @@
|
||||
[DEFAULT]
|
||||
upstream-branch = main
|
||||
upstream-tag = v%(version)s
|
||||
debian-branch=debian/bookworm
|
||||
debian-tag = debian/%(version)s
|
||||
debian-tag-msg = %(pkg)s Debian release %(version)s
|
||||
pristine-tar = True
|
||||
4
debian/revpi-middleware.install
vendored
4
debian/revpi-middleware.install
vendored
@@ -1,4 +0,0 @@
|
||||
data/dbus-policy/com.revolutionpi.middleware1.conf /usr/share/dbus-1/system.d
|
||||
data/etc/default/revpi-middleware /etc/default/
|
||||
data/etc/revpi-middleware/revpi-middleware.conf /etc/revpi-middleware/
|
||||
data/systemd/before_253/revpi-middleware.service /lib/systemd/system/
|
||||
2
debian/revpi-middleware.links
vendored
2
debian/revpi-middleware.links
vendored
@@ -1,2 +0,0 @@
|
||||
/usr/share/revpi-middleware/revpi-middleware /usr/sbin/revpi-middleware
|
||||
/usr/share/revpi-middleware/revpicli /usr/bin/revpicli
|
||||
12
debian/rules
vendored
12
debian/rules
vendored
@@ -1,12 +0,0 @@
|
||||
#!/usr/bin/make -f
|
||||
|
||||
export PYBUILD_NAME=revpi-middleware
|
||||
export PYBUILD_INSTALL_ARGS=--install-lib=/usr/share/$(PYBUILD_NAME)/ --install-scripts=/usr/share/$(PYBUILD_NAME)/
|
||||
|
||||
%:
|
||||
dh $@ --with python3 --buildsystem=pybuild
|
||||
|
||||
override_dh_auto_test:
|
||||
# Currently, the tests have to be skipped, because no SystemBus is
|
||||
# available in the Docker container.
|
||||
@echo "Skipped tests"
|
||||
1
debian/source/format
vendored
1
debian/source/format
vendored
@@ -1 +0,0 @@
|
||||
3.0 (quilt)
|
||||
51
docs/dbus.md
Normal file
51
docs/dbus.md
Normal file
@@ -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
|
||||
100
examples/revpi-config
Executable file
100
examples/revpi-config
Executable file
@@ -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)))
|
||||
@@ -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
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -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"
|
||||
|
||||
@@ -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__
|
||||
|
||||
@@ -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__
|
||||
|
||||
@@ -5,6 +5,7 @@
|
||||
This module provides the foundation for the RevPi middleware CLI commands
|
||||
and argument parsing setup.
|
||||
"""
|
||||
|
||||
from logging import getLogger
|
||||
|
||||
from . import cli_config, cli_picontrol
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -16,7 +17,7 @@ def add_subparsers(parent_parser: ArgumentParser):
|
||||
"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'.",
|
||||
"To get all available features, use 'list-features'.",
|
||||
)
|
||||
parent_parser.add_argument(
|
||||
"feature",
|
||||
|
||||
@@ -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
|
||||
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -4,11 +4,16 @@
|
||||
"""Main daemon of revpi-middleware."""
|
||||
|
||||
from logging import getLogger
|
||||
from os import getuid, environ
|
||||
from threading import Event
|
||||
from time import perf_counter
|
||||
from typing import List
|
||||
|
||||
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
|
||||
|
||||
log = getLogger(__name__)
|
||||
|
||||
@@ -25,7 +30,8 @@ class MiddlewareDaemon:
|
||||
self._reconfigure = False
|
||||
self._running = True
|
||||
|
||||
self.bus_provider = None
|
||||
self.bp_middleware1 = None
|
||||
self.bp_ios1 = None
|
||||
|
||||
self._configure()
|
||||
log.debug("leave MiddlewareDaemon.__init__")
|
||||
@@ -37,24 +43,55 @@ class MiddlewareDaemon:
|
||||
|
||||
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 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)
|
||||
self.bus_provider.start()
|
||||
dbus_middleware1_running = self.bp_middleware1 and self.bp_middleware1.is_alive()
|
||||
if not dbus_middleware1_running:
|
||||
self.bp_middleware1 = BusProviderMiddleware1(self._get_bus_address())
|
||||
self.bp_middleware1.start()
|
||||
|
||||
dbus_ios1_running = self.bp_ios1 and self.bp_ios1.is_alive()
|
||||
if not dbus_ios1_running:
|
||||
if self.bp_middleware1.published.wait(timeout=10.0):
|
||||
self.bp_ios1 = BusProviderIos1(self._get_bus_address())
|
||||
self.bp_ios1.start()
|
||||
else:
|
||||
log.error("dbus middleware1 provider thread is not alive - can not start ios1 bus")
|
||||
|
||||
log.debug("leave MiddlewareDaemon.dbus_start")
|
||||
|
||||
def dbus_stop(self):
|
||||
def dbus_stop(self, bus_filter: List[object] = None):
|
||||
log.debug("enter MiddlewareDaemon.dbus_stop")
|
||||
|
||||
if self.bus_provider:
|
||||
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")
|
||||
if bus_filter is None:
|
||||
bus_filter = [
|
||||
self.bp_middleware1,
|
||||
self.bp_ios1,
|
||||
]
|
||||
|
||||
if self.bp_middleware1 and self.bp_middleware1 in bus_filter:
|
||||
self.bp_middleware1.stop()
|
||||
self.bp_middleware1.join(timeout=10.0)
|
||||
if self.bp_middleware1.is_alive():
|
||||
log.warning("dbus middleware1 provider thread is still alive")
|
||||
|
||||
if self.bp_ios1 and self.bp_ios1 in bus_filter:
|
||||
self.bp_ios1.stop()
|
||||
self.bp_ios1.join(timeout=10.0)
|
||||
if self.bp_ios1.is_alive():
|
||||
log.warning("dbus ios1 provider thread is still alive")
|
||||
|
||||
log.debug("leave MiddlewareDaemon.dbus_stop")
|
||||
|
||||
@@ -97,6 +134,17 @@ class MiddlewareDaemon:
|
||||
self._reconfigure = False
|
||||
pi.startup_complete()
|
||||
|
||||
# Monitor bus providers for errors and restart them
|
||||
restart = False
|
||||
if not (self.bp_middleware1 and self.bp_middleware1.is_alive()):
|
||||
log.warning("dbus middleware1 provider thread is not alive - restarting")
|
||||
restart = True
|
||||
if not (self.bp_ios1 and self.bp_ios1.is_alive()):
|
||||
log.warning("dbus ios1 provider thread is not alive - restarting")
|
||||
restart = True
|
||||
if restart:
|
||||
self.dbus_start()
|
||||
|
||||
# Cycle time calculation
|
||||
dm = divmod(ot - perf_counter(), self._cycle_time)
|
||||
# For float the result is (q, a % b), where q is usually math.floor(a / b) but may be 1 less than that.
|
||||
|
||||
8
src/revpi_middleware/dbus_ios1/__init__.py
Normal file
8
src/revpi_middleware/dbus_ios1/__init__.py
Normal file
@@ -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
|
||||
122
src/revpi_middleware/dbus_ios1/bus_provider_ios1.py
Normal file
122
src/revpi_middleware/dbus_ios1/bus_provider_ios1.py
Normal file
@@ -0,0 +1,122 @@
|
||||
# -*- 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()
|
||||
except Exception as e:
|
||||
log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}")
|
||||
|
||||
# Subscribe to NotifyDriverReset on middleware1 dbus
|
||||
iface_pi_control = bus.get(
|
||||
"com.revolutionpi.middleware1",
|
||||
"/com/revolutionpi/middleware1",
|
||||
)["com.revolutionpi.middleware1.PiControl"]
|
||||
iface_pi_control.onNotifyDriverReset = self.stop
|
||||
|
||||
try:
|
||||
self._loop.run()
|
||||
except Exception as e:
|
||||
log.error(f"can not run dbus mainloop: {e}")
|
||||
|
||||
bus.con.close()
|
||||
self._modio.cleanup()
|
||||
|
||||
log.debug("leave BusProviderIos1.run")
|
||||
|
||||
def stop(self):
|
||||
log.debug("enter BusProviderIos1.stop")
|
||||
self._loop.quit()
|
||||
log.debug("leave BusProviderIos1.stop")
|
||||
|
||||
@property
|
||||
def running(self):
|
||||
return self._loop.is_running()
|
||||
133
src/revpi_middleware/dbus_ios1/interface_devices.py
Normal file
133
src/revpi_middleware/dbus_ios1/interface_devices.py
Normal file
@@ -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.")
|
||||
306
src/revpi_middleware/dbus_ios1/interface_ios.py
Normal file
306
src/revpi_middleware/dbus_ios1/interface_ios.py
Normal file
@@ -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)
|
||||
51
src/revpi_middleware/dbus_ios1/ios1_helper.py
Normal file
51
src/revpi_middleware/dbus_ios1/ios1_helper.py
Normal file
@@ -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}")
|
||||
@@ -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
|
||||
|
||||
@@ -2,38 +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
|
||||
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(),
|
||||
@@ -41,15 +44,17 @@ class BusProvider(Thread):
|
||||
# ("Subdir2", Example()),
|
||||
# ("Subdir2/Whatever", Example())
|
||||
lst_interfaces = [
|
||||
InterfacePiControl(self.picontrol_device, self.config_rsc),
|
||||
InterfaceRevpiConfig(),
|
||||
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()
|
||||
except Exception as e:
|
||||
log.error(f"can not publish dbus {REVPI_DBUS_NAME}: {e}")
|
||||
|
||||
@@ -58,18 +63,20 @@ class BusProvider(Thread):
|
||||
except Exception as e:
|
||||
log.error(f"can not run dbus mainloop: {e}")
|
||||
|
||||
bus.con.close()
|
||||
|
||||
# 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 running(self):
|
||||
@@ -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
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -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
|
||||
@@ -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
|
||||
|
||||
|
||||
@@ -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
|
||||
|
||||
@@ -2,4 +2,6 @@
|
||||
# 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
|
||||
|
||||
@@ -2,19 +2,20 @@
|
||||
# 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_avahi_daemon,
|
||||
configure_bluetooth,
|
||||
configure_con_can,
|
||||
configure_dphys_swapfile,
|
||||
configure_external_antenna,
|
||||
configure_gui,
|
||||
configure_wlan,
|
||||
simple_systemd,
|
||||
)
|
||||
from ..dbus_helper import DbusInterface
|
||||
|
||||
@@ -42,19 +43,32 @@ class InterfaceRevpiConfig(DbusInterface):
|
||||
<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."""
|
||||
@@ -83,18 +97,8 @@ def get_feature(feature: str) -> FeatureFunction:
|
||||
AVAILABLE_FEATURES = {
|
||||
"gui": FeatureFunction(configure_gui, []),
|
||||
"revpi-con-can": FeatureFunction(configure_con_can, []),
|
||||
"dphys-swapfile": FeatureFunction(configure_dphys_swapfile, []),
|
||||
"pimodbus-master": FeatureFunction(simple_systemd, ["pimodbus-master.service"]),
|
||||
"pimodbus-slave": FeatureFunction(simple_systemd, ["pimodbus-slave.service"]),
|
||||
"systemd-timesyncd": FeatureFunction(simple_systemd, ["systemd-timesyncd.service"]),
|
||||
"ssh": FeatureFunction(simple_systemd, ["ssh.service"]),
|
||||
"nodered": FeatureFunction(simple_systemd, ["nodered.service"]),
|
||||
"noderedrevpinodes-server": FeatureFunction(
|
||||
simple_systemd, ["noderedrevpinodes-server.service"]
|
||||
),
|
||||
"revpipyload": FeatureFunction(simple_systemd, ["revpipyload.service"]),
|
||||
"swapfile": FeatureFunction(configure_dphys_swapfile, []),
|
||||
"bluetooth": FeatureFunction(configure_bluetooth, []),
|
||||
"wlan": FeatureFunction(configure_wlan, []),
|
||||
"avahi": FeatureFunction(configure_avahi_daemon, []),
|
||||
"external-antenna": FeatureFunction(configure_external_antenna, []),
|
||||
}
|
||||
|
||||
@@ -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())
|
||||
@@ -10,12 +10,12 @@ from glob import glob
|
||||
from logging import getLogger
|
||||
from os import X_OK, access
|
||||
from os.path import exists, join
|
||||
from threading import Thread
|
||||
from typing import List, Optional
|
||||
|
||||
from pydbus import SystemBus
|
||||
|
||||
from ..dbus_helper import grep
|
||||
from ..systemd_helper import simple_systemd, ServiceActions
|
||||
|
||||
log = getLogger(__name__)
|
||||
|
||||
@@ -42,6 +42,7 @@ class ComputeModuleTypes(IntEnum):
|
||||
CM4S (int): Represents a Compute Module 4S.
|
||||
CM5 (int): Represents a Compute Module 5.
|
||||
"""
|
||||
|
||||
UNKNOWN = 0
|
||||
CM1 = 6
|
||||
CM3 = 10
|
||||
@@ -58,6 +59,7 @@ class ConfigActions(Enum):
|
||||
actions. It can be used to ensure consistency when working with or defining
|
||||
such actions in a system.
|
||||
"""
|
||||
|
||||
ENABLE = "enable"
|
||||
DISABLE = "disable"
|
||||
STATUS = "status"
|
||||
@@ -232,6 +234,7 @@ class ConfigTxt:
|
||||
_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):
|
||||
@@ -432,18 +435,6 @@ class ConfigTxt:
|
||||
return self._config_txt_path
|
||||
|
||||
|
||||
def configure_avahi_daemon(action: ConfigActions):
|
||||
return_value = simple_systemd(action, "avahi-daemon.service")
|
||||
|
||||
# Post actions for avahi-daemon
|
||||
if action in (ConfigActions.ENABLE, ConfigActions.DISABLE):
|
||||
# Apply the enable/disable action to the avahi socket AFTER the service
|
||||
# unit, because a connected socket could interrupt stop
|
||||
simple_systemd(action, "avahi-daemon.socket")
|
||||
|
||||
return return_value
|
||||
|
||||
|
||||
def configure_bluetooth(action: ConfigActions):
|
||||
hci_device = join(LINUX_BT_CLASS_PATH, "hci0")
|
||||
bt_rfkill_index = get_rfkill_index(hci_device)
|
||||
@@ -509,7 +500,17 @@ def configure_con_can(action: ConfigActions):
|
||||
|
||||
|
||||
def configure_dphys_swapfile(action: ConfigActions):
|
||||
return_value = simple_systemd(action, "dphys-swapfile.service")
|
||||
# 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:
|
||||
@@ -634,98 +635,6 @@ def get_rfkill_index(device_class_path: str) -> Optional[int]:
|
||||
return None
|
||||
|
||||
|
||||
def simple_systemd(action: ConfigActions, unit: str):
|
||||
"""
|
||||
Performs specified actions on systemd units.
|
||||
|
||||
This function allows interaction with systemd units for various operations
|
||||
such as enabling, disabling, checking the status, and verifying availability.
|
||||
It communicates with the systemd manager via the SystemBus and handles units
|
||||
based on the action specified.
|
||||
|
||||
Parameters:
|
||||
action (ConfigActions): Specifies the action to be performed on the
|
||||
systemd unit. Supported actions include ENABLE,
|
||||
DISABLE, STATUS, and AVAILABLE.
|
||||
unit (str): The name of the systemd unit on which the action is to be
|
||||
performed.
|
||||
|
||||
Returns:
|
||||
bool: For STATUS and AVAILABLE actions, returns True if the corresponding
|
||||
criteria are met (e.g., enabled and active for STATUS, or not found
|
||||
for AVAILABLE). Otherwise, returns False.
|
||||
|
||||
Raises:
|
||||
ValueError: If the specified action is not supported.
|
||||
"""
|
||||
bus = SystemBus()
|
||||
systemd = bus.get(
|
||||
"org.freedesktop.systemd1",
|
||||
"/org/freedesktop/systemd1",
|
||||
)
|
||||
systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
|
||||
|
||||
if action is ConfigActions.ENABLE:
|
||||
|
||||
def thread_unit_config():
|
||||
"""Change configuration asynchronously."""
|
||||
# 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 ConfigActions.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 ConfigActions.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 == "active"
|
||||
|
||||
elif action is ConfigActions.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
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
rc = RevPiConfig()
|
||||
print("Model:", rc.model)
|
||||
|
||||
121
src/revpi_middleware/dbus_middleware1/systemd_helper.py
Normal file
121
src/revpi_middleware/dbus_middleware1/systemd_helper.py
Normal file
@@ -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
|
||||
@@ -2,6 +2,7 @@
|
||||
# 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
|
||||
|
||||
@@ -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"
|
||||
|
||||
@@ -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(
|
||||
self.picontrol.name,
|
||||
use_system_bus=False,
|
||||
bus_address = dbus_address_get_for_bus_sync(BusType.SESSION)
|
||||
self.bp = BusProviderMiddleware1(
|
||||
bus_address,
|
||||
picontrol_device=self.picontrol.name,
|
||||
)
|
||||
self.bp.start()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user