rpc_wrappers: json handling

Add json handling for a number of RPCs.

Signed-off-by: Jordan Yates <jordan@embeint.com>

Author: JordanYates

src/infuse_iot/rpc_wrappers/application_info.py

@@ -35,3 +35,23 @@ def handle_response(self, return_code, response):
         print(f"\t     KV CRC: 0x{r.kv_crc:08x}")
         print(f"\t   O Blocks: {r.data_blocks_internal}")
         print(f"\t   E Blocks: {r.data_blocks_external}")
+
+    @classmethod
+    def handle_json_response(cls, response: dict) -> None:
+        rsp = defs.application_info.response(
+            int(response["application_id"]),
+            defs.rpc_struct_mcuboot_img_sem_ver(
+                int(response["version"]["major"]),
+                int(response["version"]["minor"]),
+                int(response["version"]["revision"]),
+                int(response["version"]["build_num"]),
+            ),
+            int(response["network_id"]),
+            int(response["uptime"]),
+            int(response["reboots"]),
+            int(response["kv_crc"]),
+            int(response["data_blocks_internal"]),
+            int(response["data_blocks_external"]),
+        )
+        x = cls({})
+        x.handle_response(0, rsp)

src/infuse_iot/rpc_wrappers/last_reboot.py

@@ -38,3 +38,18 @@ def handle_response(self, return_code, response):
         print(f"\t     Thread: {response.thread.decode('utf-8')}")
         for idx, val in enumerate(response.esf):
             print(f"\t    ESF[{idx:2d}]: 0x{val:08x}")
+
+    @classmethod
+    def handle_json_response(cls, response: dict) -> None:
+        rsp = defs.last_reboot.response(
+            int(response["reason"]),
+            int(response["epoch_time_source"]),
+            int(response["epoch_time"]),
+            int(response["hardware_flags"]),
+            int(response["uptime"]),
+            int(response["param_1"]),
+            int(response["param_2"]),
+        )
+        rsp.esf = [int(x) for x in response["esf"]]
+        x = cls({})
+        x.handle_response(0, rsp)

src/infuse_iot/rpc_wrappers/wifi_scan.py

@@ -41,3 +41,28 @@ def handle_response(self, return_code, response):
 
         headers = ["SSID", "BSSID", "Band", "Channel", "Security", "RSSI"]
         print(tabulate.tabulate(table, headers=headers))
+
+    @classmethod
+    def handle_json_response(cls, response: dict) -> None:
+        table = []
+        for network in response["networks"]:
+            bssid = ":".join([f"{int(b):02x}" for b in network["bssid"]])
+            try:
+                security = str(z_wifi.SecurityType(int(network["security"])))
+            except ValueError:
+                security = f"Unknown ({network['security']})"
+
+            table.append(
+                [
+                    network["ssid"],
+                    bssid,
+                    str(z_wifi.FrequencyBand(int(network["band"]))),
+                    network["channel"],
+                    security,
+                    f"{network['rssi']} dBm",
+                ]
+            )
+
+        headers = ["SSID", "BSSID", "Band", "Channel", "Security", "RSSI"]
+        print(f"Total Networks: {response['network_count']}")
+        print(tabulate.tabulate(table, headers=headers))