Draft: Calling support

src/push_service/calling.rs

@@ -0,0 +1,41 @@
+use super::{HttpAuthOverride, PushService, ReqwestExt, ServiceError};
+use crate::configuration::Endpoint;
+use reqwest::Method;
+use serde::Deserialize;
+
+#[derive(Debug, Clone, Deserialize)]
+#[serde(rename_all = "camelCase")]
+pub struct TurnServerInfo {
+    pub username: String,
+    pub password: String,
+    pub hostname: Option<String>,
+    pub urls: Vec<String>,
+    #[serde(default)]
+    pub urls_with_ips: Vec<String>,
+}
+
+impl PushService {
+    pub async fn get_turn_server_info(
+        &mut self,
+    ) -> Result<Vec<TurnServerInfo>, ServiceError> {
+        #[derive(Debug, Deserialize)]
+        #[serde(rename_all = "camelCase")]
+        struct GetRelaysResponse {
+            relays: Vec<TurnServerInfo>,
+        }
+
+        Ok(self
+            .request(
+                Method::GET,
+                Endpoint::service("/v2/calling/relays"),
+                HttpAuthOverride::NoOverride,
+            )?
+            .send()
+            .await?
+            .service_error_for_status()
+            .await?
+            .json::<GetRelaysResponse>()
+            .await?
+            .relays)
+    }
+}

src/push_service/mod.rs

@@ -24,6 +24,7 @@ pub const KEEPALIVE_TIMEOUT_SECONDS: Duration = Duration::from_secs(55);
 pub const DEFAULT_DEVICE_ID: u32 = 1;
 
 mod account;
+mod calling;
 mod cdn;
 mod error;
 mod keys;
@@ -34,6 +35,7 @@ mod response;
 mod stickers;
 
 pub use account::*;
+pub use calling::*;
 pub use cdn::*;
 pub use error::*;
 pub use keys::*;