Revert accidental commit 24d2560 (moq-native connect/reconnect refactor)

Commit 24d2560 was pushed to main by mistake: it captured an in-progress
moq-native Client::connect / reconnect refactor under an unrelated commit
message ("classify malformed auth-API JSON ...") and bypassed review. This
reverts those changes so the refactor can land properly via its own PR. The
original change is preserved in history at 24d2560 for re-use.

This reverts commit 24d2560.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: kixelated

doc/lib/rs/env/native.md

@@ -23,13 +23,11 @@ Create a [`ClientConfig`](https://docs.rs/moq-native/latest/moq_native/struct.Cl
 ```rust
 let client = moq_native::ClientConfig::default().init()?;
 let url = url::Url::parse("https://cdn.moq.dev/anon/my-broadcast")?;
-let session = client.connect_once(url).await?;
+let session = client.connect(url).await?;
 ```
 
 The default configuration uses system TLS roots, enables WebSocket fallback, and gives QUIC a 200ms head-start.
 
-`connect_once` makes a single attempt and resolves to a session. For most apps prefer `client.connect(url)`, which stays connected and reconnects with exponential backoff whenever the session drops, returning a [`Reconnect`](https://docs.rs/moq-native/latest/moq_native/struct.Reconnect.html) handle.
-
 ### URL Schemes
 
 The client supports several URL schemes:
@@ -41,7 +39,7 @@ The client supports several URL schemes:
 
 ### Transport Racing
 
-`client.connect()` and `client.connect_once()` automatically race QUIC and WebSocket connections.
+`client.connect()` automatically races QUIC and WebSocket connections.
 QUIC gets a configurable head-start (default 200ms); if it fails, WebSocket takes over.
 Once WebSocket wins for a given server, future connections skip the delay.
 This is transparent to your application.
@@ -54,7 +52,7 @@ Pass JWT tokens via URL query parameters:
 let url = Url::parse(&format!(
     "https://relay.example.com/room/123?jwt={}", token
 ))?;
-let session = client.connect_once(url).await?;
+let session = client.connect(url).await?;
 ```
 
 See the [Authentication guide](/bin/relay/auth) for how to generate tokens.

doc/lib/rs/index.md

@@ -231,20 +231,17 @@ a relay with a few lines:
 ```rust
 let client = moq_native::ClientConfig::default().init()?;
 let url = url::Url::parse("https://relay.moq.dev/anon")?;
-let session = client.connect_once(url).await?;
+let session = client.connect(url).await?;
 ```
 
-`connect_once` makes a single attempt; `client.connect(url)` instead stays connected
-and reconnects with exponential backoff whenever the session drops.
-
 To publish or consume, wire an [`Origin`](https://docs.rs/moq-net/latest/moq_net/struct.Origin.html)
 into the session before connecting:
 
 ```rust
 // Subscribe: wait for broadcasts to be announced.
 let origin = moq_net::Origin::new().produce();
 let mut consumer = origin.consume();
-let session = client.with_consume(origin).connect_once(url).await?;
+let session = client.with_consume(origin).connect(url).await?;
 
 while let Some((path, broadcast)) = consumer.announced().await {
     // ... subscribe to tracks on each broadcast ...

rs/hang/examples/subscribe.rs

@@ -31,7 +31,7 @@ async fn run_session(origin: moq_net::OriginProducer) -> anyhow::Result<()> {
 	// Establish a connection with automatic reconnection.
 	// with_consume() registers an OriginProducer for incoming data.
 	// Use with_publish() if you also want to publish from the session.
-	let reconnect = client.with_consume(origin).connect(url);
+	let reconnect = client.with_consume(origin).reconnect(url);
 
 	// Wait until the reconnect loop stops (e.g. timeout exceeded).
 	Ok(reconnect.closed().await?)

rs/hang/examples/video.rs

@@ -31,7 +31,7 @@ async fn run_session(origin: moq_net::OriginConsumer) -> anyhow::Result<()> {
 	// Establish a connection with automatic reconnection.
 	// with_publish() registers an OriginConsumer for outgoing data.
 	// Use with_consume() if you also want to subscribe/consume from the session.
-	let reconnect = client.with_publish(origin).connect(url);
+	let reconnect = client.with_publish(origin).reconnect(url);
 
 	// Wait until the reconnect loop stops (e.g. timeout exceeded).
 	Ok(reconnect.closed().await?)

rs/libmoq/src/session.rs

@@ -72,7 +72,7 @@ impl Session {
 			.init()?
 			.with_publish(publish)
 			.with_consume(consume)
-			.connect(url);
+			.reconnect(url);
 
 		// report() runs until the reconnect loop gives up; map its terminal error to Connect.
 		Self::report(callback, reconnect)

rs/moq-boy/src/main.rs

@@ -235,7 +235,7 @@ async fn run(config: &Config) -> Result<()> {
 	let reconnect = client
 		.with_publish(publish_origin.consume())
 		.with_consume(consume_origin)
-		.connect(config.url.clone());
+		.reconnect(config.url.clone());
 
 	// Set up catalog and encoders.
 	let catalog = moq_mux::catalog::hang::Producer::new(&mut broadcast)?;

rs/moq-cli/src/client.rs

@@ -10,7 +10,7 @@ pub async fn run_client(client: moq_native::Client, url: Url, name: String, publ
 
 	tracing::info!(%url, %name, "connecting");
 
-	let reconnect = client.with_publish(origin.consume()).connect(url);
+	let reconnect = client.with_publish(origin.consume()).reconnect(url);
 
 	#[cfg(unix)]
 	// Notify systemd that we're ready.

rs/moq-cli/src/main.rs

@@ -223,7 +223,7 @@ async fn run_subscribe(
 
 	tracing::info!(%url, %broadcast, "connecting");
 
-	let reconnect = client.with_consume(origin).connect(url);
+	let reconnect = client.with_consume(origin).reconnect(url);
 
 	#[cfg(unix)]
 	let _ = sd_notify::notify(&[sd_notify::NotifyState::Ready]);

rs/moq-ffi/src/session.rs

@@ -27,7 +27,7 @@ impl Client {
 		let session = client
 			.with_publish(publish)
 			.with_consume(consume)
-			.connect_once(url)
+			.connect(url)
 			.await
 			.map_err(|err| MoqError::Connect(format!("{err}")))?;
 

rs/moq-gst/src/sink/imp.rs

@@ -402,7 +402,7 @@ async fn run_session(
 	);
 
 	let client = client.with_publish(origin.consume());
-	let session = client.connect_once(settings.url.clone()).await?;
+	let session = client.connect(settings.url.clone()).await?;
 
 	let mut runtime = RuntimeState {
 		session,