Naveen 2976

core/sdk/src/utils/channel_utils.rs

@@ -23,6 +23,7 @@ pub async fn mpsc_send_and_log<T: std::fmt::Debug>(
     message: T,
     channel_id: &str,
 ) {
+    println!("@@@NNA....mpsc send fn");
     match tx.send(message).await {
         Ok(_) => {
             trace!("Successfully sent message through mpsc channel")

device/thunder/src/bootstrap/boot_thunder_channel.rs

@@ -17,18 +17,13 @@
 
 use thunder_ripple_sdk::{
     bootstrap::boot_thunder::boot_thunder,
-    client::plugin_manager::{ThunderPluginBootParam, ThunderPluginParam},
     ripple_sdk::{extn::client::extn_client::ExtnClient, log::info},
 };
 
 pub async fn boot_thunder_channel(state: ExtnClient) {
     info!("Booting thunder");
     let _ = boot_thunder(
         state,
-        ThunderPluginBootParam {
-            activate_on_boot: ThunderPluginParam::Default,
-            expected: ThunderPluginParam::Default,
-        },
     )
     .await;
 }

device/thunder_ripple_sdk/src/bootstrap/boot_thunder.rs

@@ -17,7 +17,7 @@
 
 use crate::{
     bootstrap::setup_thunder_processors::SetupThunderProcessor,
-    client::plugin_manager::ThunderPluginBootParam, thunder_state::ThunderBootstrapStateWithClient,
+    thunder_state::ThunderBootstrapStateWithClient,
 };
 use ripple_sdk::{
     api::manifest::device_manifest::DeviceManifest,
@@ -45,7 +45,6 @@ fn gateway_default() -> String {
 
 pub async fn boot_thunder(
     ext_client: ExtnClient,
-    _plugin_param: ThunderPluginBootParam,
     device_manifest: &DeviceManifest,
 ) -> Option<ThunderBootstrapStateWithClient> {
     info!("Booting thunder initiated");
@@ -94,16 +93,8 @@ pub async fn boot_thunder(
             gateway_url.set_host(Some(&host_override)).ok();
         }
 
-        if let Ok(thndr_client) = ThunderClientBuilder::start_thunder_client(
-            gateway_url.clone(),
-            None,
-            None,
-            None,
-            None,
-            true,
-            status_check,
-        )
-        .await
+        if let Ok(thndr_client) =
+            ThunderClientBuilder::start_thunder_client(gateway_url.clone(), status_check).await
         {
             let thunder_state = ThunderState::new(ext_client.clone(), thndr_client);
 

device/thunder_ripple_sdk/src/client/device_operator.rs

@@ -36,7 +36,7 @@ pub trait DeviceOperator: Clone {
         handler: mpsc::Sender<DeviceResponseMessage>,
     ) -> Result<DeviceResponseMessage, RecvError>;
 
-    async fn unsubscribe(&self, request: DeviceUnsubscribeRequest);
+    //async fn unsubscribe(&self, request: DeviceUnsubscribeRequest); //not used anywhere commented out for now.
 }
 
 #[derive(Debug, Clone)]