Merge pull request #111 from rascaraficci/bugfix/device-update-event

Changed to publish event for devices when they are indirectly updated

DeviceManager/TemplateHandler.py

@@ -6,7 +6,7 @@
 from sqlalchemy.sql import text, collate, func
 
 from DeviceManager.DatabaseHandler import db
-from DeviceManager.DatabaseModels import handle_consistency_exception, assert_template_exists
+from DeviceManager.DatabaseModels import handle_consistency_exception, assert_template_exists, assert_device_exists
 from DeviceManager.DatabaseModels import DeviceTemplate, DeviceAttr, DeviceTemplateMap
 from DeviceManager.SerializationModels import template_list_schema, template_schema
 from DeviceManager.SerializationModels import attr_list_schema, attr_schema
@@ -20,6 +20,10 @@
 
 from DeviceManager.Logger import Log
 from datetime import datetime
+
+from DeviceManager.BackendHandler import KafkaHandler
+from DeviceManager.DeviceHandler import serialize_full_device
+
 import time
 import json
 
@@ -264,7 +268,7 @@ def update_attr(attrs_from_db, attrs_from_request):
             attrs_from_db.static_value = attrs_from_request.get('static_value', None)
 
         def validate_attr(attr_from_request):
-            attr_schema.load(attr_from_request)    
+            attr_schema.load(attr_from_request)
 
         def analyze_attrs(attrs_from_db, attrs_from_request, parentAttr=None):
             for attr_from_db in attrs_from_db:
@@ -292,7 +296,7 @@ def analyze_attrs(attrs_from_db, attrs_from_request, parentAttr=None):
             LOGGER.debug(f" Adding new attribute {attr}")
             if "id" in attr:
                 del attr["id"]
-            child = DeviceAttr(template=old, **attr)    
+            child = DeviceAttr(template=old, **attr)
             db.session.add(child)
             if "metadata" in attr and attr["metadata"] is not None:
                 for metadata in attr["metadata"]:
@@ -313,7 +317,10 @@ def analyze_attrs(attrs_from_db, attrs_from_request, parentAttr=None):
                              .all()
 
         affected_devices = []
+        kafka_handler = KafkaHandler()
         for device in affected:
+            orm_device = assert_device_exists(device.device_id)
+            kafka_handler.update(serialize_full_device(orm_device, service), meta={"service": service})
             affected_devices.append(device.device_id)
 
         event = {

docs/kafka-messages.rst

@@ -108,7 +108,8 @@ And its attributes are:
 Update message
 --------------
 
-This message is published whenever a new device is updated.
+This message is published whenever a new device is directly or indirectly updated.
+The indirectly case happens when a template associated with the device is updated.
 Its payload looks very similar to device creation:
 
 .. code-block:: json