auto: snapshot

Author: howardjohn

Cargo.lock

@@ -47,7 +47,7 @@ cel = { path = "crates/cel-fork/cel" }
 cel-derive = { path = "crates/cel-fork/cel-derive" }
 atomic_float = { version = "1.1.0", features = ["serde"] }
 anyhow = "1.0"
-arc-swap = "1.7.1"
+arc-swap = "1.8.2"
 arcstr = { version = "1.2", features = ["serde"] }
 assert_matches = "1.5.0"
 async-openai = { version = "0.33.0", default-features = false, features = ["chat-completion-types", "moderation-types", "response-types", "realtime-types"] }
@@ -58,18 +58,18 @@ aws-credential-types = "1.2"
 aws-sigv4 = "1.3"
 aws-smithy-eventstream = "0.60"
 aws-smithy-types = "1.3"
-aws-lc-rs = "1.15"
+aws-lc-rs = "1.16"
 axum = { version = "0.8", features = ["macros"] }
 axum-core = "0.5"
 axum-extra = { version = "0.12", features = ["json-lines", "typed-header"] }
 # Disable default features to avoid pulling in native-tls and requiring openssl
 # TODO: allow default features if we ever add an openssl feature
-azure_identity = { version = "0.31", default-features = false }
-azure_core = { version = "0.31", default-features = false }
-typespec_client_core = { default-features = false, version = "0.10" }
+azure_identity = { version = "0.32", default-features = false }
+azure_core = { version = "0.32", default-features = false }
+typespec_client_core = { default-features = false, version = "0.11" }
 base64 = "0.22"
-bcrypt = "0.18"
-bytes = { version = "1.10", features = ["serde"] }
+bcrypt = "0.19"
+bytes = { version = "1.11", features = ["serde"] }
 chrono = { version = "0.4", features = ["serde"] }
 clap = { version = "4.5", features = ["derive"] }
 clocksource = "0.8"
@@ -78,7 +78,7 @@ divan = "0.1"
 durationfmt = "0.1"
 go-parse-duration = "0.1"
 flurry = "0.5.2"
-fs-err = { version = "3.1", features = ["tokio"] }
+fs-err = { version = "3.3", features = ["tokio"] }
 futures = "0.3"
 futures-channel = "0.3"
 futures-core = "0.3"
@@ -96,22 +96,22 @@ hex = "0.4"
 hickory-resolver = { version = "0.25", features = ["serde"] }
 htpasswd-verify-fork = { path = "crates/htpasswd-verify-fork" }
 httpdate = "1.0"
-http = "1.3"
+http = "1.4"
 http-body = "1"
 http-body-util = "0.1.3"
-hyper = { version = "1.6", features = ["full"] }
+hyper = { version = "1.8", features = ["full"] }
 hyper-rustls = "0.27"
 hyper-util = { version = "0.1", features = ["full"] }
 hyper-util-fork = { path = "crates/hyper-util-fork" }
 include_dir = "0.7"
-indexmap = { version = "2.9", features = ["serde"] }
-insta = { version = "1.38", features = ["json", "redactions", "filters", "yaml"] }
-ipnet = { version = "2.11", features = ["serde"] }
+indexmap = { version = "2.13", features = ["serde"] }
+insta = { version = "1.46", features = ["json", "redactions", "filters", "yaml"] }
+ipnet = { version = "2.12", features = ["serde"] }
 itertools = "0.14"
 jsonwebtoken = { version = "10.3", features = ["aws_lc_rs"] }
-lazy_static = "1.4"
+lazy_static = "1.5"
 libc = "0.2"
-notify = "8.0"
+notify = "8.2"
 notify-debouncer-full = "0.7"
 md-5 = "0.10"
 num_cpus = "1.17"
@@ -126,7 +126,7 @@ parking_lot = "0.12"
 percent-encoding = "2.3"
 phonenumber = "0.3"
 pin-project-lite = "0.2"
-pingora-pool = "0.7"
+pingora-pool = "0.8"
 ppp = "2.3"
 pprof = { version = "0.15", features = [
     "protobuf",
@@ -138,12 +138,12 @@ prometheus-client = "0.24"
 prost = "0.14"
 prost-build = "0.14"
 prost-types = "0.14"
-prost-wkt-types = { version = "0.7.0", features = ["vendored-protox"] }
-prost-wkt-build = "0.7.0"
+prost-wkt-types = { version = "0.7.1", features = ["vendored-protox"] }
+prost-wkt-build = "0.7.1"
 pwhash = "1"
 rand = "0.10"
 rcgen = { version = "0.14", features = ["pem", "x509-parser"] }
-regex = "1.11"
+regex = "1.12"
 reqwest = { version = "0.13", default-features = false, features = [
     "http2",
     "charset",
@@ -154,7 +154,7 @@ rustc_version = "0.4"
 rustls = { version = "0.23", features = ["tls12", "ring"] }
 rustls-native-certs = "0.8"
 rustls-pemfile = "2.2"
-rustls-pki-types = "1.12"
+rustls-pki-types = "1.14"
 schemars = { version = "=1.0.4", git = "https://github.com/howardjohn/schemars", rev = "4364354fa41897a0c2001d891c0a9a38eafedb82", features = [
     #schemars = { version = "1.0", features = [
     "bytes1",
@@ -176,10 +176,10 @@ socket2 = "0.6"
 split-iter = "0.1"
 sse-stream = "0.2"
 stacker = "0.1"
-tempfile = "3.20"
+tempfile = "3.26"
 thiserror = "2.0"
 tiktoken-rs = "0.9"
-tokio = { version = "1.48", features = ["full", "macros", "sync"] }
+tokio = { version = "1.50", features = ["full", "macros", "sync"] }
 tokio-rustls = { version = "0.26", default-features = false }
 tokio-stream = { version = "0.1", features = ["net", "sync"] }
 tokio-test = "0.4"
@@ -203,7 +203,7 @@ tracing-subscriber = { version = "0.3", features = [
     "json",
 ] }
 url = "2.5"
-uuid = { version = "1.11", features = ["v4"] }
+uuid = { version = "1.21", features = ["v4"] }
 wiremock = { version = "0.6", features = ["tls"] }
 x509-parser = { version = "0.18", default-features = false, features = ["verify-aws"] }
 which = "8.0"
@@ -214,28 +214,28 @@ crossbeam-channel = "0.5"
 http-serde = "2.1"
 itoa = "1.0"
 serde_urlencoded = "0.7"
-serde_with = { version = "3.14", features = [
+serde_with = { version = "3.17", features = [
     "schemars_1",
     "macros",
     "alloc",
 ], default-features = false }
-value-bag = { version = "1.11", features = ["serde", "value-bag-serde1"] }
+value-bag = { version = "1.12", features = ["serde", "value-bag-serde1"] }
 time = "0.3"
 tikv-jemallocator = { version = "0.6", features = [
     "profiling",
     "unprefixed_malloc_on_supported_platforms",
 ] }
 jemalloc_pprof = { version = "0.8", features = ["symbolize"] }
 protox = "0.9"
-async-compression = { version = "0.4.27", features = [
+async-compression = { version = "0.4.41", features = [
     "brotli",
     "zlib",
     "gzip",
     "zstd",
     "tokio",
 ] }
 core_affinity = "0.8.3"
-frozen-collections = "0.8.0"
+frozen-collections = "0.4.0"
 heck = "0.5"
 macro_rules_attribute = "0.2.2"
 

Cargo.toml

@@ -98,7 +98,7 @@ rand.workspace = true
 rcgen.workspace = true
 regex.workspace = true
 
-rmcp = { version = "0.16", features = [
+rmcp = { version = "1.0", features = [
     "client",
     "server",
     "base64",
@@ -177,7 +177,7 @@ rstest.workspace = true
 tempfile.workspace = true
 tokio = { workspace = true, features = ["test-util"] }
 which.workspace = true
-rmcp = { version = "0.16", features = [
+rmcp = { version = "1.0", features = [
     "client",
     "server",
     "base64",

crates/agentgateway/Cargo.toml

@@ -7,7 +7,7 @@ use azure_core::error::ResultExt;
 use futures_util::TryStreamExt;
 use http_body_util::BodyExt;
 use tracing::{debug, error, warn};
-use typespec_client_core::http::{AsyncRawResponse, Sanitizer};
+use azure_core::http::{AsyncRawResponse, Sanitizer};
 
 use crate::client::{ApplicationTransport, Call, Client};
 use crate::types::agent::Target;
@@ -47,7 +47,7 @@ impl azure_core::http::HttpClient for Client {
 
 		debug!(
 			"performing request {method} '{}' with `agentgateway::client::Client`",
-			url.sanitize(&typespec_client_core::http::DEFAULT_ALLOWED_QUERY_PARAMETERS)
+			url.sanitize(&azure_core::http::DEFAULT_ALLOWED_QUERY_PARAMETERS)
 		);
 		let rsp = self
 			.call(Call {

crates/agentgateway/src/client/azure.rs

@@ -134,13 +134,13 @@ impl Relay {
 							)
 						})
 						// Rename to handle multiplexing
-						.map(|t| Tool {
-							name: Cow::Owned(resource_name(
+						.map(|mut t| {
+							t.name = Cow::Owned(resource_name(
 								default_target_name.as_ref(),
 								server_name.as_str(),
 								&t.name,
-							)),
-							..t
+							));
+							t
 						})
 						.collect_vec()
 				})
@@ -202,9 +202,10 @@ impl Relay {
 								&cel,
 							)
 						})
-						.map(|p| Prompt {
-							name: resource_name(default_target_name.as_ref(), server_name.as_str(), &p.name),
-							..p
+						.map(|mut p| {
+							p.name =
+								resource_name(default_target_name.as_ref(), server_name.as_str(), &p.name);
+							p
 						})
 						.collect_vec()
 				})
@@ -377,38 +378,22 @@ impl Relay {
 	}
 	fn get_info(pv: ProtocolVersion, multiplexing: bool) -> ServerInfo {
 		let capabilities = if multiplexing {
-			ServerCapabilities {
-				completions: None,
-				experimental: None,
-				logging: None,
-				tasks: None,
-				extensions: None,
-				tools: Some(ToolsCapability::default()),
-				// These are not supported when multiplexing.
-				prompts: None,
-				resources: None,
-			}
+			// These are not supported when multiplexing.
+			ServerCapabilities::builder().enable_tools().build()
 		} else {
-			ServerCapabilities {
-				completions: None,
-				experimental: None,
-				logging: None,
-				tasks: None,
-				extensions: None,
-				tools: Some(ToolsCapability::default()),
-				prompts: Some(PromptsCapability::default()),
-				resources: Some(ResourcesCapability::default()),
-			}
+			ServerCapabilities::builder()
+				.enable_tools()
+				.enable_prompts()
+				.enable_resources()
+				.build()
 		};
 		let instructions = Some(
             "This server is a gateway to a set of mcp servers. It is responsible for routing requests to the correct server and aggregating the results.".to_string(),
         );
-		ServerInfo {
-			protocol_version: pv,
-			capabilities,
-			server_info: Implementation::from_build_env(),
-			instructions,
-		}
+		ServerInfo::new(capabilities)
+			.with_protocol_version(pv)
+			.with_server_info(Implementation::from_build_env())
+			.with_instructions(instructions.unwrap_or_default())
 	}
 }
 

crates/agentgateway/src/mcp/handler.rs

@@ -65,11 +65,7 @@ impl Session {
 		let is_init = matches!(&message, ClientJsonRpcMessage::Request(r) if matches!(&r.request, &ClientRequest::InitializeRequest(_)));
 		if !is_init {
 			// first, send the initialize
-			let init_request = rmcp::model::InitializeRequest {
-				method: Default::default(),
-				params: get_client_info(),
-				extensions: Default::default(),
-			};
+			let init_request = rmcp::model::InitializeRequest::new(get_client_info());
 			let _ = self
 				.send(
 					parts.clone(),
@@ -645,21 +641,9 @@ impl sse_stream::Timer for TokioSseTimer {
 }
 
 fn get_client_info() -> ClientInfo {
-	ClientInfo {
-		meta: None,
-		protocol_version: ProtocolVersion::V_2025_06_18,
-		capabilities: rmcp::model::ClientCapabilities {
-			experimental: None,
-			roots: None,
-			sampling: None,
-			elicitation: None,
-			tasks: None,
-			extensions: None,
-		},
-		client_info: Implementation {
-			name: "agentgateway".to_string(),
-			version: BuildInfo::new().version.to_string(),
-			..Default::default()
-		},
-	}
+	let mut client_info = ClientInfo::default();
+	client_info.protocol_version = ProtocolVersion::V_2025_06_18;
+	client_info.capabilities = rmcp::model::ClientCapabilities::default();
+	client_info.client_info = Implementation::new("agentgateway", BuildInfo::new().version.to_string());
+	client_info
 }