TELEMETRY-2: Dynamic telemetry markers for Dynamic Tables in Telemetry

Description:
Introduced marker type DataModelTable for dynamic tables in telemetry.

Enhanced T2 agent to resolve and collect data from all instances of multi-instance object tables when dynamic markers are configured.

Added logic to parse DataModelTable, filter markers based on telemetry profile configuration, and encode them in telemetry reports after collection, ensuring telemetry reports include per-instance data for configured dynamic markers.

Added support for an "index" parameter in configuration to restrict data collection to specific indexes if required.

Reason for change:
Enable telemetry to capture dynamic, per-instance data from tables (e.g., Host table, Wi-Fi associated devices) where indexes are not fixed, ensuring richer and more flexible telemetry collection.

Signed-off-by: onkar.panchare1 <onkar.panchare@telekom-digital.com>

Author: onkar-panchare1

schemas/t2_reportProfileSchema.schema.json

@@ -95,6 +95,44 @@
                         }
                     }                  
                 ]
+            },
+            "dataModelSimple": {
+                "title": "\"dataModel\" Parameter (restricted for use in dataModelTable)",
+                "type": "object",
+                "properties": {
+                "type": { "type": "string", "const": "dataModel" },
+                "reference": { "type": "string" }
+                },
+                "required": ["type", "reference"],
+                "additionalProperties": false
+            },
+            "dataModelTable": {
+                "title": "\"dataModelTable\" Parameter",
+                "type": "object",
+                "properties": {
+                "type": { "type": "string", "const": "dataModelTable" },
+                "reference": {
+                    "type": "string",
+                    "pattern": ".*\\.$",
+                    "description": "Reference must end with a dot '.'"
+                },
+                "index": {
+                    "type": "string",
+                    "pattern": "^(\\d+(-\\d+)?)(,(\\d+(-\\d+)?))*$",
+                    "description": "Comma separated numbers, ranges (e.g. 1-4), or combinations (e.g. 1,2,5-7)."
+                },
+                "Parameter": {
+                    "type": "array",
+                    "items": {
+                    "oneOf": [
+                        { "$ref": "#/definitions/parmDefinitions/properties/dataModelSimple" },
+                        { "$ref": "#/definitions/parmDefinitions/properties/dataModelTable" }
+                    ]
+                    }
+                }
+                },
+                "required": ["type", "reference", "Parameter"],
+                "additionalProperties": false
             }   
         }     
     },
@@ -234,7 +272,8 @@
                 "oneOf": [
                     { "$ref": "#/definitions/parmDefinitions/properties/grep", "title": "grep" },
                     { "$ref": "#/definitions/parmDefinitions/properties/event", "title": "event" },
-                    { "$ref": "#/definitions/parmDefinitions/properties/dataModel", "title": "dataModel" }
+                    { "$ref": "#/definitions/parmDefinitions/properties/dataModel", "title": "dataModel" },
+                    { "$ref": "#/definitions/parmDefinitions/properties/dataModelTable", "title": "dataModelTable" }
                     ]
             },
             "description": "An array of objects which defines the data to be included in the generated report. Each object defines the type of data, the source of the data and an optional name to be used as the name (marker) for this data in the generated report. "

source/bulkdata/profile.c

@@ -29,6 +29,7 @@
 #include "t2markers.h"
 #include "t2log_wrapper.h"
 #include "busInterface.h"
+#include "ccspinterface.h"
 #include "curlinterface.h"
 #include "rbusmethodinterface.h"
 #include "scheduler.h"
@@ -195,6 +196,10 @@ static void freeProfile(void *data)
             Vector_Destroy(profile->cachedReportList, free);
             profile->cachedReportList = NULL;
         }
+        if(profile->dataModelTableList)
+        {
+            Vector_Destroy(profile->dataModelTableList, freeDataModelTable);
+        }
         if(profile->jsonReportObj)
         {
             cJSON_Delete(profile->jsonReportObj);
@@ -445,7 +450,14 @@ static void* CollectAndReport(void* data)
                     profileParamVals = getProfileParameterValues(profile->paramList, count);
                     if(profileParamVals != NULL)
                     {
-                        encodeParamResultInJSON(valArray, profile->paramList, profileParamVals);
+                        if (Vector_Size(profile->dataModelTableList) > 0)
+                        {
+                            encodeParamResultInJSON(valArray, profile->paramList, profileParamVals, profile->dataModelTableList);
+                        }
+                        else
+                        {
+                            encodeParamResultInJSON(valArray, profile->paramList, profileParamVals, NULL);
+                        }
                     }
                     Vector_Destroy(profileParamVals, freeProfileValues);
                 }

source/bulkdata/profile.h

@@ -80,6 +80,7 @@ typedef struct _Profile
     Vector *gMarkerList;
     Vector *topMarkerList;
     Vector *cachedReportList;
+    Vector *dataModelTableList;   // List of DataModelTable
     cJSON *jsonReportObj;
     pthread_t reportThread;
     pthread_mutex_t triggerCondMutex;

source/bulkdata/profilexconf.c

@@ -280,7 +280,7 @@ static void* CollectAndReportXconf(void* data)
                 T2Info("Fetch complete for TR-181 Object/Parameter Values for parameters \n");
                 if(profileParamVals != NULL)
                 {
-                    encodeParamResultInJSON(valArray, profile->paramList, profileParamVals);
+                    encodeParamResultInJSON(valArray, profile->paramList, profileParamVals, NULL);
                 }
                 Vector_Destroy(profileParamVals, freeProfileValues);
             }