Updated to current Typespec emitter and regenerated SDK clients (Azure#2968)

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

Author: LarryOsterman

Cargo.lock

@@ -1,17 +1,17 @@
 {
   "main": "dist/src/index.js",
   "dependencies": {
-    "@azure-tools/typespec-rust": "0.20.0"
+    "@azure-tools/typespec-rust": "0.21.0"
   },
   "devDependencies": {
-    "@azure-tools/typespec-azure-core": "0.58.0",
-    "@azure-tools/typespec-azure-rulesets": "0.58.0",
-    "@azure-tools/typespec-client-generator-core": "0.58.0",
-    "@typespec/compiler": "1.2.1",
-    "@typespec/http": "1.2.1",
-    "@typespec/openapi": "1.2.1",
-    "@typespec/rest": "0.72.1",
-    "@typespec/versioning": "0.72.1",
-    "@typespec/xml": "0.72.1"
+    "@azure-tools/typespec-azure-core": "0.59.0",
+    "@azure-tools/typespec-azure-rulesets": "0.59.0",
+    "@azure-tools/typespec-client-generator-core": "0.59.1",
+    "@typespec/compiler": "1.3",
+    "@typespec/http": "1.3",
+    "@typespec/openapi": "1.3",
+    "@typespec/rest": "0.73",
+    "@typespec/versioning": "0.73",
+    "@typespec/xml": "0.73"
   }
 }

eng/emitter-package-lock.json

@@ -91,7 +91,7 @@ reqwest = { version = "0.12.23", features = ["rustls-tls-webpki-roots"] }
 
 You could even completely replace `reqwest` and provide your own `HttpClient` implementation. See [an example](#other-http-client) below.
 
-** NOTE:** The `debug` feature may expose PII and/or secrets to logs or tracing spans which would normally be redacted.
+**NOTE:** The `debug` feature may expose PII and/or secrets to logs or tracing spans which would normally be redacted.
 
 ## Examples
 
@@ -155,14 +155,14 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     )?;
 
     // call a service method, which returns Response<T>
-    let response = client.get_secret("secret-name", "", None).await?;
+    let response = client.get_secret("secret-name", None).await?;
 
     // Response<T> has two main accessors:
     // 1. The `into_body()` function consumes self to deserialize into a model type
     let secret = response.into_body().await?;
 
     // get response again because it was moved in above statement
-    let response: Response<Secret> = client.get_secret("secret-name", "", None).await?;
+    let response: Response<Secret> = client.get_secret("secret-name", None).await?;
 
     // 2. The deconstruct() method for accessing all the details of the HTTP response
     let (status, headers, body) = response.deconstruct();
@@ -198,7 +198,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         None,
     )?;
 
-    match client.get_secret("secret-name", "", None).await {
+    match client.get_secret("secret-name", None).await {
         Ok(secret) => println!("Secret: {:?}", secret.into_body().await?.value),
         Err(e) => match e.kind() {
             ErrorKind::HttpResponse { status, error_code, .. } if *status == StatusCode::NotFound => {
@@ -575,7 +575,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     )?;
 
     // get a secret
-    let secret = client.get_secret("secret-name", "", None)
+    let secret = client.get_secret("secret-name", None)
         .await?
         .into_body()
         .await?;

eng/emitter-package.json

@@ -63,7 +63,7 @@ async fn test_remove_user_agent() -> Result<(), Box<dyn std::error::Error>> {
 
     // We'll fetch a secret and let the mock client assert the User-Agent header was removed.
     let secret = client
-        .get_secret("my-secret", "", None)
+        .get_secret("my-secret", None)
         .await?
         .into_body()
         .await?;

sdk/core/azure_core/README.md

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "rust",
   "TagPrefix": "rust/eventhubs",
-  "Tag": "rust/eventhubs_8405b278af"
+  "Tag": "rust/eventhubs_e00fc5e364"
 }

sdk/core/azure_core/examples/core_remove_user_agent.rs

@@ -137,7 +137,7 @@ impl BlobCheckpointStore {
         let blob_content = RequestContent::<Bytes, NoFormat>::from(Vec::new());
         let options = BlockBlobClientUploadOptions {
             metadata: metadata.clone(),
-            if_match: Some("*".to_string()), // Upload without an etag, creating a new blob
+            if_none_match: Some("*".to_string()), // Upload without an etag, creating a new blob
             ..Default::default()
         };
 

sdk/eventhubs/assets.json

@@ -4,19 +4,24 @@
 //! Unit tests for the blob checkpoint store models and utilities.
 
 use azure_core::{http::Etag, time::OffsetDateTime, Result};
-use azure_core_test::{recorded, TestContext};
+use azure_core_test::{recorded, Recording, TestContext};
 use azure_messaging_eventhubs::{models::Ownership, CheckpointStore};
 mod checkpoint_unit_tests;
 use checkpoint_unit_tests::create_test_checkpoint_store;
 use tracing::trace;
 
+fn create_test_namespace(recording: &Recording) -> String {
+    let namespace = recording.var("EVENTHUBS_HOST", None);
+    recording.random_string::<55>(Some(namespace.as_str()))
+}
+
 #[recorded::test]
 async fn list_ownerships(ctx: TestContext) -> Result<()> {
     let recording = ctx.recording();
     const TEST_PARTITION_ID: &str = "list_ownerships";
     let checkpoint_store = create_test_checkpoint_store(recording)?;
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());
@@ -81,7 +86,7 @@ async fn claim_ownership_single_partition(ctx: TestContext) -> Result<()> {
 
     const TEST_PARTITION_ID: &str = "claim_ownership_single_partition";
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());
@@ -129,7 +134,7 @@ async fn claim_ownership_multiple_partitions(ctx: TestContext) -> Result<()> {
     let recording = ctx.recording();
     let checkpoint_store = create_test_checkpoint_store(recording)?;
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());
@@ -213,7 +218,7 @@ async fn claim_ownership_update_existing(ctx: TestContext) -> Result<()> {
     const TEST_PARTITION_ID: &str = "ownership_update_existing";
     let checkpoint_store = create_test_checkpoint_store(recording)?;
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());
@@ -264,7 +269,7 @@ async fn claim_ownership_concurrent_update_should_fail(ctx: TestContext) -> Resu
     let recording = ctx.recording();
     let checkpoint_store = create_test_checkpoint_store(recording)?;
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());
@@ -309,7 +314,7 @@ async fn claim_ownership_no_owner_id(ctx: TestContext) -> Result<()> {
     let recording = ctx.recording();
     let checkpoint_store = create_test_checkpoint_store(recording)?;
 
-    let namespace = recording.var("EVENTHUBS_HOST", None);
+    let namespace = create_test_namespace(recording);
     let consumer_group = recording
         .var_opt("EVENTHUBS_CONSUMER_GROUP", None)
         .unwrap_or("$Default".to_string());

sdk/eventhubs/azure_messaging_eventhubs_checkpointstore_blob/src/checkpoint_store.rs

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "rust",
   "TagPrefix": "rust/keyvault",
-  "Tag": "rust/keyvault_c904be268a"
+  "Tag": "rust/keyvault_456b9ceaa6"
 }

sdk/eventhubs/azure_messaging_eventhubs_checkpointstore_blob/tests/ownership_unit_tests.rs

@@ -4,8 +4,12 @@
 
 ### Features Added
 
+- Updated to latest version of fixes for the "7.6" specification after TypeSpec migration.
+
 ### Breaking Changes
 
+- Moved certificate version parameters to client method options.
+
 ### Bugs Fixed
 
 ### Other Changes