chore(deps): bump axum from 0.7.9 to 0.8.6 (#1969)

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Ian Clarke <ian@freenetproject.org>
Co-authored-by: Claude <noreply@anthropic.com>

Author: 3 people

Cargo.lock

@@ -11,7 +11,7 @@ members = [
 
 [workspace.dependencies]
 arrayvec = { version = "0.7", features = ["serde"] }
-axum = { version = "0.7", default-features = false }
+axum = { version = "0.8", default-features = false }
 blake3 = { version = "1", features = ["std", "traits-preview"] }
 bs58 = "0.5"
 chacha20poly1305 = "0.10"

Cargo.toml

@@ -434,7 +434,7 @@ async fn websocket_interface(
                     },
                     EncodingProtocol::Native => bincode::serialize(&response)?,
                 };
-                server_sink.send(Message::Binary(serialized_res)).await.inspect_err(|err| {
+                server_sink.send(Message::Binary(serialized_res.into())).await.inspect_err(|err| {
                     tracing::debug!(err = %err, "error sending message to client");
                 })?;
             }
@@ -476,8 +476,8 @@ async fn process_client_request(
     encoding_protoc: EncodingProtocol,
 ) -> Result<Option<Message>, Option<anyhow::Error>> {
     let msg = match msg {
-        Ok(Message::Binary(data)) => data,
-        Ok(Message::Text(data)) => data.into_bytes(),
+        Ok(Message::Binary(data)) => data.to_vec(),
+        Ok(Message::Text(data)) => data.as_bytes().to_vec(),
         Ok(Message::Close(_)) => return Err(None),
         Ok(Message::Ping(ping)) => return Ok(Some(Message::Pong(ping))),
         Ok(m) => {
@@ -492,7 +492,7 @@ async fn process_client_request(
         match encoding_protoc {
             EncodingProtocol::Flatbuffers => match ClientRequest::try_decode_fbs(&msg) {
                 Ok(decoded) => decoded.into_owned(),
-                Err(err) => return Ok(Some(Message::Binary(err.into_fbs_bytes()))),
+                Err(err) => return Ok(Some(Message::Binary(err.into_fbs_bytes().into()))),
             },
             EncodingProtocol::Native => match bincode::deserialize::<ClientRequest>(&msg) {
                 Ok(decoded) => decoded.into_owned(),
@@ -504,7 +504,7 @@ async fn process_client_request(
                         .into(),
                     ))
                     .map_err(|err| Some(err.into()))?;
-                    return Ok(Some(Message::Binary(result_error)));
+                    return Ok(Some(Message::Binary(result_error.into())));
                 }
             },
         }
@@ -624,7 +624,7 @@ async fn process_host_response(
                 );
             }
 
-            let send_result = tx.send(Message::Binary(serialized_res)).await;
+            let send_result = tx.send(Message::Binary(serialized_res.into())).await;
 
             // Log WebSocket send result for UPDATE responses
             if let Some(key) = is_update_response {
@@ -662,7 +662,7 @@ async fn process_host_response(
             let result_error = bincode::serialize(&Err::<HostResponse, ClientError>(
                 ErrorKind::NodeUnavailable.into(),
             ))?;
-            tx.send(Message::Binary(result_error)).await?;
+            tx.send(Message::Binary(result_error.into())).await?;
             tx.send(Message::Close(None)).await?;
             tracing::warn!("node shut down while handling responses for {client_id}");
             Err(anyhow::anyhow!(

crates/core/src/client_events/websocket.rs

@@ -20,9 +20,9 @@ impl HttpGateway {
 
         let router = Router::new()
             .route("/v1", get(home))
-            .route("/v1/contract/web/:key/", get(web_home))
+            .route("/v1/contract/web/{key}/", get(web_home))
             .with_state(config)
-            .route("/v1/contract/web/:key/*path", get(web_subpages))
+            .route("/v1/contract/web/{key}/{*path}", get(web_subpages))
             .layer(Extension(attested_contracts.clone()))
             .layer(Extension(HttpGatewayRequest(proxy_request_sender)));