Add 'get_status' to datalake file client

sdk/storage_datalake/src/clients/file_client.rs

@@ -118,6 +118,11 @@ impl FileClient {
         HeadPathBuilder::new(self.clone(), self.file_system_client.context.clone())
     }
 
+    pub fn get_status(&self) -> HeadPathBuilder<Self> {
+        HeadPathBuilder::new(self.clone(), self.file_system_client.context.clone())
+            .action(PathGetPropertiesAction::GetStatus)
+    }
+
     pub fn set_properties(&self, properties: Properties) -> PatchPathBuilder<Self> {
         PatchPathBuilder::new(self.clone(), self.file_system_client.context.clone())
             .properties(properties)

sdk/storage_datalake/src/operations/path_head.rs

@@ -87,7 +87,7 @@ pub struct HeadPathResponse {
     pub common_storage_response_headers: CommonStorageResponseHeaders,
     pub etag: String,
     pub last_modified: DateTime<Utc>,
-    pub properties: Properties,
+    pub properties: Option<Properties>,
 }
 
 impl HeadPathResponse {
@@ -98,7 +98,7 @@ impl HeadPathResponse {
             common_storage_response_headers: (&headers).try_into()?,
             etag: etag_from_headers(&headers)?,
             last_modified: last_modified_from_headers(&headers)?,
-            properties: (&headers).try_into()?,
+            properties: (&headers).try_into().ok(),
         })
     }
 }

sdk/storage_datalake/tests/files.rs

@@ -1,6 +1,6 @@
 #![cfg(feature = "mock_transport_framework")]
 use azure_storage_datalake::Properties;
-use std::error::Error;
+use std::{assert_eq, assert_ne, error::Error};
 
 mod setup;
 
@@ -162,7 +162,7 @@ async fn file_rename() -> Result<(), Box<dyn Error + Send + Sync>> {
     let renamed_file_properties = file_client3.get_properties().into_future().await?;
 
     // when renaming a file, the source file properties should be propagated
-    assert_eq!(renamed_file_properties.properties, file_properties);
+    assert_eq!(renamed_file_properties.properties, Some(file_properties));
     assert_ne!(
         renamed_file_properties.properties,
         original_target_file_properties.properties
@@ -176,3 +176,48 @@ async fn file_rename() -> Result<(), Box<dyn Error + Send + Sync>> {
 
     Ok(())
 }
+
+#[tokio::test]
+async fn file_get_properties() -> Result<(), Box<dyn Error + Send + Sync>> {
+    let data_lake_client = setup::create_data_lake_client("datalake_file_properties")
+        .await
+        .unwrap();
+
+    let file_system_name = "azurerustsdk-datalake-file-get-properties";
+    let file_system_client = data_lake_client
+        .clone()
+        .into_file_system_client(file_system_name.to_string());
+
+    let create_fs_response = file_system_client.create().into_future().await?;
+    assert!(
+        create_fs_response.namespace_enabled,
+        "namespace should be enabled"
+    );
+
+    let file_path = "some/path/e2etest-file.txt";
+    let file_client = file_system_client.get_file_client(file_path);
+
+    file_client.create().into_future().await?;
+
+    let mut file_properties = Properties::new();
+    file_properties.insert("AddedVia", "Azure SDK for Rust");
+
+    file_client
+        .create()
+        .properties(file_properties.clone())
+        .into_future()
+        .await?;
+
+    // Get properties
+    let file_properties = file_client.get_properties().into_future().await?;
+    assert!(file_properties.properties.is_some());
+
+    // Get status (ie: only system-defined properties)
+    let file_properties = file_client.get_status().into_future().await?;
+    assert!(!file_properties.properties.is_some());
+
+    // Cleanup
+    file_system_client.delete().into_future().await?;
+
+    Ok(())
+}

test/transactions/datalake_file_properties/0_request.json

@@ -0,0 +1,12 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties?resource=filesystem",
+  "method": "PUT",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "content-length": "0",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:46 GMT",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/0_response.json

@@ -0,0 +1,14 @@
+{
+  "status": 201,
+  "headers": {
+    "content-length": "0",
+    "date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "etag": "\"0x8DA1BD718A4B558\"",
+    "last-modified": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-namespace-enabled": "true",
+    "x-ms-request-id": "def5aa2e-901f-0073-67bf-4d3635000000",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/1_request.json

@@ -0,0 +1,12 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties/some/path/e2etest-file.txt?resource=file",
+  "method": "PUT",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "content-length": "0",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/1_response.json

@@ -0,0 +1,14 @@
+{
+  "status": 201,
+  "headers": {
+    "content-length": "0",
+    "date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "etag": "\"0x8DA1BD718F18E95\"",
+    "last-modified": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-request-id": "def5aa30-901f-0073-69bf-4d3635000000",
+    "x-ms-request-server-encrypted": "true",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/2_request.json

@@ -0,0 +1,13 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties/some/path/e2etest-file.txt?resource=file",
+  "method": "PUT",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "content-length": "0",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "x-ms-properties": "AddedVia=QXp1cmUgU0RLIGZvciBSdXN0",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/2_response.json

@@ -0,0 +1,14 @@
+{
+  "status": 201,
+  "headers": {
+    "content-length": "0",
+    "date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "etag": "\"0x8DA1BD71918DC66\"",
+    "last-modified": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-request-id": "def5aa32-901f-0073-6bbf-4d3635000000",
+    "x-ms-request-server-encrypted": "true",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/3_request.json

@@ -0,0 +1,11 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties/some/path/e2etest-file.txt",
+  "method": "HEAD",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/3_response.json

@@ -0,0 +1,24 @@
+{
+  "status": 200,
+  "headers": {
+    "accept-ranges": "bytes",
+    "content-length": "0",
+    "content-type": "application/octet-stream",
+    "date": "Mon, 11 Apr 2022 16:19:48 GMT",
+    "etag": "\"0x8DA1BD71918DC66\"",
+    "last-modified": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-content-crc64": "AAAAAAAAAAA=",
+    "x-ms-group": "$superuser",
+    "x-ms-lease-state": "available",
+    "x-ms-lease-status": "unlocked",
+    "x-ms-owner": "$superuser",
+    "x-ms-permissions": "rw-r-----",
+    "x-ms-properties": "AddedVia=QXp1cmUgU0RLIGZvciBSdXN0",
+    "x-ms-request-id": "def5aa4e-901f-0073-76bf-4d3635000000",
+    "x-ms-resource-type": "file",
+    "x-ms-server-encrypted": "true",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/4_request.json

@@ -0,0 +1,11 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties/some/path/e2etest-file.txt?action=getStatus",
+  "method": "HEAD",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:48 GMT",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/4_response.json

@@ -0,0 +1,18 @@
+{
+  "status": 200,
+  "headers": {
+    "content-length": "0",
+    "date": "Mon, 11 Apr 2022 16:19:48 GMT",
+    "etag": "\"0x8DA1BD71918DC66\"",
+    "last-modified": "Mon, 11 Apr 2022 16:19:47 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-group": "$superuser",
+    "x-ms-owner": "$superuser",
+    "x-ms-permissions": "rw-r-----",
+    "x-ms-request-id": "def5aa4f-901f-0073-77bf-4d3635000000",
+    "x-ms-resource-type": "file",
+    "x-ms-server-encrypted": "true",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/5_request.json

@@ -0,0 +1,12 @@
+{
+  "uri": "/azurerustsdk-datalake-file-get-properties?resource=filesystem",
+  "method": "DELETE",
+  "headers": {
+    "authorization": "<<STRIPPED>>",
+    "content-length": "0",
+    "user-agent": "azsdk-rust-storage_datalake/0.1.1 (1.59.0; linux; x86_64)",
+    "x-ms-date": "Mon, 11 Apr 2022 16:19:48 GMT",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}

test/transactions/datalake_file_properties/5_response.json

@@ -0,0 +1,11 @@
+{
+  "status": 202,
+  "headers": {
+    "content-length": "0",
+    "date": "Mon, 11 Apr 2022 16:19:48 GMT",
+    "server": "Windows-Azure-HDFS/1.0 Microsoft-HTTPAPI/2.0",
+    "x-ms-request-id": "def5aa50-901f-0073-78bf-4d3635000000",
+    "x-ms-version": "2019-12-12"
+  },
+  "body": ""
+}