feat(virtual_terminal): added support for all the endpoints in the virtual terminal route

Author: morukele

src/endpoints/virtual_terminal.rs

@@ -7,7 +7,8 @@ use std::{marker::PhantomData, sync::Arc};
 use serde_json::json;
 
 use crate::{
-    HttpClient, PaystackAPIError, PaystackResult, Response, VirtualTerminalRequestData,
+    DestinationRequest, DestinationResponse, HttpClient, PaystackAPIError, PaystackResult,
+    Response, TransactionSplitResponseData, VirtualTerminalRequestData,
     VirtualTerminalResponseData, VirtualTerminalStatus,
 };
 
@@ -165,4 +166,120 @@ impl<T: HttpClient + Default> VirtualTerminalEndpoints<T> {
             Err(e) => Err(PaystackAPIError::VirtualTerminal(e.to_string())),
         }
     }
+
+    /// Add a destination (WhatsApp number) to a Virtual Terminal on your integration
+    ///
+    /// Takes in the following:
+    ///     - `code`: Code of the Virtual Terminal
+    ///     - `destinations`: A vector of `DestinationRequest` containing the notification recipients for payments to the Virtual Terminal.
+    pub async fn assign_virtual_terminal_destination(
+        &self,
+        code: String,
+        destinations: Vec<DestinationRequest>,
+    ) -> PaystackResult<Vec<DestinationResponse>> {
+        let url = format!("{}/{}/destination/assign", self.base_url, code);
+        let body = json!({
+            "destinations": destinations
+        });
+
+        let response = self.http.post(&url, &self.key, &body).await;
+
+        match response {
+            Ok(response) => {
+                let parsed_response: Response<Vec<DestinationResponse>> =
+                    serde_json::from_str(&response)
+                        .map_err(|e| PaystackAPIError::VirtualTerminal(e.to_string()))?;
+
+                Ok(parsed_response)
+            }
+            Err(e) => Err(PaystackAPIError::VirtualTerminal(e.to_string())),
+        }
+    }
+
+    /// Unassign a destination (WhatsApp Number) summary of transactions from a Virtual Terminal on your integration
+    ///
+    /// Takes in the following:
+    ///     - `code`: Code of the Virtual Terminal.
+    ///     - `targets`: A vector of destination targets to unassign.
+    pub async fn unassign_virtual_terminal_destination(
+        &self,
+        code: String,
+        targets: Vec<String>,
+    ) -> PaystackResult<PhantomData<String>> {
+        let url = format!("{}/{}/destination/unassign", self.base_url, code);
+        let body = json!({
+            "targets": targets
+        });
+
+        let response = self.http.post(&url, &self.key, &body).await;
+
+        match response {
+            Ok(response) => {
+                let parsed_response: Response<PhantomData<String>> =
+                    serde_json::from_str(&response)
+                        .map_err(|e| PaystackAPIError::VirtualTerminal(e.to_string()))?;
+
+                Ok(parsed_response)
+            }
+            Err(e) => Err(PaystackAPIError::VirtualTerminal(e.to_string())),
+        }
+    }
+
+    /// Add a split code to a Virtual Terminal on your integration
+    ///
+    /// Takes in the following:
+    ///     - `code`: Code of the Virtual Terminal
+    ///     - `split_code`: Split code to be added to the Virtual Terminal
+    pub async fn add_split_code_to_virtual_terminal(
+        &self,
+        code: String,
+        split_code: String,
+    ) -> PaystackResult<TransactionSplitResponseData> {
+        let url = format!("{}/{}/split_code", self.base_url, code);
+        let body = json!({
+            "split_code": split_code
+        });
+
+        let response = self.http.put(&url, &self.key, &body).await;
+
+        match response {
+            Ok(response) => {
+                let parsed_response: Response<TransactionSplitResponseData> =
+                    serde_json::from_str(&response)
+                        .map_err(|e| PaystackAPIError::VirtualTerminal(e.to_string()))?;
+
+                Ok(parsed_response)
+            }
+            Err(e) => Err(PaystackAPIError::VirtualTerminal(e.to_string())),
+        }
+    }
+
+    /// Remove a split code from a Virtual Terminal on your integration
+    ///
+    /// Takes in the following:
+    ///     - `code`: Code of the Virtual Terminal
+    ///     - `split_code`: Split code to be removed from the Virtual Terminal
+    pub async fn remove_split_code_from_virtual_terminal(
+        &self,
+        code: String,
+        split_code: String,
+    ) -> PaystackResult<PhantomData<String>> {
+        let url = format!("{}/{}/split_code", self.base_url, code);
+        let body = json!({
+            "split_code": split_code
+        });
+
+        let response = self.http.delete(&url, &self.key, &body).await;
+
+        match response {
+            Ok(response) => {
+                let parsed_response: Response<PhantomData<String>> =
+                    serde_json::from_str(&response)
+                        .map_err(|e| PaystackAPIError::VirtualTerminal(e.to_string()))?;
+
+                Ok(parsed_response)
+            }
+            Err(e) => Err(PaystackAPIError::VirtualTerminal(e.to_string())),
+        }
+    }
 }

src/models/transaction_split.rs

@@ -50,9 +50,12 @@ pub struct TransactionSplitResponseData {
     /// The subaccount ID of the bearer associated with the percentage split.
     pub bearer_subaccount: u32,
     /// The creation timestamp of the percentage split.
+    #[serde(rename = "createdAt")]
     pub created_at: Option<String>,
     /// The last update timestamp of the percentage split.
+    #[serde(rename = "updatedAt")]
     pub updated_at: Option<String>,
+    pub is_dynamic: Option<bool>,
     /// The list of subaccounts involved in the percentage split.
     pub subaccounts: Vec<SubaccountData>,
     /// The total count of subaccounts in the percentage split.

src/models/virtual_terminal.rs

@@ -60,11 +60,16 @@ pub struct VirtualTerminalResponseData {
 
 #[derive(Debug, Deserialize, Clone, Serialize, Default)]
 pub struct DestinationResponse {
+    pub integration: Option<u32>,
     pub target: Option<String>,
+    pub name: Option<String>,
     #[serde(rename = "type")]
     pub destination_type: Option<String>,
-    pub name: Option<String>,
+    pub id: Option<u32>,
+    #[serde(rename = "createdAt")]
     pub created_at: Option<String>,
+    #[serde(rename = "updatedAt")]
+    pub updated_at: Option<String>,
 }
 
 #[derive(Debug, Serialize, Deserialize, Clone)]