- Implemented new RestartPolicy logic with exponential backoff support.
- Added systemBus as an extra stream for system-level events and logs.
- Improved DeviceStateEvent to handle more detailed device transitions.

@@ -0,0 +42,4 @@
+/**
+ * Defines how child device lifecycle should be managed.
+ */
+public enum class LifecycleMode {

@@ -0,0 +70,4 @@
+    public fun <D: ConfigurableCompositeControlComponent<*>> getSpec(name: Name): CompositeControlComponentSpec<D>?
+}
+
+public class ComponentRegistryManager : AbstractPlugin(), ComponentRegistry {

@@ -0,0 +18,4 @@
+/**
+ * Create a [MetaConverter] for enum values
+ */
+public fun <E : Enum<E>> createEnumConverter(enumValues: Array<E>): MetaConverter<E> = object : MetaConverter<E> {

@@ -0,0 +18,4 @@
+    // ---------------------- Device Specifications ----------------------------------
+
+    public object StepperMotorSpec : CompositeControlComponentSpec<StepperMotorDevice>() {
+        public val position by intMutable(

@@ -0,0 +110,4 @@
+// ---------------------- Device Implementations ----------------------------------
+
+    // Implementation of Stepper Motor Device
+    public class StepperMotorDevice(

@@ -0,0 +1,3287 @@
+@file:Suppress("MemberVisibilityCanBePrivate", "unused")

@@ -0,0 +24,4 @@
+import kotlin.time.Duration.Companion.seconds
+
+/** Global configuration for controls system. */
+public class ControlsConfiguration(

@@ -0,0 +56,4 @@
+ * @param T The type parameter of the deferred result.
+ * @return The completed value if available and not cancelled, or `null` otherwise.
+ */
+private suspend fun <T> Deferred<T>.awaitCompletedOrNull(): T? =

@@ -0,0 +75,4 @@
+
+/**
+ * Base class for all device-related exceptions
+ */

@@ -0,0 +76,4 @@
+/**
+ * Base class for all device-related exceptions
+ */
+public sealed class DeviceException(

@@ -0,0 +153,4 @@
+/**
+ * EventBus interface for publishing and subscribing to application-level events.
+ */
+public interface EventBus {

@@ -0,0 +176,4 @@
+/**
+ * Event emitted when a message is sent through the transport
+ */
+public data class MessageSentEvent(val message: DeviceMessage) : Event

@@ -0,0 +230,4 @@
+ * TransportAdapter interface for distributed communications.
+ * This abstraction allows plugging in different transport mechanisms.
+ */
+public interface TransportAdapter {

@@ -0,0 +303,4 @@
+/**
+ * Represents an undoable action for transaction rollback
+ */
+public interface UndoableAction {

@@ -0,0 +319,4 @@
+ * Represents a transaction context with a unique ID.
+ * This is used to track and manage transactions.
+ */
+public class TransactionContext(

@@ -0,0 +350,4 @@
+/**
+ * Interface for managing transactional operations.
+ */
+public interface TransactionManager {

@@ -0,0 +488,4 @@
+/**
+ * Interface for publishing metrics.
+ */
+public interface MetricPublisher {

@@ -0,0 +596,4 @@
+/**
+ * Thread-safe atomic reference implementation.
+ */
+public class AtomicReference<T>(initialValue: T) {

@@ -0,0 +658,4 @@
+/**
+ * Interface for loading external device configurations.
+ */
+public interface ExternalConfigurationProvider {

@@ -0,0 +1032,4 @@
+ *
+ * @param CD The type of the child device.
+ */
+public interface ChildComponentConfig<CD : ConfigurableCompositeControlComponent<CD>> {

@@ -0,0 +1048,4 @@
+ *
+ * @param D The device type this spec applies to.
+ */
+public interface CompositeDeviceSpec<D : ConfigurableCompositeControlComponent<D>> {

@@ -0,0 +1543,4 @@
+/**
+ * Manager for health checks across devices.
+ */
+public class HealthCheckManager(

@@ -0,0 +1647,4 @@
+/**
+ * Manages error handling for devices.
+ */
+public class ErrorHandlingManager(

@@ -0,0 +1978,4 @@
+    /**
+     * A [MutableSharedFlow] for system-level messages.
+     */
+    public abstract val systemBus: MutableSharedFlow<SystemLogMessage>

@@ -0,0 +10,4 @@
+/**
+ * Create a [MetaConverter] for enum values using [reified] type with an option to ignore case.
+ */
+public inline fun <reified E : Enum<E>> createEnumConverter(ignoreCase: Boolean = false): MetaConverter<E> {

@@ -219,1 +219,4 @@
 
+@Serializable
+@SerialName("system.log")
+public data class SystemLogMessage(

@@ -11,0 +11,4 @@
+    /**
+     * The device is newly created and has not started yet.
+     */
+    INITIAL,

@@ -6,3 +6,3 @@
 import space.kscience.dataforge.meta.MetaConverter
 
-internal object DeviceMetaPropertySpec : DevicePropertySpec<Device, Meta> {
+public object DeviceMetaPropertySpec : DevicePropertySpec<Device, Meta> {

@@ -94,3 +94,4 @@ include(
     ":demo:constructor",
     ":demo:device-collective"
 )
+include("controls-composite-spec")

@@ -0,0 +22,4 @@
+        implementation(projects.magix.magixRsocket)
+        implementation(projects.magix.magixZmq)
+        implementation(projects.controlsMagix)
+        implementation("org.jetbrains.kotlinx:atomicfu:0.27.0")

@@ -19,3 +20,3 @@
 
 @Serializable
-public sealed class DeviceMessage {
+public sealed class Message {