use async_trait::async_trait;
use thiserror::Error;
use crate::directory_sync::{DirectoryId, DirectorySync};
use crate::{ResponseExt, WorkOsError, WorkOsResult};
#[derive(Debug, Error)]
pub enum DeleteDirectoryError {}
impl From<DeleteDirectoryError> for WorkOsError<DeleteDirectoryError> {
fn from(err: DeleteDirectoryError) -> Self {
Self::Operation(err)
}
}
#[async_trait]
pub trait DeleteDirectory {
async fn delete_directory(
&self,
directory_id: &DirectoryId,
) -> WorkOsResult<(), DeleteDirectoryError>;
}
#[async_trait]
impl DeleteDirectory for DirectorySync<'_> {
async fn delete_directory(
&self,
directory_id: &DirectoryId,
) -> WorkOsResult<(), DeleteDirectoryError> {
let url = self
.workos
.base_url()
.join(&format!("/directories/{directory_id}"))?;
self.workos
.client()
.delete(url)
.bearer_auth(self.workos.key())
.send()
.await?
.handle_unauthorized_or_generic_error()
.await?;
Ok(())
}
}
#[cfg(test)]
mod test {
use matches::assert_matches;
use tokio;
use crate::directory_sync::DirectoryId;
use crate::{ApiKey, WorkOs};
use super::*;
#[tokio::test]
async fn it_calls_the_delete_directory_endpoint() {
let mut server = mockito::Server::new_async().await;
let workos = WorkOs::builder(&ApiKey::from("sk_example_123456789"))
.base_url(&server.url())
.unwrap()
.build();
server
.mock(
"DELETE",
"/directories/directory_01ECAZ4NV9QMV47GW873HDCX74",
)
.match_header("Authorization", "Bearer sk_example_123456789")
.with_status(202)
.create_async()
.await;
let result = workos
.directory_sync()
.delete_directory(&DirectoryId::from("directory_01ECAZ4NV9QMV47GW873HDCX74"))
.await;
assert_matches!(result, Ok(()));
}
}