Supported Hardware

Primary Device (Master)
    |
    +-- Local I/O (platform_iface)
    |
    +-- Modbus Bus (modbus_iface)
            |
            +-- Slave 1: Moxa 1242 @ 192.168.1.10:502
            +-- Slave 2: Moxa 1241 @ 192.168.1.11:502
            +-- Slave 3: RTU Device @ /dev/ttyUSB0, ID 1

# Configure slaves in your application config
class MyConfig(Schema):
    def __init__(self):
        self.modbus_config = ModbusConfig("Modbus")
        self.modbus_config.type.default = "tcp"
        self.modbus_config.name.default = "io_bus"
        self.modbus_config.tcp_uri.default = "192.168.1.10:502"

# Read from a Moxa slave
class MyApp(Application):
    def main_loop(self):
        # Read digital inputs from Moxa 1242
        di_values = self.modbus_iface.read_registers(
            bus_id="io_bus",
            modbus_id=1,
            start_address=0,
            num_registers=12,
            register_type=2  # Discrete inputs
        )

        # Write digital outputs
        self.modbus_iface.write_registers(
            bus_id="io_bus",
            modbus_id=1,
            start_address=0,
            values=[1, 0, 1, 1],  # Set outputs 0-3
            register_type=1  # Coils
        )

from pydoover.docker import Application, run_app, ManyModbusConfig
from pydoover.config import Schema

class DistributedIOConfig(Schema):
    def __init__(self):
        # Configure multiple Modbus buses for slave devices
        self.modbus_config = ManyModbusConfig("Modbus Buses")

class DistributedIOApp(Application):
    config: DistributedIOConfig

    def setup(self):
        # Open connection to first Moxa slave
        self.modbus_iface.open_bus(
            bus_type="tcp",
            name="moxa_1",
            tcp_uri="192.168.1.10:502"
        )

        # Open connection to second Moxa slave
        self.modbus_iface.open_bus(
            bus_type="tcp",
            name="moxa_2",
            tcp_uri="192.168.1.11:502"
        )

    def main_loop(self):
        # Read from local Doovit I/O
        local_di = self.platform_iface.get_di(0)

        # Read from first Moxa slave
        remote_di_1 = self.modbus_iface.read_registers(
            bus_id="moxa_1",
            modbus_id=1,
            start_address=0,
            num_registers=1,
            register_type=2
        )

        # Read from second Moxa slave
        remote_di_2 = self.modbus_iface.read_registers(
            bus_id="moxa_2",
            modbus_id=1,
            start_address=0,
            num_registers=1,
            register_type=2
        )

        # Use combined I/O data
        print(f"Local: {local_di}, Remote 1: {remote_di_1}, Remote 2: {remote_di_2}")

if __name__ == "__main__":
    run_app(DistributedIOApp(config=DistributedIOConfig()))