Merge pull request #54 from CoLearn-Dev/support-call-forwarding

Call forwarding

Author: stneng

Cargo.toml

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

README.md

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

proto

@@ -356,6 +356,19 @@ impl CoLink {
         Ok(())
     }
 
+    pub async fn import_forwarding_user_id(
+        &self,
+        user_id: &str,
+        forwarding_user_id: &str,
+    ) -> Result<(), Error> {
+        self.update_entry(
+            &format!("_internal:known_users:{}:forwarding_user_id", user_id),
+            forwarding_user_id.as_bytes(),
+        )
+        .await?;
+        Ok(())
+    }
+
     /// The default expiration time is 1 day later. If you want to specify an expiration time, use run_task_with_expiration_time instead.
     pub async fn run_task(
         &self,

src/application.rs

@@ -48,7 +48,7 @@ impl InstantServer {
                 .arg("bash -c \"$(curl -fsSL https://raw.githubusercontent.com/CoLearn-Dev/colinkctl/main/install_colink.sh)\"")
                 .env("COLINK_INSTALL_SERVER_ONLY", "true")
                 .env("COLINK_INSTALL_SILENT", "true")
-                .env("COLINK_SERVER_VERSION", "v0.3.2")
+                .env("COLINK_SERVER_VERSION", "v0.3.3")
                 .status()
                 .unwrap();
         }

src/extensions/instant_server.rs

@@ -21,4 +21,32 @@ impl crate::application::CoLink {
         self.wait_task(&task_id).await?;
         Ok(())
     }
+
+    pub async fn set_forwarding_user_id(&self, forwarding_user_id: &str) -> Result<(), Error> {
+        self.update_entry(
+            "_registry:forwarding_user_id",
+            forwarding_user_id.as_bytes(),
+        )
+        .await?;
+        let _ = async {
+            let registries = self.read_entry("_registry:registries").await?;
+            let registries: Registries = Message::decode(&*registries)?;
+            self.update_registries(&registries).await?;
+            Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
+        }
+        .await;
+        Ok(())
+    }
+
+    pub async fn unset_forwarding_user_id(&self) -> Result<(), Error> {
+        self.delete_entry("_registry:forwarding_user_id").await?;
+        let _ = async {
+            let registries = self.read_entry("_registry:registries").await?;
+            let registries: Registries = Message::decode(&*registries)?;
+            self.update_registries(&registries).await?;
+            Ok::<(), Box<dyn std::error::Error + Send + Sync + 'static>>(())
+        }
+        .await;
+        Ok(())
+    }
 }

src/extensions/registry.rs

@@ -6,7 +6,7 @@ PACKAGE_NAME="colink-server-linux-x86_64.tar.gz"
 if [ "$(uname)" == "Darwin" ]; then
     PACKAGE_NAME="colink-server-macos-x86_64.tar.gz"
 fi
-wget https://github.com/CoLearn-Dev/colink-server-dev/releases/download/v0.3.2/$PACKAGE_NAME
+wget https://github.com/CoLearn-Dev/colink-server-dev/releases/download/v0.3.3/$PACKAGE_NAME
 tar -xzf $PACKAGE_NAME
 touch user_init_config.toml # create an empty user init config to prevent automatically starting protocols when importing users.
 cd ..