Merge pull request #17 from CoLearn-Dev/0.1.20

- update proto

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "colink"
-version = "0.1.19"
+version = "0.1.20"
 edition = "2021"
 description = "CoLink Rust SDK"
 license = "MIT"

README.md

@@ -9,7 +9,7 @@ CoLink SDK helps both application adnd protocol developers access the functional
 Add this to your Cargo.toml:
 ```toml
 [dependencies]
-colink = "0.1.19"
+colink = "0.1.20"
 ```
 
 ## Getting Started

examples/user_start_protocol_operator.rs

@@ -9,7 +9,9 @@ async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync + 'static>
     let protocol_name = &args[2];
     let user_id = decode_jwt_without_validation(jwt).unwrap().user_id;
     let cl = CoLink::new(addr, jwt);
-    let instance_id = cl.start_protocol_operator(protocol_name, &user_id).await?;
+    let instance_id = cl
+        .start_protocol_operator(protocol_name, &user_id, false)
+        .await?;
     println!("Instance id: {}", instance_id);
 
     Ok(())

src/application.rs

@@ -419,14 +419,15 @@ impl CoLink {
         &self,
         protocol_name: &str,
         user_id: &str,
+        upgrade: bool,
     ) -> Result<String, Error> {
         let mut client = self._grpc_connect(&self.core_addr).await?;
         let request = generate_request(
             &self.jwt,
-            ProtocolOperatorInstance {
+            StartProtocolOperatorRequest {
                 protocol_name: protocol_name.to_string(),
                 user_id: user_id.to_string(),
-                ..Default::default()
+                upgrade,
             },
         );
         let response = client.start_protocol_operator(request).await?;
@@ -438,9 +439,8 @@ impl CoLink {
         let mut client = self._grpc_connect(&self.core_addr).await?;
         let request = generate_request(
             &self.jwt,
-            ProtocolOperatorInstance {
+            ProtocolOperatorInstanceId {
                 instance_id: instance_id.to_string(),
-                ..Default::default()
             },
         );
         let response = client.stop_protocol_operator(request).await?;

src/protocol.rs

@@ -166,7 +166,7 @@ pub fn _protocol_start(
         let cl = cl.clone();
         if protocol_and_role.ends_with(":@init") {
             let protocol_name = protocol_and_role[..protocol_and_role.len() - 6].to_string();
-            let _ = tokio::runtime::Builder::new_multi_thread()
+            tokio::runtime::Builder::new_multi_thread()
                 .enable_all()
                 .build()
                 .unwrap()
@@ -188,14 +188,14 @@ pub fn _protocol_start(
                     }
                     cl.unlock(lock).await?;
                     Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
-                });
+                })?;
         } else {
             protocols.push(protocol_and_role[..protocol_and_role.rfind(':').unwrap()].to_string());
             operator_funcs.insert(protocol_and_role, user_func);
         }
     }
     let cl_clone = cl.clone();
-    let _ = tokio::runtime::Builder::new_multi_thread()
+    tokio::runtime::Builder::new_multi_thread()
         .enable_all()
         .build()
         .unwrap()
@@ -206,7 +206,7 @@ pub fn _protocol_start(
                 cl_clone.update_entry(&is_initialized_key, &[1]).await?;
             }
             Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
-        });
+        })?;
     for (protocol_and_role, user_func) in operator_funcs {
         let cl = cl.clone();
         thread::spawn(|| {