Changes to send response in the fireboltInteraction logs

core/main/src/firebolt/rpc_router.rs

@@ -180,7 +180,7 @@ impl RpcRouter {
 
                 Self::log_rdk_telemetry_message(&app_id, &method, status_code, now - start);
 
-                TelemetryBuilder::send_fb_tt(&state, req.clone(), now - start, success);
+                TelemetryBuilder::send_fb_tt(&state, req.clone(), now - start, success, &msg);
 
                 return_api_message_for_transport(session, msg, state).await;
             }

core/main/src/processor/metrics_processor.rs

@@ -263,7 +263,7 @@ impl ExtnRequestProcessor for OpMetricsProcessor {
                 .operational_telemetry_listener(&requestor, true),
             OperationalMetricRequest::UnSubscribe => state
                 .metrics
-                .operational_telemetry_listener(&requestor, true),
+                .operational_telemetry_listener(&requestor, false),
             _ => (),
         }
         Self::ack(state.get_client().get_extn_client(), msg)

core/main/src/service/telemetry_builder.rs

@@ -28,7 +28,7 @@ use ripple_sdk::{
                 TelemetrySystemError,
             },
         },
-        gateway::rpc_gateway_api::{CallContext, RpcRequest},
+        gateway::rpc_gateway_api::{ApiMessage, CallContext, RpcRequest},
     },
     chrono::{DateTime, Utc},
     extn::client::extn_client::ExtnClient,
@@ -181,7 +181,13 @@ impl TelemetryBuilder {
         }
     }
 
-    pub fn send_fb_tt(ps: &PlatformState, req: RpcRequest, tt: i64, success: bool) {
+    pub fn send_fb_tt(
+        ps: &PlatformState,
+        req: RpcRequest,
+        tt: i64,
+        success: bool,
+        resp: &ApiMessage,
+    ) {
         let ctx = req.ctx;
         let method = req.method;
         let params = if let Ok(mut p) = serde_json::from_str::<Vec<Value>>(&req.params_json) {
@@ -195,6 +201,7 @@ impl TelemetryBuilder {
         } else {
             None
         };
+        let response = serde_json::to_string(resp).unwrap_or_default();
         if let Err(e) = Self::send_telemetry(
             ps,
             TelemetryPayload::FireboltInteraction(FireboltInteraction {
@@ -205,6 +212,7 @@ impl TelemetryBuilder {
                 method,
                 params,
                 success,
+                response,
             }),
         ) {
             error!("send_telemetry={:?}", e)

core/sdk/src/api/firebolt/fb_telemetry.rs

@@ -150,6 +150,7 @@ pub struct FireboltInteraction {
     pub success: bool,
     pub ripple_session_id: String,
     pub app_session_id: Option<String>,
+    pub response: String,
 }
 
 #[derive(Debug, PartialEq, Serialize, Deserialize, Clone)]