@@ -186,9 +186,8 @@ impl<C: Send + Sync> store::Handler<C> for Handler {
186186 Ok ( nats) => nats,
187187 Err ( err) => return Ok ( Err ( store:: Error :: Other ( format ! ( "{err:#}" ) ) ) ) ,
188188 } ;
189- let Some ( prefix) = url. path ( ) . strip_prefix ( '/' ) else {
190- return Ok ( Err ( store:: Error :: Other ( "invalid URL" . to_string ( ) ) ) ) ;
191- } ;
189+ let prefix = url. path ( ) ;
190+ let prefix = prefix. strip_prefix ( '/' ) . unwrap_or ( prefix) ;
192191 let wrpc = match wrpc_transport_nats:: Client :: new ( nats, prefix, None )
193192 . await
194193 . context ( "failed to construct wRPC client" )
@@ -221,11 +220,14 @@ impl<C: Send + Sync> store::Handler<C> for Handler {
221220 . try_into ( )
222221 . context ( "failed to convert rustls client config to QUIC client config" ) ?;
223222 ep. set_default_client_config ( quinn:: ClientConfig :: new ( Arc :: new ( conf) ) ) ;
224- let conn = match ep. connect ( addr, san) . context ( "failed to connect" ) {
223+ let conn = match ep
224+ . connect ( addr, san)
225+ . context ( "failed to connect using QUIC" )
226+ {
225227 Ok ( ep) => ep,
226228 Err ( err) => return Ok ( Err ( store:: Error :: Other ( format ! ( "{err:#}" ) ) ) ) ,
227229 } ;
228- let conn = match conn. await . context ( "failed to establish connection" ) {
230+ let conn = match conn. await . context ( "failed to establish QUIC connection" ) {
229231 Ok ( ep) => ep,
230232 Err ( err) => return Ok ( Err ( store:: Error :: Other ( format ! ( "{err:#}" ) ) ) ) ,
231233 } ;
@@ -276,7 +278,7 @@ impl<C: Send + Sync> store::Handler<C> for Handler {
276278 let conn = match ep
277279 . connect ( format ! ( "https://{}" , url. authority( ) ) )
278280 . await
279- . context ( "failed to establish connection" )
281+ . context ( "failed to establish WebTransport connection" )
280282 {
281283 Ok ( ep) => ep,
282284 Err ( err) => return Ok ( Err ( store:: Error :: Other ( format ! ( "{err:#}" ) ) ) ) ,
0 commit comments