Added if_match_etag to Item Options (Azure#2705)

* read me change

* if_match_etag changes with tests

* if_match_etag changes with tests

* test changes

* if_match_etag added with tests

* changing back test_accounts file

* test changes and small fixes

* change log and url fixes

* comment changes

* added test recordings

* changed changelog

* Update sdk/cosmos/azure_data_cosmos/CHANGELOG.md

Co-authored-by: Heath Stewart <[email protected]>

---------

Co-authored-by: Heath Stewart <[email protected]>

Author: gsa9989

sdk/cosmos/assets.json

@@ -1,6 +1,6 @@
 {
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "rust",
-  "Tag": "rust/azure_data_cosmos_ff23846344",
+  "Tag": "rust/azure_data_cosmos_a39b424a5b",
   "TagPrefix": "rust/azure_data_cosmos"
 }

sdk/cosmos/azure_data_cosmos/CHANGELOG.md

@@ -3,6 +3,7 @@
 ## 0.25.0 (Unreleased)
 
 ### Features Added
+* Added `if_match_etag` to `ItemOptions` ([#2705](https://github.com/Azure/azure-sdk-for-rust/pull/2705))
 
 ### Breaking Changes
 

sdk/cosmos/azure_data_cosmos/README.md

@@ -131,8 +131,6 @@ async fn example(cosmos_client: CosmosClient) -> Result<(), Box<dyn std::error::
 * [Partitioning](https://learn.microsoft.com/azure/cosmos-db/partition-data)
 * [Using emulator](https://github.com/Azure/azure-documentdb-dotnet/blob/master/docs/documentdb-nosql-local-emulator.md)
 
-## Next steps
-
 ### Provide feedback
 
 If you encounter bugs or have suggestions, [open an issue](https://github.com/Azure/azure-sdk-for-rust/issues).

sdk/cosmos/azure_data_cosmos/src/clients/container_client.rs

@@ -12,7 +12,7 @@ use crate::{
 };
 
 use azure_core::http::{
-    headers,
+    headers::{self},
     request::{options::ContentType, Request},
     response::Response,
     Method,
@@ -358,6 +358,9 @@ impl ContainerClient {
         if !options.enable_content_response_on_write {
             req.insert_header(headers::PREFER, constants::PREFER_MINIMAL);
         }
+        if let Some(etag) = options.if_match_etag {
+            req.insert_header(headers::IF_MATCH, etag);
+        }
         req.insert_headers(&partition_key.into())?;
         req.insert_headers(&ContentType::APPLICATION_JSON)?;
         req.set_json(&item)?;
@@ -447,6 +450,9 @@ impl ContainerClient {
         if !options.enable_content_response_on_write {
             req.insert_header(headers::PREFER, constants::PREFER_MINIMAL);
         }
+        if let Some(etag) = options.if_match_etag {
+            req.insert_header(headers::IF_MATCH, etag);
+        }
         req.insert_header(constants::IS_UPSERT, "true");
         req.insert_headers(&partition_key.into())?;
         req.insert_headers(&ContentType::APPLICATION_JSON)?;
@@ -537,6 +543,9 @@ impl ContainerClient {
         let link = self.items_link.item(item_id);
         let url = self.pipeline.url(&link);
         let mut req = Request::new(url, Method::Delete);
+        if let Some(etag) = options.if_match_etag {
+            req.insert_header(headers::IF_MATCH, etag);
+        }
         req.insert_headers(&partition_key.into())?;
         self.pipeline
             .send(options.method_options.context, &mut req, link)
@@ -613,6 +622,9 @@ impl ContainerClient {
         if !options.enable_content_response_on_write {
             req.insert_header(headers::PREFER, constants::PREFER_MINIMAL);
         }
+        if let Some(etag) = options.if_match_etag {
+            req.insert_header(headers::IF_MATCH, etag);
+        }
         req.insert_headers(&partition_key.into())?;
         req.insert_headers(&ContentType::APPLICATION_JSON)?;
         req.set_json(&patch)?;

sdk/cosmos/azure_data_cosmos/src/options/mod.rs

@@ -1,7 +1,7 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
-use azure_core::http::{ClientMethodOptions, ClientOptions};
+use azure_core::http::{ClientMethodOptions, ClientOptions, Etag};
 
 use crate::models::ThroughputProperties;
 
@@ -47,7 +47,10 @@ pub struct DeleteDatabaseOptions<'a> {
 #[derive(Clone, Default)]
 pub struct ItemOptions<'a> {
     pub method_options: ClientMethodOptions<'a>,
-
+    /// If specified, the operation will only be performed if the item matches the provided Etag.
+    ///
+    /// See [Optimistic Concurrency Control](https://learn.microsoft.com/en-us/azure/cosmos-db/nosql/database-transactions-optimistic-concurrency#optimistic-concurrency-control) for more.
+    pub if_match_etag: Option<Etag>,
     /// When this value is true, write operations will respond with the new value of the resource being written.
     ///
     /// The default for this is `false`, which reduces the network and CPU burden that comes from serializing and deserializing the response.