#[cfg(test)]
mod test;
use bson::{bson, doc};
use crate::{
cmap::{Command, CommandResponse, StreamDescription},
error::Result,
operation::{append_options, Operation, WriteConcernOnlyBody},
options::DropDatabaseOptions,
};
#[derive(Debug)]
pub(crate) struct DropDatabase {
target_db: String,
options: Option<DropDatabaseOptions>,
}
impl DropDatabase {
#[cfg(test)]
fn empty() -> Self {
Self::new(String::new(), None)
}
pub(crate) fn new(target_db: String, options: Option<DropDatabaseOptions>) -> Self {
Self { target_db, options }
}
}
impl Operation for DropDatabase {
type O = ();
const NAME: &'static str = "dropDatabase";
fn build(&self, description: &StreamDescription) -> Result<Command> {
let mut body = doc! {
Self::NAME: 1,
};
append_options(&mut body, self.options.as_ref())?;
Ok(Command::new(
Self::NAME.to_string(),
self.target_db.clone(),
body,
))
}
fn handle_response(&self, response: CommandResponse) -> Result<Self::O> {
response.body::<WriteConcernOnlyBody>()?.validate()
}
}