Salvo and Webtransport

[statirasystems]

I have been playing with a cli application that can contact a Web-transport server, I made from examples. It works. I was trying the client on your server with the example web-transport setup, when I got the warning output:

2024-05-20T16:51:54.852121Z  WARN salvo_http3::proto::frame: Unsupported setting: SettingId(
    0xffd277,
)
2024-05-20T16:51:54.852206Z  WARN salvo_http3::proto::frame: Unsupported setting: SettingId(
    0x1328b2af29,
)
thread 'tokio-runtime-worker' panicked at src/main.rs:49:49:
called `Result::unwrap()` on an `Err` value: Other("invalid web transport without connection and stream")

So I configured Chrome to work with self signed certs and tried your static html page connector. It gave me the same errors. I put some tracer responses, and it does not seem to be establishing a web-transport connection. I made my certs with mkcert and they work with my litter server. My client code is:

use std::{fs, time::Instant, path::PathBuf, sync::Arc};
use anyhow::Result;
use rustls::{self, pki_types::CertificateDer, ClientConfig};
use rustls_native_certs;
use tokio::io::{AsyncRead, AsyncReadExt, AsyncWrite, AsyncWriteExt};
use tracing::{error, info};
use url::Url;
use web_transport_quinn;
use quinn;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>>{
    tracing_subscriber::fmt()
        .with_env_filter(tracing_subscriber::EnvFilter::from_default_env())
        .with_span_events(tracing_subscriber::fmt::format::FmtSpan::FULL)
        .with_writer(std::io::stderr)
        .with_max_level(tracing::Level::INFO) //may increase for testing
        .init();
    
    //________________________Set Parameters________________________________________________________________
    rustls::crypto::ring::default_provider().install_default();

    let ca = PathBuf::from("src/ca.cert");
    let destinationUri: String = "https://192.168.1.239:3000/counter".to_string();
    let key_log_file: bool = false;

    //__ ____________________Connection Details__________________________________________________________
    let uri = destinationUri.parse::<http::Uri>()?;
    if uri.scheme() != Some(&http::uri::Scheme::HTTPS){
        Err("uri scheme must be 'https'")?;
    }
    let auth = uri.authority().ok_or("uri must have a host")?.clone();
    let port = auth.port_u16().unwrap_or(443);
    let addr = tokio::net::lookup_host((auth.host(),port))
        .await?
        .next()
        .ok_or("dns found no addresses")?;
    info!("DNS lookup for {:?} {:?}", uri, addr);

    //________________________  ___________________quinn setup________________________________________ 
    //____________________________________________certs firts_____________________________________
    let mut roots = rustls::RootCertStore::empty();
    for cert in rustls_native_certs::load_native_certs()?{
        roots.add(cert).unwrap();
    }

    roots.add(CertificateDer::from(fs::read(ca)?));
    let mut tls_config = rustls::ClientConfig::builder()
        .with_root_certificates(roots)
        .with_no_client_auth();
    tls_config.enable_early_data = true;
    tls_config.alpn_protocols = vec![web_transport_quinn::ALPN.to_vec()];
    let tls_config: quinn::crypto::rustls::QuicClientConfig = tls_config.try_into()?;
    let client_config = quinn::ClientConfig::new(Arc::new(tls_config));

    let mut client_endpoint = quinn::Endpoint::client("[::]:0".parse()?)?;
    client_endpoint.set_default_client_config(client_config);

     //_____________________________________Client Connection_____________________________________________
    //let conn = client_endpoint.connect(addr, auth.host())?.await?;
    let neededurl = url::Url::parse(&uri.to_string()).unwrap();
    let conn = web_transport_quinn::connect(&client_endpoint,&neededurl).await?;
    info!("Connecting at {}", uri);
    info!("QUIC connection established");


    let (mut send, mut recv) = conn.open_bi().await?;
    info!("Sending information. ______________________________________________________________");
    let msg = "hello to you".to_string();  //format!("GET {}\r\n", uri.path());
    send.write_all(msg.as_bytes()).await?;
    info!("Sent message: {}", msg);
    send.finish()?;

    let response_start = Instant::now();
    info!("Request sent {:?}", response_start);
    let resp = recv.read_to_end(1024).await?; //usize::max_value()
    let respstring = String::from_utf8(resp)?;
    info!("Response {}", respstring );
    conn.close(0u32.into(), b"done");

    client_endpoint.wait_idle().await;


    Ok(())
}

I am rusty, no pun intended, as I was out of the game for 8 years in the pokie. Webtransport would be great from a tabletop game application I want to make.