deprecate set(get)_variable

Author: stneng

examples/protocol_variable_transfer.rs

@@ -11,7 +11,7 @@ impl ProtocolEntry for Initiator {
         participants: Vec<Participant>,
     ) -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> {
         println!("initiator");
-        cl.set_variable("output", &param, &[participants[1].clone()])
+        cl.send_variable("output", &param, &[participants[1].clone()])
             .await?;
         Ok(())
     }
@@ -26,7 +26,7 @@ impl ProtocolEntry for Receiver {
         param: Vec<u8>,
         participants: Vec<Participant>,
     ) -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>> {
-        let msg = cl.get_variable("output", &participants[0]).await?;
+        let msg = cl.receive_variable("output", &participants[0]).await?;
         println!("{}", String::from_utf8_lossy(&msg));
         cl.create_entry(&format!("tasks:{}:output", cl.get_task_id()?), &msg)
             .await?;

src/extensions/variable_transfer/p2p_inbox.rs

@@ -165,7 +165,7 @@ impl crate::application::CoLink {
             .contains_key(&receiver.user_id)
         {
             let inbox = self
-                .get_variable_with_remote_storage("inbox", receiver)
+                .receive_variable_with_remote_storage("inbox", receiver)
                 .await?;
             let inbox: VTInbox = serde_json::from_slice(&inbox)?;
             let inbox = if inbox.addr.is_empty() {
@@ -287,7 +287,7 @@ impl crate::application::CoLink {
                         .clone(),
                 }
             };
-            self.set_variable_with_remote_storage(
+            self.send_variable_with_remote_storage(
                 "inbox",
                 &serde_json::to_vec(&vt_inbox)?,
                 &[sender.clone()],

tests/test_protocol_variable_transfer.rs

@@ -15,10 +15,14 @@ impl ProtocolEntry for Initiator {
         for i in 0..8 {
             let key = &format!("output{}", i);
             let key2 = &format!("output_remote_storage{}", i);
-            cl.set_variable(key, &param, &participants[1..participants.len()])
-                .await?;
-            cl.set_variable_with_remote_storage(key2, &param, &participants[1..participants.len()])
+            cl.send_variable(key, &param, &participants[1..participants.len()])
                 .await?;
+            cl.send_variable_with_remote_storage(
+                key2,
+                &param,
+                &participants[1..participants.len()],
+            )
+            .await?;
         }
         Ok(())
     }
@@ -36,11 +40,11 @@ impl ProtocolEntry for Receiver {
         for i in 0..8 {
             let key = &format!("output{}", i);
             let key2 = &format!("output_remote_storage{}", i);
-            let msg = cl.get_variable(key, &participants[0]).await?;
+            let msg = cl.receive_variable(key, &participants[0]).await?;
             cl.create_entry(&format!("tasks:{}:output{}", cl.get_task_id()?, i), &msg)
                 .await?;
             let msg = cl
-                .get_variable_with_remote_storage(key2, &participants[0])
+                .receive_variable_with_remote_storage(key2, &participants[0])
                 .await?;
             cl.create_entry(
                 &format!("tasks:{}:output_remote_storage{}", cl.get_task_id()?, i),