v0.1.9-rc1

- Improved ValueStore realtime update support
- Bugfixes and improvements

Author: anedyasystems

.gitignore

@@ -3,6 +3,8 @@ __pycache__/
 *.py[cod]
 *$py.class
 
+tests/test.py
+development/
 # Distribution / packaging
 .Python
 build/

HISTORY.md

@@ -1,5 +1,51 @@
 # Release History
 
+## 0.1.9
+- Bugfixes and improvements
+
+## 0.1.8
+- Support for realtime ValueStore Updates
+- Bugfixes
+
+## 0.1.7
+- Improves support for commands
+- Bugfixes
+- Documentation improvements
+
+## 0.1.6
+- Bug fixes
+- Added support for Command status update
+
+## 0.1.5
+- Bug fixes
+
+## 0.1.4
+- Bug fixes and improvement
+
+## 0.1.3
+- Data submission to Anedya
+- Log submission to Anedya
+- Time synchronization
+- Device Binding
+
+## 0.1.2
+- Bugfixes and improvements
+
+## 0.1.1
+- Bugfixes
+
+## 0.1.0
+- Introducing preliminary MQTT support for the Anedya SDK
+
+## 0.0.9
+- Updated dependencies
+
+## 0.0.8
+- Added support for Time Synchronization APIs
+
+## 0.0.7
+- Bug fixes and improvement
+
 ## 0.0.6
 - Introducing Millisecond level resolution
 - Streamlined Function Arguments

examples/submitdata_mqtt.py examples/submitFloat_data.pyexamples/submitdata_mqtt.py renamed to examples/submitFloat_data.py

@@ -5,9 +5,9 @@
 # Emulate Hardware Sensor?
 virtual_sensor = True
 # Set the ID of the physical device
-deviceID = "<PHYSICAL-DEVICE-ID>"
+deviceID = "PHYSICAL_DEVICE_ID"
 # Set the connection key for the device
-connectionKey = "<NODE-CONNECTION-KEY>"
+connectionKey = "CONNECTION_KEY"
 
 # Note: It is assumed that the humidity sensor is attached at GPIO23 of the Raspberry Pi
 
@@ -20,7 +20,7 @@
 def main():
     # Create a configuration object
     config = anedya.default_config()
-    config.connection_mode = anedya.ConnectionMode.MQTT
+    config.connection_mode = anedya.ConnectionMode.MQTT  # Set the connection mode, HTTP or MQTT
     # Set the config parameters
     config.set_deviceid(deviceID)
     config.set_connection_key(connectionKey)
@@ -30,11 +30,10 @@ def main():
 
     time.sleep(1)
     # Client is created, now connect with the MQTT server
-    client.connect()
+    client.connect()  # if connection mode is http so comment this line
 
     time.sleep(2)
-    print(client._mqttclient.is_connected())
-
+    
     if not virtual_sensor:
         for proc in psutil.process_iter():
             if proc.name() == "libgpiod_pulsein" or proc.name() == "libgpiod_pulsei":
@@ -86,8 +85,9 @@ def main():
         data.append(dp2)
 
         client.submit_data(data)
-        print("Data Pushed!")
+        print("Data pushed to Anedya!")
         data.reset_datapoints()
+        print("=============================")
         time.sleep(15)
 
     client.disconnect()

examples/submitdata_http.py

@@ -0,0 +1,36 @@
+import anedya
+import time
+
+# Set the ID of the physical device
+deviceID = "PHYSICAL_DEVICE_ID"
+# Set the connection key for the device
+connectionKey = "CONNECTION_KEY"
+
+
+def main():
+    config = anedya.default_config()
+    config.connection_mode = anedya.ConnectionMode.MQTT
+    config.set_deviceid(deviceID)
+    config.set_connection_key(connectionKey)
+    config.set_on_vsupdate(callback=on_VSUpdate_callback)
+
+    # Create a client
+    client = anedya.AnedyaClient(config)
+
+    time.sleep(1)
+    # Client is created, now connect with the MQTT server
+    client.connect()
+    time.sleep(2)
+
+    input("Press Enter to continue after sending command...\n")
+    print("Disconnecting")
+    client.disconnect()
+
+
+def on_VSUpdate_callback(vs):
+    print(f"Received VS updates from platform!")
+    print(f"Namespace: {vs.namespace}, Type: {vs.type}, Key: {vs.key}, Value: {vs.value}, Modified: {vs.modified}")
+    return
+
+if __name__ == '__main__':
+    main()

examples/valuestore_updates.py

@@ -1,6 +1,6 @@
 [metadata]
 name = anedya-dev-sdk
-version = 0.1.7
+version = 0.1.9
 url = https://github.com/anedyaio/anedya-dev-sdk-python
 author = Anedya Systems
 author_email = support@anedya.io
@@ -21,7 +21,7 @@ classifiers =
     Topic :: Software Development :: Libraries :: Python Modules
 project_urls =
     Documentation = https://docs.anedya.io
-    Release notes = https://github.com/anedyaio/anedya-dev-sdk-python
+    Release notes = https://github.com/anedyaio/anedya-dev-sdk-python/blob/main/HISTORY.md
     Source = https://github.com/anedyaio/anedya-dev-sdk-python
 
 [bdist_wheel]

setup.cfg

@@ -46,6 +46,7 @@ def __init__(self, config: AnedyaConfig):
             self.on_connect = config.on_connect
             self.on_disconnect = config.on_disconnect
             self.on_command = config.on_command
+            self.on_vsupdate = config.on_vsupdate
             self._mqttclient.on_connect = self._onconnect_handler
             self._mqttclient.on_disconnect = self._ondisconnect_handler
             # self._mqttclient.on_message = self.onmessage_handler
@@ -108,4 +109,4 @@ def disconnect(self):
     from .client.commandsNext import next_command
     from .client.timeSync import get_time
     from .client.mqttHandlers import _onconnect_handler, _ondisconnect_handler
-    from .client.callbacks import _error_callback, _response_callback, _command_callback
+    from .client.callbacks import _error_callback, _response_callback, _command_callback, _vsupdate_callback

src/anedya/anedya.py

@@ -41,7 +41,7 @@ def _bind_device_http(self, binding_secret: str, timeout: float | None = None) -
         jsonResponse = r.json()
         payload = json.loads(jsonResponse)
         if payload['success'] is not True:
-            raise AnedyaTxFailure(payload['error'], payload['errCode'])
+            raise AnedyaTxFailure(payload['error'], payload['errorcode'])
     except ValueError:
         raise AnedyaTxFailure(message="Invalid JSON response")
     return True
@@ -75,5 +75,5 @@ def _bind_device_mqtt(self, binding_secret: str, timeout: float | None = None):
     self._transactions.clear_transaction(tr)
     # Check if transaction is successful or not
     if data['success'] is not True:
-        raise AnedyaTxFailure(data['error'], data['errCode'])
+        raise AnedyaTxFailure(data['error'], data['errorcode'])
     return

src/anedya/client/bindDevice.py

@@ -1,5 +1,5 @@
 import json
-from ..models import CommandDetails
+from ..models import CommandDetails, VSUpdate
 
 
 def _response_callback(self, client, userdata, message):
@@ -32,3 +32,15 @@ def _command_callback(self, client, userdata, message):
     except Exception:
         pass
     return
+
+
+def _vsupdate_callback(self, client, userdata, message):
+    payload_data = json.loads(message.payload)
+    # This callback is called when a valuestore update is received.
+    # Call the client callback
+    try:
+        vsupdate = VSUpdate(payload_data)
+        self.on_vsupdate(vsupdate)
+    except Exception:
+        pass
+    return

src/anedya/client/callbacks.py

@@ -40,7 +40,7 @@ def _next_command_http(self, timeout: float | None = None) -> tuple[CommandDetai
         jsonResponse = r.json()
         payload = json.loads(jsonResponse)
         if payload['success'] is not True:
-            raise AnedyaTxFailure(payload['error'], payload['errCode'])
+            raise AnedyaTxFailure(payload['error'], payload['errorcode'])
         # Payload has success now create a CommandDetails object and return
         command = CommandDetails()
         command.id = uuid.UUID(payload["commandId"])
@@ -89,7 +89,7 @@ def _next_command_mqtt(self, timeout: float | None = None) -> tuple[CommandDetai
     self._transactions.clear_transaction(tr)
     # Check if transaction is successful or not
     if data['success'] is not True:
-        raise AnedyaTxFailure(data['error'], data['errCode'])
+        raise AnedyaTxFailure(data['error'], data['errorcode'])
     try:
         if data['available'] is not True:
             return None, None