refactor: Replace usage of SmartREST with JSON over MQTT

Signed-off-by: Rina Fujino <rina.fujino.23@gmail.com>

Author: rina23q

operations/c8y_Coils

@@ -1,4 +1,4 @@
 [exec]
-  topic = "c8y/s/ds"
-  on_message = "xy"
+  topic = "c8y/devicecontrol/notifications"
+  on_fragment = "c8y_Coils"
   command = "python3 -m tedge_modbus.operations c8y_Coils"

operations/c8y_ModbusConfiguration

@@ -1,4 +1,4 @@
 [exec]
-  topic = "c8y/s/dc/modbus"
-  on_message = "1"
-  command = "python3 -m tedge_modbus.operations c8y_ModbusConfiguration"
+  topic = "c8y/devicecontrol/notifications"
+  on_fragment = "c8y_ModbusConfiguration"
+  command = "python3 -m tedge_modbus.operations c8y_ModbusConfiguration ${.payload.c8y_ModbusConfiguration.transmitRate} ${.payload.c8y_ModbusConfiguration.pollingRate}"

operations/c8y_ModbusDevice

@@ -1,4 +1,4 @@
 [exec]
-  topic = "c8y/s/dc/modbus"
-  on_message = "2"
-  command = "python3 -m tedge_modbus.operations c8y_ModbusDevice"
+  topic = "c8y/devicecontrol/notifications"
+  on_fragment = "c8y_ModbusDevice"
+  command = "python3 -m tedge_modbus.operations c8y_ModbusDevice ${.payload.c8y_ModbusDevice.protocol} ${.payload.c8y_ModbusDevice.address} ${.payload.c8y_ModbusDevice.name} ${.payload.c8y_ModbusDevice.ipAddress} ${.payload.c8y_ModbusDevice.id} ${.payload.c8y_ModbusDevice.type}"

operations/c8y_Registers

@@ -1,4 +1,4 @@
 [exec]
-  topic = "c8y/s/ds"
-  on_message = "xy"
+  topic = "c8y/devicecontrol/notifications"
+  on_fragment = "c8y_Registers"
   command = "python3 -m tedge_modbus.operations c8y_Registers"

operations/c8y_SerialConfiguration

@@ -1,4 +1,4 @@
 [exec]
-  topic = "c8y/s/dc/modbus"
-  on_message = "3"
-  command = "python3 -m tedge_modbus.operations c8y_SerialConfiguration"
+  topic = "c8y/devicecontrol/notifications"
+  on_fragment = "c8y_SerialConfiguration"
+  command = "python3 -m tedge_modbus.operations c8y_SerialConfiguration ${.payload.c8y_SerialConfiguration.baudRate} ${.payload.c8y_ModbusConfiguration.stopBits} ${.payload.c8y_ModbusConfiguration.parity} ${.payload.c8y_ModbusConfiguration.dataBits}"

scripts/deb/postinst

@@ -1,7 +1,6 @@
 #!/bin/sh
 set -e
 
-tedge config add c8y.smartrest.templates modbus
 tedge refresh-bridges
 
 # Automatically added by thin-edge.io

scripts/rpm/postinst

@@ -1,7 +1,6 @@
 #!/bin/sh
 set -e
 
-tedge config add c8y.smartrest.templates modbus
 tedge refresh-bridges
 
 # Automatically added by thin-edge.io

tedge_modbus/operations/__main__.py

@@ -24,7 +24,7 @@ def main():
     elif command == "c8y_SerialConfiguration":
         run = c8y_serial_configuration.run
 
-    arguments = sys.argv[2].split(",") if len(sys.argv) > 2 else []
+    arguments = sys.argv[2:]
     context = Context()
     run(arguments, context)
 

tedge_modbus/operations/c8y_modbus_configuration.py

@@ -1,5 +1,5 @@
 #!/usr/bin/env python3
-"""Cumulocity IoT ModbusConfiguration operation handler"""
+"""Cumulocity ModbusConfiguration operation handler"""
 import json
 import logging
 import toml
@@ -15,18 +15,16 @@
 
 def run(arguments, context: Context):
     """Run c8y_ModbusConfiguration operation handler"""
-    if len(arguments) != 4:
-        raise ValueError(
-            f"Expected 4 arguments in smart rest template. Got {len(arguments)}"
-        )
+    if len(arguments) != 2:
+        raise ValueError(f"Expected 2 arguments. Got {len(arguments)}")
     # Get device configuration
     modbus_config = context.base_config
     loglevel = modbus_config["modbus"]["loglevel"] or "INFO"
     logger.setLevel(getattr(logging, loglevel.upper(), logging.INFO))
     logger.info("New c8y_ModbusConfiguration operation")
     logger.debug("Current configuration: %s", modbus_config)
-    transmit_rate = int(arguments[2])
-    polling_rate = int(arguments[3])
+    transmit_rate = int(arguments[0])
+    polling_rate = int(arguments[1])
     logger.debug("transmitRate: %d, pollingRate: %d", transmit_rate, polling_rate)
 
     # Update configuration

tedge_modbus/operations/c8y_modbus_device.py

@@ -1,5 +1,5 @@
 #!/usr/bin/env python3
-"""Cumulocity IoT Modbus device operation handler"""
+"""Cumulocity Modbus device operation handler"""
 import logging
 from dataclasses import dataclass
 import requests
@@ -77,12 +77,12 @@ def get_device_from_mapping(target: ModebusDevice, mapping):
 def parse_arguments(arguments) -> ModebusDevice:
     """Parse operation arguments"""
     return ModebusDevice(
-        modbus_type=arguments[2],  # Only works for TCP.
-        modbus_address=arguments[3],
-        child_name=arguments[4],
-        modbus_server=arguments[5],
-        device_id=arguments[6],
-        mapping_path=arguments[7],
+        modbus_type=arguments[0],
+        modbus_address=arguments[1],
+        child_name=arguments[2],
+        modbus_server=arguments[3],
+        device_id=arguments[4],
+        mapping_path=arguments[5],
     )
 
 
@@ -92,12 +92,8 @@ def run(arguments, context: Context):
     logger.setLevel(getattr(logging, loglevel.upper(), logging.INFO))
     logger.info("New c8y_ModbusDevice operation")
     # Check and store arguments
-    if len(arguments) != 8:
-        raise ValueError(
-            "Expected 8 arguments in smart rest template. Got "
-            + str(len(arguments))
-            + "."
-        )
+    if len(arguments) != 6:
+        raise ValueError("Expected 6 arguments. Got " + str(len(arguments)) + ".")
     config_path = context.config_dir / "devices.toml"
     target = parse_arguments(arguments)