update to hyper v1 (#745)

Author: ahl

Cargo.lock

@@ -106,7 +106,7 @@ clap = "4.2"
 const_format = "0.2"
 crossbeam-channel = "0.5"
 ctrlc = "3.2"
-dropshot = { git = "https://github.com/oxidecomputer/dropshot", branch = "main" }
+dropshot = "0.12.0"
 erased-serde = "0.4"
 errno = "0.2.8"
 escargot = "0.5.8"
@@ -116,8 +116,8 @@ futures = "0.3"
 futures-util = "0.3.21"
 flate2 = "1.0.28"
 hex = "0.4.3"
-http = "0.2.9"
-hyper = "0.14"
+http = "1.1.0"
+hyper = "1.0"
 indicatif = "0.17.3"
 inventory = "0.3.0"
 kstat-rs = "0.2.4"
@@ -130,10 +130,10 @@ owo-colors = "4"
 pin-project-lite = "0.2.13"
 proc-macro2 = "1.0"
 proc-macro-error = "1"
-progenitor = { git = "https://github.com/oxidecomputer/progenitor", branch = "main" }
+progenitor = "0.8.0"
 quote = "1.0"
 rand = "0.8"
-reqwest = { version = "0.11.18", default-features = false }
+reqwest = { version = "0.12.0", default-features = false }
 ring = "0.17"
 ron = "0.8"
 schemars = "0.8.10"

Cargo.toml

@@ -397,15 +397,15 @@ mod serial {
     use std::sync::atomic::{AtomicBool, Ordering};
     use std::sync::Arc;
 
+    use dropshot::WebsocketConnectionRaw;
     use futures::StreamExt;
-    use hyper::upgrade::Upgraded;
     use tokio::sync::{mpsc, Notify};
     use tokio_tungstenite::tungstenite::protocol::{
         frame::coding::CloseCode, CloseFrame,
     };
     use tokio_tungstenite::WebSocketStream;
 
-    type WsConn = WebSocketStream<Upgraded>;
+    type WsConn = WebSocketStream<WebsocketConnectionRaw>;
 
     const DEFAULT_MAX_LEN: usize = 1024;
 

bin/mock-server/src/lib/lib.rs

@@ -30,7 +30,6 @@ crucible-client-types.workspace = true
 dropshot = { workspace = true, features = ["usdt-probes"] }
 erased-serde.workspace = true
 futures.workspace = true
-http.workspace = true
 hyper.workspace = true
 internal-dns.workspace = true
 kstat-rs.workspace = true

bin/propolis-server/Cargo.toml

@@ -26,7 +26,7 @@ pub(crate) trait MigrateConn:
 }
 
 impl MigrateConn for tokio_tungstenite::MaybeTlsStream<tokio::net::TcpStream> {}
-impl MigrateConn for hyper::upgrade::Upgraded {}
+impl MigrateConn for dropshot::WebsocketConnectionRaw {}
 
 #[derive(Copy, Clone, Debug, Eq, PartialEq, Serialize, Deserialize)]
 pub enum MigrateRole {

bin/propolis-server/src/lib/migrate/mod.rs

@@ -17,7 +17,6 @@ use crate::serial::history_buffer::{HistoryBuffer, SerialHistoryOffset};
 use futures::future::Fuse;
 use futures::stream::SplitSink;
 use futures::{FutureExt, SinkExt, StreamExt};
-use hyper::upgrade::Upgraded;
 use propolis::chardev::{pollers, Sink, Source};
 use propolis_api_types::InstanceSerialConsoleControlMessage;
 use slog::{info, warn, Logger};
@@ -78,11 +77,14 @@ pub struct SerialTask {
     /// clients of a migration
     pub control_ch: mpsc::Sender<SerialTaskControlMessage>,
     /// Channel used to send new client connections to the streaming task
-    pub websocks_ch: mpsc::Sender<WebSocketStream<Upgraded>>,
+    pub websocks_ch:
+        mpsc::Sender<WebSocketStream<dropshot::WebsocketConnectionRaw>>,
 }
 
 pub async fn instance_serial_task<Device: Sink + Source>(
-    mut websocks_recv: mpsc::Receiver<WebSocketStream<Upgraded>>,
+    mut websocks_recv: mpsc::Receiver<
+        WebSocketStream<dropshot::WebsocketConnectionRaw>,
+    >,
     mut control_recv: mpsc::Receiver<SerialTaskControlMessage>,
     serial: Arc<Serial<Device>>,
     log: Logger,
@@ -94,11 +96,13 @@ pub async fn instance_serial_task<Device: Sink + Source>(
 
     let mut ws_sinks: HashMap<
         usize,
-        SplitSink<WebSocketStream<Upgraded>, Message>,
+        SplitSink<WebSocketStream<dropshot::WebsocketConnectionRaw>, Message>,
     > = HashMap::new();
     let mut ws_streams: HashMap<
         usize,
-        futures::stream::SplitStream<WebSocketStream<Upgraded>>,
+        futures::stream::SplitStream<
+            WebSocketStream<dropshot::WebsocketConnectionRaw>,
+        >,
     > = HashMap::new();
 
     let (send_ch, mut recv_ch) = mpsc::channel(4);

bin/propolis-server/src/lib/serial/mod.rs

@@ -272,7 +272,7 @@ async fn instance_ensure_common(
             | VmError::AlreadyInitialized
             | VmError::RundownInProgress => HttpError::for_client_error(
                 Some(api::ErrorCode::AlreadyInitialized.to_string()),
-                http::StatusCode::CONFLICT,
+                hyper::StatusCode::CONFLICT,
                 "instance already initialized".to_string(),
             ),
             VmError::InitializationFailed(e) => HttpError::for_internal_error(
@@ -409,7 +409,7 @@ async fn instance_state_monitor(
         state_watcher.changed().await.map_err(|_| {
             HttpError::for_client_error(
                 Some(api::ErrorCode::NoInstance.to_string()),
-                http::status::StatusCode::GONE,
+                hyper::StatusCode::GONE,
                 format!(
                     "No instance present; will never reach generation {}",
                     gen
@@ -439,7 +439,7 @@ async fn instance_state_put(
             }
             VmError::ForbiddenStateChange(reason) => HttpError::for_status(
                 Some(format!("instance state change not allowed: {}", reason)),
-                http::status::StatusCode::FORBIDDEN,
+                hyper::StatusCode::FORBIDDEN,
             ),
             _ => HttpError::for_internal_error(format!(
                 "unexpected error from VM controller: {e}"
@@ -693,7 +693,7 @@ async fn instance_issue_crucible_vcr_request(
         .map_err(|e| match e {
             VmError::ForbiddenStateChange(reason) => HttpError::for_status(
                 Some(format!("instance state change not allowed: {}", reason)),
-                http::status::StatusCode::FORBIDDEN,
+                hyper::StatusCode::FORBIDDEN,
             ),
             _ => HttpError::for_internal_error(format!(
                 "unexpected error from VM controller: {e}"
@@ -749,7 +749,7 @@ pub fn api() -> ApiDescription<Arc<DropshotEndpointContext>> {
 fn not_created_error() -> HttpError {
     HttpError::for_client_error(
         Some(api::ErrorCode::NoInstance.to_string()),
-        http::StatusCode::FAILED_DEPENDENCY,
+        hyper::StatusCode::FAILED_DEPENDENCY,
         "Server not initialized (no instance)".to_string(),
     )
 }

bin/propolis-server/src/lib/server.rs

@@ -433,7 +433,7 @@ impl Drop for ExternalRequestQueue {
                                 "VM destroyed before request could be handled"
                                     .to_string(),
                             ),
-                            http::StatusCode::GONE,
+                            hyper::StatusCode::GONE,
                         )));
                 }
 

bin/propolis-server/src/lib/vm/request_queue.rs

@@ -20,7 +20,6 @@ fatfs.workspace = true
 futures.workspace = true
 flate2.workspace = true
 hex.workspace = true
-http.workspace = true
 libc.workspace = true
 newtype_derive.workspace = true
 propolis-client.workspace = true

phd-tests/framework/Cargo.toml

@@ -1049,7 +1049,7 @@ async fn try_ensure_vm_destroyed(client: &Client) {
         // nothing else that *can* be done, but the error is unusual and should
         // be logged.
         match error.status() {
-            Some(http::status::StatusCode::FAILED_DEPENDENCY) => {}
+            Some(reqwest::StatusCode::FAILED_DEPENDENCY) => {}
             _ => {
                 error!(
                     %error,