feat: #ITD-I25: eddited response data

Author: naveenhiremath28

api-service/src/controllers/DataOut/DataOutController.ts

@@ -10,6 +10,7 @@ import { datasetService } from "../../services/DatasetService";
 import { obsrvError } from "../../types/ObsrvError";
 
 export const apiId = "api.data.out";
+export const query_data = {"data": {}};
 
 const requestValidation = async (req: Request) => {
     const datasourceKey = req.params?.dataset_id;
@@ -34,6 +35,7 @@ const dataOut = async (req: Request, res: Response) => {
 
     if (isValidQuery === true && _.isObject(query)) {
         const result = await executeNativeQuery(query);
+        _.set(query_data, "data", result.data);
         logger.info({ apiId, msgid, requestBody, datasetId, message: "Native query executed successfully" })
         return ResponseHandler.successResponse(req, res, {
             status: 200, data: result?.data
@@ -42,6 +44,7 @@ const dataOut = async (req: Request, res: Response) => {
 
     if (isValidQuery === true && _.isString(query)) {
         const result = await executeSqlQuery({ query })
+        _.set(query_data, "data", result.data);
         logger.info({ apiId, msgid, requestBody, datasetId, message: "SQL query executed successfully" })
         return ResponseHandler.successResponse(req, res, {
             status: 200, data: result?.data

api-service/src/services/telemetry.ts

@@ -7,6 +7,7 @@ import { OTelService } from "./otel/OTelService";
 import { Parser } from "node-sql-parser";
 import { datasetService } from "./DatasetService";
 import { result_data } from "../controllers/QueryWrapper/SqlQueryWrapper";
+import { query_data } from "../controllers/DataOut/DataOutController";
 
 const {env, version} = _.pick(appConfig, ["env","version"])
 const telemetryTopic = _.get(appConfig, "telemetry_dataset");
@@ -293,10 +294,10 @@ export const getFilterValue = (data: any) => {
 export const setLogResponse = (telemetryLogEvent: any, request: Request, response: Response, ast: any) => {
     const logEvent: any = _.get(request, "logEvent") || {};
     const size = response.getHeaders()["content-length"];
-    const result : any = _.get(result_data, "data"); 
+    const result : any =  _.get(result_data, "data") || _.get(query_data, "data"); 
     _.set(telemetryLogEvent, "edata.query_metadata.response.size", !isNaN(Number(size)) ? Number(size) : size);
     _.set(telemetryLogEvent, "edata.query_metadata.response.duration", Date.now() - logEvent.ets);
-    JSON.parse(appConfig.telemetry_log).response_data && _.set(telemetryLogEvent, "edata.query_metadata.response.data", getResponseData(result, ast, response));
+    JSON.parse(appConfig.telemetry_log).response_data && _.set(telemetryLogEvent, "edata.query_metadata.response.data", !_.isEmpty(result) ? getResponseData(result, ast, response) : []);
 }
 
 export const getMetrics = (columns: any) => {