rpc_wrappers: initial rpc_cloud support

Add initial support for queuing some commands through `rpc_cloud`.

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

Author: JordanYates

src/infuse_iot/rpc_wrappers/application_info.py

@@ -17,6 +17,9 @@ def __init__(self, _args):
     def request_struct(self):
         return self.request()
 
+    def request_json(self):
+        return {}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query current time ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/data_logger_state.py

@@ -24,6 +24,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.request(self.logger)
 
+    def request_json(self):
+        return {"logger": str(self.logger.value)}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query current time ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/kv_read.py

@@ -58,6 +58,9 @@ def request_struct(self):
         keys = (ctypes.c_uint16 * len(self.keys))(*self.keys)
         return bytes(self.request(len(self.keys))) + bytes(keys)
 
+    def request_json(self):
+        return {"num": str(len(self.keys)), "keys": [str(k) for k in self.keys]}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Invalid data buffer ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/last_reboot.py

@@ -17,6 +17,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.request()
 
+    def request_json(self):
+        return {}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query reboot info ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/lte_at_cmd.py

@@ -25,6 +25,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.args.cmd.encode("utf-8") + b"\x00"
 
+    def request_json(self):
+        return {"cmd": self.args.cmd}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to run command ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/lte_modem_info.py

@@ -1,15 +1,13 @@
 #!/usr/bin/env python3
 
-import ctypes
+# import ctypes
+import argparse
 import os
 
-import infuse_iot.generated.rpc_definitions as defs
-from infuse_iot.commands import InfuseRpcCommand
-
 from . import kv_read, lte_pdp_ctx
 
 
-class lte_modem_info(InfuseRpcCommand, defs.kv_read):
+class lte_modem_info(kv_read.kv_read):
     HELP = "Get LTE modem information"
     DESCRIPTION = "Get LTE modem information"
 
@@ -23,12 +21,8 @@ class response(kv_read.kv_read.response):
     def add_parser(cls, parser):
         return
 
-    def __init__(self, args):
-        self.keys = [40, 41, 42, 43, 44, 45]
-
-    def request_struct(self):
-        keys = (ctypes.c_uint16 * len(self.keys))(*self.keys)
-        return bytes(self.request(len(self.keys))) + bytes(keys)
+    def __init__(self, _args):
+        super().__init__(argparse.Namespace(keys=[40, 41, 42, 43, 44, 45]))
 
     def handle_response(self, return_code, response):
         if return_code != 0:

src/infuse_iot/rpc_wrappers/lte_state.py

@@ -80,6 +80,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.request()
 
+    def request_json(self):
+        return {}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query current time ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/time_get.py

@@ -17,6 +17,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.request()
 
+    def request_json(self):
+        return {}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query current time ({os.strerror(-return_code)})")

src/infuse_iot/rpc_wrappers/zbus_channel_state.py

@@ -63,6 +63,9 @@ def __init__(self, args):
     def request_struct(self):
         return self.request(self._channel.id)
 
+    def request_json(self):
+        return {"channel_id": str(self._channel.id)}
+
     def handle_response(self, return_code, response):
         if return_code != 0:
             print(f"Failed to query channel ({os.strerror(-return_code)})")