Compare commits
17 Commits
v0.0.3
...
debian/0.0
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c7d5b254e8 | ||
| c668f34124 | |||
| 8db1f59cfe | |||
| 7051eba9b9 | |||
| 04780bd0dd | |||
| 41fb2b3c61 | |||
| 41d9b13e71 | |||
| 463a61a001 | |||
|
|
8fc058c7ee | ||
| 0618bf8693 | |||
| e1e9db8a21 | |||
|
|
686bf407a8 | ||
| c12c0d36f0 | |||
| e2bf154185 | |||
| 7506f56121 | |||
| f23a91bd4f | |||
| 28d4ce0116 |
@@ -1,4 +1,4 @@
|
|||||||
<!-- /etc/dbus-1/system.d/revpi-middleware.conf -->
|
<!-- /usr/share/dbus-1/system.d/com.revolutionpi.middleware1.conf -->
|
||||||
<busconfig>
|
<busconfig>
|
||||||
<!-- Allow full access to root as the bus owner -->
|
<!-- Allow full access to root as the bus owner -->
|
||||||
<policy user="root">
|
<policy user="root">
|
||||||
@@ -12,7 +12,7 @@
|
|||||||
<allow send_destination="com.revolutionpi.middleware1"
|
<allow send_destination="com.revolutionpi.middleware1"
|
||||||
send_interface="org.freedesktop.DBus.Introspectable"/>
|
send_interface="org.freedesktop.DBus.Introspectable"/>
|
||||||
<allow send_destination="com.revolutionpi.middleware1"
|
<allow send_destination="com.revolutionpi.middleware1"
|
||||||
send_interface="com.revolutionpi.middleware1.picontrol"/>
|
send_interface="com.revolutionpi.middleware1.PiControl"/>
|
||||||
</policy>
|
</policy>
|
||||||
|
|
||||||
<!-- Standard-Policy -->
|
<!-- Standard-Policy -->
|
||||||
|
|||||||
88
debian/changelog
vendored
Normal file
88
debian/changelog
vendored
Normal file
@@ -0,0 +1,88 @@
|
|||||||
|
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 11:08:12 +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
Normal file
39
debian/control
vendored
Normal file
@@ -0,0 +1,39 @@
|
|||||||
|
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
Normal file
27
debian/copyright
vendored
Normal file
@@ -0,0 +1,27 @@
|
|||||||
|
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
Normal file
7
debian/gbp.conf
vendored
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
[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
Normal file
4
debian/revpi-middleware.install
vendored
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
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
Normal file
2
debian/revpi-middleware.links
vendored
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
/usr/share/revpi-middleware/revpi-middleware /usr/sbin/revpi-middleware
|
||||||
|
/usr/share/revpi-middleware/revpicli /usr/bin/revpicli
|
||||||
12
debian/rules
vendored
Executable file
12
debian/rules
vendored
Executable file
@@ -0,0 +1,12 @@
|
|||||||
|
#!/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
Normal file
1
debian/source/format
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
3.0 (quilt)
|
||||||
@@ -26,6 +26,21 @@ CONFIG_TXT_LOCATIONS = ("/boot/firmware/config.txt", "/boot/config.txt")
|
|||||||
|
|
||||||
|
|
||||||
class ComputeModuleTypes(IntEnum):
|
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
|
UNKNOWN = 0
|
||||||
CM1 = 6
|
CM1 = 6
|
||||||
CM3 = 10
|
CM3 = 10
|
||||||
@@ -35,6 +50,13 @@ class ComputeModuleTypes(IntEnum):
|
|||||||
|
|
||||||
|
|
||||||
class ConfigActions(Enum):
|
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"
|
ENABLE = "enable"
|
||||||
DISABLE = "disable"
|
DISABLE = "disable"
|
||||||
STATUS = "status"
|
STATUS = "status"
|
||||||
@@ -42,6 +64,20 @@ class ConfigActions(Enum):
|
|||||||
|
|
||||||
|
|
||||||
class RevPiConfig:
|
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):
|
def __init__(self):
|
||||||
self._cm_type = ComputeModuleTypes.UNKNOWN
|
self._cm_type = ComputeModuleTypes.UNKNOWN
|
||||||
@@ -55,6 +91,29 @@ class RevPiConfig:
|
|||||||
self._init_device_info()
|
self._init_device_info()
|
||||||
|
|
||||||
def _init_device_info(self):
|
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 = {}
|
dc_cpuinfo = {}
|
||||||
|
|
||||||
# Extract CPU information
|
# Extract CPU information
|
||||||
@@ -103,22 +162,75 @@ class RevPiConfig:
|
|||||||
|
|
||||||
@property
|
@property
|
||||||
def class_path_wlan(self) -> str:
|
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
|
return self._wlan_class_path
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def cm_type(self) -> ComputeModuleTypes:
|
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
|
return self._cm_type
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def with_con_bridge(self) -> bool:
|
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
|
return self._revpi_with_con_bridge
|
||||||
|
|
||||||
@property
|
@property
|
||||||
def with_wlan(self) -> bool:
|
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)
|
return bool(self._wlan_class_path)
|
||||||
|
|
||||||
|
|
||||||
class ConfigTxt:
|
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*$")
|
re_name_value = re.compile(r"^\s*(?!#)(?P<name>[^=\s].+?)\s*=\s*(?P<value>\S+)\s*$")
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
@@ -134,6 +246,24 @@ class ConfigTxt:
|
|||||||
self._config_txt_lines = []
|
self._config_txt_lines = []
|
||||||
|
|
||||||
def _clear_name_values(self, name: str, values: str or list) -> int:
|
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
|
counter = 0
|
||||||
if type(values) is str:
|
if type(values) is str:
|
||||||
values = [values]
|
values = [values]
|
||||||
@@ -146,6 +276,21 @@ class ConfigTxt:
|
|||||||
return counter
|
return counter
|
||||||
|
|
||||||
def _get_all_name_values(self) -> List[ConfigVariable]:
|
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:
|
if not self._config_txt_lines:
|
||||||
self.reload_config()
|
self.reload_config()
|
||||||
|
|
||||||
@@ -159,10 +304,28 @@ class ConfigTxt:
|
|||||||
return lst_return
|
return lst_return
|
||||||
|
|
||||||
def reload_config(self):
|
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:
|
with open(self._config_txt_path, "r") as f:
|
||||||
self._config_txt_lines = f.readlines()
|
self._config_txt_lines = f.readlines()
|
||||||
|
|
||||||
def save_config(self):
|
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:
|
if not self._config_txt_lines:
|
||||||
return
|
return
|
||||||
|
|
||||||
@@ -174,6 +337,20 @@ class ConfigTxt:
|
|||||||
self._config_txt_lines.clear()
|
self._config_txt_lines.clear()
|
||||||
|
|
||||||
def add_name_value(self, name: str, value: str):
|
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
|
# Check weather name and value already exists
|
||||||
for config_var in self._get_all_name_values():
|
for config_var in self._get_all_name_values():
|
||||||
if config_var.name == name and config_var.value == value:
|
if config_var.name == name and config_var.value == value:
|
||||||
@@ -182,12 +359,55 @@ class ConfigTxt:
|
|||||||
self._config_txt_lines.append(f"{name}={value}\n")
|
self._config_txt_lines.append(f"{name}={value}\n")
|
||||||
|
|
||||||
def clear_dtoverlays(self, dtoverlays: str or list) -> int:
|
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)
|
return self._clear_name_values("dtoverlay", dtoverlays)
|
||||||
|
|
||||||
def clear_dtparams(self, dtparams: str or list) -> int:
|
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)
|
return self._clear_name_values("dtparam", dtparams)
|
||||||
|
|
||||||
def get_values(self, var_name: str) -> list:
|
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 = []
|
var_values = []
|
||||||
|
|
||||||
for config_var in self._get_all_name_values():
|
for config_var in self._get_all_name_values():
|
||||||
@@ -198,6 +418,16 @@ class ConfigTxt:
|
|||||||
|
|
||||||
@property
|
@property
|
||||||
def config_txt_path(self) -> str:
|
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
|
return self._config_txt_path
|
||||||
|
|
||||||
|
|
||||||
@@ -324,7 +554,11 @@ def configure_gui(action: ConfigActions):
|
|||||||
return gui_available
|
return gui_available
|
||||||
|
|
||||||
bus = SystemBus()
|
bus = SystemBus()
|
||||||
systemd_manager = bus.get(".systemd1")
|
systemd = bus.get(
|
||||||
|
"org.freedesktop.systemd1",
|
||||||
|
"/org/freedesktop/systemd1",
|
||||||
|
)
|
||||||
|
systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
|
||||||
|
|
||||||
if action is ConfigActions.ENABLE:
|
if action is ConfigActions.ENABLE:
|
||||||
systemd_manager.SetDefaultTarget("graphical.target", True)
|
systemd_manager.SetDefaultTarget("graphical.target", True)
|
||||||
@@ -373,6 +607,23 @@ def configure_wlan(action: ConfigActions):
|
|||||||
|
|
||||||
|
|
||||||
def get_rfkill_index(device_class_path: str) -> Optional[int]:
|
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+)$")
|
re_rfkill_index = re.compile(r"^/.+/rfkill(?P<index>\d+)$")
|
||||||
for rfkill_path in glob(join(device_class_path, "rfkill*")):
|
for rfkill_path in glob(join(device_class_path, "rfkill*")):
|
||||||
match_index = re_rfkill_index.match(rfkill_path)
|
match_index = re_rfkill_index.match(rfkill_path)
|
||||||
@@ -383,8 +634,35 @@ def get_rfkill_index(device_class_path: str) -> Optional[int]:
|
|||||||
|
|
||||||
|
|
||||||
def simple_systemd(action: ConfigActions, unit: str):
|
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()
|
bus = SystemBus()
|
||||||
systemd_manager = bus.get(".systemd1")
|
systemd = bus.get(
|
||||||
|
"org.freedesktop.systemd1",
|
||||||
|
"/org/freedesktop/systemd1",
|
||||||
|
)
|
||||||
|
systemd_manager = systemd["org.freedesktop.systemd1.Manager"]
|
||||||
|
|
||||||
if action is ConfigActions.ENABLE:
|
if action is ConfigActions.ENABLE:
|
||||||
systemd_manager.UnmaskUnitFiles([unit], False)
|
systemd_manager.UnmaskUnitFiles([unit], False)
|
||||||
@@ -398,7 +676,7 @@ def simple_systemd(action: ConfigActions, unit: str):
|
|||||||
elif action is ConfigActions.STATUS:
|
elif action is ConfigActions.STATUS:
|
||||||
try:
|
try:
|
||||||
unit_path = systemd_manager.LoadUnit(unit)
|
unit_path = systemd_manager.LoadUnit(unit)
|
||||||
properties = bus.get(".systemd1", unit_path)
|
properties = bus.get("org.freedesktop.systemd1", unit_path)
|
||||||
except Exception:
|
except Exception:
|
||||||
log.warning(f"could not get systemd unit {unit}")
|
log.warning(f"could not get systemd unit {unit}")
|
||||||
return False
|
return False
|
||||||
@@ -408,7 +686,7 @@ def simple_systemd(action: ConfigActions, unit: str):
|
|||||||
elif action is ConfigActions.AVAILABLE:
|
elif action is ConfigActions.AVAILABLE:
|
||||||
try:
|
try:
|
||||||
unit_path = systemd_manager.LoadUnit(unit)
|
unit_path = systemd_manager.LoadUnit(unit)
|
||||||
properties = bus.get(".systemd1", unit_path)
|
properties = bus.get("org.freedesktop.systemd1", unit_path)
|
||||||
except Exception:
|
except Exception:
|
||||||
log.warning(f"could not get systemd unit {unit}")
|
log.warning(f"could not get systemd unit {unit}")
|
||||||
return False
|
return False
|
||||||
|
|||||||
Reference in New Issue
Block a user