+
+
+def deep_update_dict(data, updated_data):
+ if isinstance(data, list):
+ processed_items_data = []
+ for index, item in enumerate(data):
+ processed_items_data.append(deep_update_dict(item, updated_data[index]))
+ return processed_items_data
+
+ if isinstance(data, dict):
+ for key in data.keys():
+ if key in updated_data:
+ if not isinstance(data[key], dict) and not isinstance(data[key], list):
+ data[key] = updated_data[key]
+ else:
+ data[key] = deep_update_dict(data[key], updated_data[key])
+ return data
+
+ return data
+
+
+def cef_event(cef_logger, cef_fields):
+ for key, value in cef_fields.items():
+ cef_logger.set_field(key, value)
+
+
+def cef_event_builder(config):
+ cef_logger = CEFEvent()
+ cef_fields = {
+ "version": config["version"],
+ "deviceVendor": config["deviceVendor"],
+ "deviceProduct": config["deviceProduct"],
+ "deviceVersion": get_version(),
+ "message": "CEF Logger",
+ "sourceUserName": "admin",
+ "severity": 1,
+ }
+ cef_event(cef_logger, cef_fields)
+ cef_logger.build_cef()
+ return cef_logger
+
+
+def get_version():
+ osm_version = version.split("+")
+ return osm_version[0]