chore: bump to rust 1.90.0 (#453)
This commit is contained in:
parent
aff82ed0c4
commit
57fc428c57
7 changed files with 14 additions and 16 deletions
|
|
@ -672,6 +672,7 @@ pub struct InitializeResult {
|
||||||
pub type ServerInfo = InitializeResult;
|
pub type ServerInfo = InitializeResult;
|
||||||
pub type ClientInfo = InitializeRequestParam;
|
pub type ClientInfo = InitializeRequestParam;
|
||||||
|
|
||||||
|
#[allow(clippy::derivable_impls)]
|
||||||
impl Default for ServerInfo {
|
impl Default for ServerInfo {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
ServerInfo {
|
ServerInfo {
|
||||||
|
|
@ -683,6 +684,7 @@ impl Default for ServerInfo {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[allow(clippy::derivable_impls)]
|
||||||
impl Default for ClientInfo {
|
impl Default for ClientInfo {
|
||||||
fn default() -> Self {
|
fn default() -> Self {
|
||||||
ClientInfo {
|
ClientInfo {
|
||||||
|
|
|
||||||
|
|
@ -63,6 +63,7 @@ pub enum StreamableHttpProtocolError {
|
||||||
MissingSessionIdInResponse,
|
MissingSessionIdInResponse,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[allow(clippy::large_enum_variant)]
|
||||||
pub enum StreamableHttpPostResponse {
|
pub enum StreamableHttpPostResponse {
|
||||||
Accepted,
|
Accepted,
|
||||||
Json(ServerJsonRpcMessage, Option<String>),
|
Json(ServerJsonRpcMessage, Option<String>),
|
||||||
|
|
@ -557,7 +558,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
|
||||||
///
|
///
|
||||||
/// impl StreamableHttpClient for MyHttpClient {
|
/// impl StreamableHttpClient for MyHttpClient {
|
||||||
/// type Error = MyError;
|
/// type Error = MyError;
|
||||||
///
|
///
|
||||||
/// async fn post_message(
|
/// async fn post_message(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
@ -567,7 +568,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
|
||||||
/// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
/// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
||||||
/// todo!()
|
/// todo!()
|
||||||
/// }
|
/// }
|
||||||
///
|
///
|
||||||
/// async fn delete_session(
|
/// async fn delete_session(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
@ -576,7 +577,7 @@ impl<C: StreamableHttpClient> Worker for StreamableHttpClientWorker<C> {
|
||||||
/// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
/// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
||||||
/// todo!()
|
/// todo!()
|
||||||
/// }
|
/// }
|
||||||
///
|
///
|
||||||
/// async fn get_stream(
|
/// async fn get_stream(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
@ -639,7 +640,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
|
||||||
///
|
///
|
||||||
/// impl StreamableHttpClient for MyHttpClient {
|
/// impl StreamableHttpClient for MyHttpClient {
|
||||||
/// type Error = MyError;
|
/// type Error = MyError;
|
||||||
///
|
///
|
||||||
/// async fn post_message(
|
/// async fn post_message(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
@ -649,7 +650,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
|
||||||
/// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
/// ) -> Result<rmcp::transport::streamable_http_client::StreamableHttpPostResponse, rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
||||||
/// todo!()
|
/// todo!()
|
||||||
/// }
|
/// }
|
||||||
///
|
///
|
||||||
/// async fn delete_session(
|
/// async fn delete_session(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
@ -658,7 +659,7 @@ impl<C: StreamableHttpClient> StreamableHttpClientTransport<C> {
|
||||||
/// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
/// ) -> Result<(), rmcp::transport::streamable_http_client::StreamableHttpError<Self::Error>> {
|
||||||
/// todo!()
|
/// todo!()
|
||||||
/// }
|
/// }
|
||||||
///
|
///
|
||||||
/// async fn get_stream(
|
/// async fn get_stream(
|
||||||
/// &self,
|
/// &self,
|
||||||
/// _uri: Arc<str>,
|
/// _uri: Arc<str>,
|
||||||
|
|
|
||||||
|
|
@ -304,7 +304,7 @@ impl From<SessionError> for std::io::Error {
|
||||||
fn from(value: SessionError) -> Self {
|
fn from(value: SessionError) -> Self {
|
||||||
match value {
|
match value {
|
||||||
SessionError::Io(io) => io,
|
SessionError::Io(io) => io,
|
||||||
_ => std::io::Error::new(std::io::ErrorKind::Other, format!("Session error: {value}")),
|
_ => std::io::Error::other(format!("Session error: {value}")),
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
@ -687,6 +687,7 @@ impl LocalSessionHandle {
|
||||||
|
|
||||||
pub type SessionTransport = WorkerTransport<LocalSessionWorker>;
|
pub type SessionTransport = WorkerTransport<LocalSessionWorker>;
|
||||||
|
|
||||||
|
#[allow(clippy::large_enum_variant)]
|
||||||
#[derive(Debug, Error)]
|
#[derive(Debug, Error)]
|
||||||
pub enum LocalSessionWorkerError {
|
pub enum LocalSessionWorkerError {
|
||||||
#[error("transport terminated")]
|
#[error("transport terminated")]
|
||||||
|
|
|
||||||
|
|
@ -1458,6 +1458,7 @@ async fn test_elicitation_examples_compile() {
|
||||||
use serde::{Deserialize, Serialize};
|
use serde::{Deserialize, Serialize};
|
||||||
|
|
||||||
// Example from trait documentation
|
// Example from trait documentation
|
||||||
|
#[allow(dead_code)]
|
||||||
#[derive(Serialize, Deserialize, JsonSchema)]
|
#[derive(Serialize, Deserialize, JsonSchema)]
|
||||||
struct UserProfile {
|
struct UserProfile {
|
||||||
name: String,
|
name: String,
|
||||||
|
|
|
||||||
|
|
@ -7,6 +7,7 @@ use rmcp::{
|
||||||
use tokio::process::Command;
|
use tokio::process::Command;
|
||||||
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
|
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};
|
||||||
|
|
||||||
|
#[allow(clippy::result_large_err)]
|
||||||
#[tokio::main]
|
#[tokio::main]
|
||||||
async fn main() -> Result<(), RmcpError> {
|
async fn main() -> Result<(), RmcpError> {
|
||||||
// Initialize logging
|
// Initialize logging
|
||||||
|
|
|
||||||
|
|
@ -207,14 +207,6 @@ struct TokenRequest {
|
||||||
refresh_token: String,
|
refresh_token: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Debug, Deserialize, Serialize)]
|
|
||||||
struct UserInfo {
|
|
||||||
sub: String,
|
|
||||||
name: String,
|
|
||||||
email: String,
|
|
||||||
username: String,
|
|
||||||
}
|
|
||||||
|
|
||||||
fn generate_random_string(length: usize) -> String {
|
fn generate_random_string(length: usize) -> String {
|
||||||
rand::rng()
|
rand::rng()
|
||||||
.sample_iter(&Alphanumeric)
|
.sample_iter(&Alphanumeric)
|
||||||
|
|
|
||||||
|
|
@ -1,3 +1,3 @@
|
||||||
[toolchain]
|
[toolchain]
|
||||||
channel = "1.85"
|
channel = "1.90"
|
||||||
components = ["rustc", "rust-std", "cargo", "clippy", "rustfmt", "rust-docs"]
|
components = ["rustc", "rust-std", "cargo", "clippy", "rustfmt", "rust-docs"]
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue