ChannelsAPI.set_variable added

Cargo.toml

@@ -1,14 +1,14 @@
 [package]
 name = "asterisk-ari-client-rs"
-version = "0.1.0"
+version = "0.1.1"
 authors = ["abezecny"]
 edition = "2018"
 description = "Simple Asterisk ARI library"
 license = "MIT OR Apache-2.0"
 keywords = ["telephony", "asterisk"]
 categories = ["multimedia", "multimedia::audio"]
 repository = "https://github.com/jabber-tools/asterisk-ari-client-rs"
-documentation = "https://docs.rs/jabber-tools/0.1.0"
+documentation = "https://docs.rs/jabber-tools/0.1.1"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 

README.md

@@ -25,6 +25,7 @@ Apart from that following channels' operations are supported:
 * play
 * stop_play
 * get_variable
+* set_variable
 * hangup
 * continue_in_dialplan
 

src/apis/channels.rs

@@ -22,6 +22,9 @@ pub trait ChannelsAPI {
     /// Get the value of a channel variable
     async fn get_variable(&self, channel_id: &str, var_name: &str) -> Result<String>;
 
+    /// Get the value of a channel variable
+    async fn set_variable(&self, channel_id: &str, var_name: &str, var_value: &str) -> Result<()>;
+
     /// Hangs up the channel
     async fn hangup(&self, channel_id: &str) -> Result<()>;
 

src/client.rs

@@ -482,6 +482,23 @@ impl ChannelsAPI for AriClient {
         Ok(variable.value)
     }
 
+    async fn set_variable(&self, channel_id: &str, var_name: &str, var_value: &str) -> Result<()> {
+        let resp = HTTP_CLIENT
+            .post(format!(
+                "{}/channels/{}/variable?variable={}&value={}",
+                self.url, channel_id, var_name, var_value
+            ))
+            .headers(self.get_common_headers()?)
+            .send()
+            .await?;
+
+        let status = resp.status();
+        let body_str = resp.text().await?;
+
+        eval_status_code!(status, StatusCode::NO_CONTENT, Some(body_str));
+        Ok(())
+    }
+
     async fn hangup(&self, channel_id: &str) -> Result<()> {
         let resp = HTTP_CLIENT
             .delete(format!("{}/channels/{}", self.url, channel_id))