fix config reset and improve error display when worker crash

.github/workflows/basic-tests.yml

@@ -28,10 +28,10 @@ jobs:
           python3.11 ./platform/panduza_platform/__main__.py &
           sleep 1
 
-      - name: Export test env variables
-        uses: cardinalby/export-env-action@v1
-        with:
-          envFile: './platform/tests/auto/envs/fake_bench.env'
+      # - name: Export test env variables
+      #   uses: cardinalby/export-env-action@v1
+      #   with:
+      #     envFile: './platform/tests/auto/envs/fake_bench.env'
 
       # ---
       - name: Execute tests

client/panduza/robof/platform.py

@@ -11,6 +11,10 @@ class KeywordsPlatform(object):
     def panduza_platform_load_dtree(self, platform_alias, dtree):
         """
         """
+
+        if dtree == '':
+            dtree = {}
+
         p = Platform(alias=platform_alias)
         p.dtree.content.set(dtree)
 

platform/panduza_platform/core/mqtt_async_client.py

@@ -403,8 +403,7 @@ def __on_socket_close(self, client, userdata, sock):
         self.log.warning("Socket closed")
 
         # self.__state = "error"
-        self.worker_panic()
-
+        # self.worker_panic()
 
     # ---
 

platform/panduza_platform/core/platform.py

@@ -207,7 +207,20 @@ async def load_config_content_task(self, new_dtree):
         # Internal store of the platform config
         self.dtree = new_dtree
 
+    # ---
+
+    async def handle_worker_panic(self, name, status):
+        # 
+        self.log.error(f"PANIC: {name}")
+
+        self.log.error( str(status.get("name", "")) + "\n" )
+        self.log.error( str(status.get("final_state", "")) + "\n" )
+        self.log.error( str(status.get("error_string", "")) + "\n" )
+
+        # Remove mounted device from the previous configuration
+        await self.unmount_all_devices()
 
+    # ---
 
 
 
@@ -236,14 +249,6 @@ async def load_config_content_task(self, new_dtree):
 
 
 
-    # # ---
-
-    # def panic(self):
-    #     """
-    #     """
-    #     self.alive = False
-
-    # # ---
 
     # def load_interface(self, bench_name, device, interface_config):
     #     """Load a new interface

platform/panduza_platform/core/platform_driver.py

@@ -286,7 +286,7 @@ async def __drv_state_err(self):
         """
         """
         try:
-            self.worker_panic()
+            await self.worker_panic()
             await self._PZA_DRV_loop_err()
         except Exception as e:
             self.log.error(str(e))
@@ -390,7 +390,7 @@ async def _prepare_update(self, update_obj, att, cmd_att, field,
 
             # Check types
             if not type(v) in valid_types:
-                raise Exception(f"Invalid type for direction.value {type(v)}")
+                raise Exception(f"Invalid type for {att}.{field} got: {type(v)} / expect: {valid_types}")
 
             # Try to set
             await set_callback(v)

platform/panduza_platform/core/platform_worker.py

@@ -12,8 +12,12 @@ def __init__(self) -> None:
     def reset_work_time(self):
         self.work_time = 0
 
-    # def worker_panic(self):
-    #     self.__thread.handle_worker_panic(self.PZA_WORKER_name())
+    # ---
+
+    async def worker_panic(self):
+        await self.platform.handle_worker_panic(self.PZA_WORKER_name(), self.PZA_WORKER_status())
+
+    # ---
 
     async def task(self):
         """

platform/tests/auto/benches/virtual/bench.resource

@@ -15,9 +15,10 @@ Setup Bench Config
     ${PLATFORMS}     Panduza Scan All Platforms    localhost    1883
     Log     ${PLATFORMS}
     Create test platform alias from scan    ${PLATFORMS}    test_platform
-    Panduza platform load dtree    test_platform
+    Panduza platform load dtree    test_platform    ${EMPTY}
     Sleep    1
 
+
 Setup Bench Fake Interfaces
     Set Log Level    DEBUG
     ${PLATFORMS}     Panduza Scan All Platforms    localhost    1883