Add 'delete file'. (#512)

Author: thovoll

sdk/storage/Cargo.toml

@@ -134,7 +134,7 @@ required-features=["blob"]
 name="data_lake_00_file_system"
 required-features=["data_lake"]
 [[example]]
-name="data_lake_01_file_create"
+name="data_lake_01_file_create_delete"
 required-features=["data_lake"]
 [[example]]
 name="data_lake_02_file_upload"

sdk/storage/examples/data_lake_01_file_create.rs renamed to sdk/storage/examples/data_lake_01_file_create_delete.rs

@@ -42,6 +42,12 @@ async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
         .await?;
     println!("create file response == {:?}\n", create_file_response);
 
+    println!("deleting file '{}'...", file_path);
+    let delete_file_response = file_system_client
+        .delete_file(Context::default(), file_path, FileDeleteOptions::default())
+        .await?;
+    println!("delete_file file response == {:?}\n", delete_file_response);
+
     println!("deleting file system...");
     let delete_fs_response = file_system_client.delete().execute().await?;
     println!("delete file system response == {:?}\n", delete_fs_response);

sdk/storage/src/data_lake/clients/file_system_client.rs

@@ -88,6 +88,25 @@ impl FileSystemClient {
         Ok(FileCreateResponse::try_from(response).await?)
     }
 
+    pub async fn delete_file(
+        &self,
+        ctx: Context,
+        file_path: &str,
+        options: FileDeleteOptions<'_>,
+    ) -> Result<FileDeleteResponse, crate::Error> {
+        let mut request = self.prepare_file_delete_request(file_path);
+        let contents = DataLakeContext {};
+        let mut pipeline_context = PipelineContext::new(ctx, contents);
+
+        options.decorate_request(&mut request)?;
+        let response = self
+            .pipeline()
+            .send(&mut pipeline_context, &mut request)
+            .await?;
+
+        Ok(FileDeleteResponse::try_from(response).await?)
+    }
+
     pub async fn rename_file(
         &self,
         ctx: Context,
@@ -201,6 +220,14 @@ impl FileSystemClient {
             .into()
     }
 
+    pub(crate) fn prepare_file_delete_request(&self, file_path: &str) -> azure_core::Request {
+        let uri = format!("{}/{}", self.url(), file_path);
+        http::request::Request::delete(uri)
+            .body(bytes::Bytes::new()) // Request builder requires a body here
+            .unwrap()
+            .into()
+    }
+
     pub(crate) fn prepare_file_rename_request(
         &self,
         destination_file_path: &str,

sdk/storage/src/data_lake/operations/file_delete.rs

@@ -0,0 +1,47 @@
+use azure_core::headers::CommonStorageResponseHeaders;
+use azure_core::prelude::ContentLength;
+use azure_core::prelude::IfMatchCondition;
+use std::convert::TryInto;
+
+use azure_core::{Request as HttpRequest, Response as HttpResponse};
+
+#[derive(Debug, Clone, Default)]
+pub struct FileDeleteOptions<'a> {
+    if_match_condition: Option<IfMatchCondition<'a>>,
+}
+
+impl<'a> FileDeleteOptions<'a> {
+    pub fn new() -> Self {
+        Self {
+            if_match_condition: None,
+        }
+    }
+
+    setters! {
+        if_match_condition: IfMatchCondition<'a> => Some(if_match_condition),
+    }
+
+    pub(crate) fn decorate_request(&self, req: &mut HttpRequest) -> Result<(), crate::Error> {
+        azure_core::headers::add_optional_header2(&self.if_match_condition, req)?;
+        azure_core::headers::add_mandatory_header2(&ContentLength::new(0), req)?; // Length is required for creating files
+
+        Ok(())
+    }
+}
+
+#[derive(Debug, Clone)]
+pub struct FileDeleteResponse {
+    pub common_storage_response_headers: CommonStorageResponseHeaders,
+}
+
+impl FileDeleteResponse {
+    pub async fn try_from(response: HttpResponse) -> Result<Self, crate::Error> {
+        let (_status_code, headers, _pinned_stream) = response.deconstruct();
+
+        let common_storage_response_headers = (&headers).try_into()?;
+
+        Ok(Self {
+            common_storage_response_headers,
+        })
+    }
+}

sdk/storage/src/data_lake/operations/mod.rs

@@ -4,10 +4,12 @@
 
 mod file_append;
 mod file_create;
+mod file_delete;
 mod file_flush;
 mod file_rename;
 
 pub use file_append::*;
 pub use file_create::*;
+pub use file_delete::*;
 pub use file_flush::*;
 pub use file_rename::*;

sdk/storage/tests/data_lake.rs

@@ -91,7 +91,7 @@ async fn test_data_lake_file_system_functions() -> Result<(), Box<dyn Error + Se
 }
 
 #[tokio::test]
-async fn test_data_lake_file_create_functions() -> Result<(), Box<dyn Error + Send + Sync>> {
+async fn test_data_lake_file_create_delete_functions() -> Result<(), Box<dyn Error + Send + Sync>> {
     let data_lake_client = create_data_lake_client().await.unwrap();
 
     let file_system_name = format!(
@@ -123,6 +123,10 @@ async fn test_data_lake_file_create_functions() -> Result<(), Box<dyn Error + Se
         .create_file(Context::default(), file_path, FileCreateOptions::default())
         .await?;
 
+    file_system_client
+        .delete_file(Context::default(), file_path, FileDeleteOptions::default())
+        .await?;
+
     file_system_client.delete().execute().await?;
 
     Ok(())