Redo all the damn work I did before that renovate undid

Author: leftwo

Cargo.lock

@@ -83,6 +83,7 @@ ringbuffer = "0.15.0"
 rusqlite = { version = "0.32" }
 rustls-pemfile = { version = "1.0.4" }
 schemars = { version = "0.8", features = [ "chrono", "uuid1" ] }
+semver = "1"
 serde = { version = "1", features = [ "derive" ] }
 serde_json = "1"
 sha2 = "0.10"

Cargo.toml

@@ -16,6 +16,7 @@ http.workspace = true
 hyper.workspace = true
 omicron-common.workspace = true
 schemars.workspace = true
+semver.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 slog.workspace = true

agent/Cargo.toml

@@ -4,6 +4,7 @@ use anyhow::{anyhow, bail, Result};
 use clap::Parser;
 use dropshot::{ConfigLogging, ConfigLoggingIfExists, ConfigLoggingLevel};
 use slog::{debug, error, info, o, Logger};
+use semver::Version;
 use std::collections::HashSet;
 use std::io::Write;
 use std::net::SocketAddr;
@@ -341,7 +342,7 @@ async fn main() -> Result<()> {
 
 fn write_openapi<W: Write>(f: &mut W) -> Result<()> {
     let api = server::make_api()?;
-    api.openapi("Crucible Agent", "0.0.0").write(f)?;
+    api.openapi("Crucible Agent", Version::new(0, 0, 1)).write(f)?;
     Ok(())
 }
 

agent/src/main.rs

@@ -352,7 +352,7 @@ pub async fn run_server(
     let server = dropshot::HttpServerStarter::new(
         &dropshot::ConfigDropshot {
             bind_address,
-            request_body_max_bytes: 1024 * 10,
+            default_request_body_max_bytes: 1024 * 10,
             default_handler_task_mode: HandlerTaskMode::Detached,
             log_headers: vec![],
         },

agent/src/server.rs

@@ -37,6 +37,7 @@ reqwest.workspace = true
 ringbuffer.workspace = true
 rusqlite.workspace = true
 schemars.workspace = true
+semver.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 sha2.workspace = true

downstairs/Cargo.toml

@@ -13,6 +13,7 @@ use dropshot::RequestContext;
 use dropshot::{endpoint, Path};
 use hyper::{Response, StatusCode};
 use schemars::JsonSchema;
+use semver::Version;
 use serde::Deserialize;
 
 use super::*;
@@ -30,7 +31,7 @@ pub struct FileServerContext {
 
 pub fn write_openapi<W: Write>(f: &mut W) -> Result<()> {
     let api = build_api();
-    api.openapi("Downstairs Repair", "0.0.0").write(f)?;
+    api.openapi("Downstairs Repair", Version::new(0, 0, 1)).write(f)?;
     Ok(())
 }
 
@@ -57,7 +58,7 @@ pub fn repair_main(
      */
     let config_dropshot = ConfigDropshot {
         bind_address: addr,
-        request_body_max_bytes: 1024,
+        default_request_body_max_bytes: 1024,
         default_handler_task_mode: HandlerTaskMode::Detached,
         log_headers: vec![],
     };

downstairs/src/repair.rs

@@ -17,6 +17,7 @@ dropshot.workspace = true
 rand.workspace = true
 rand_chacha.workspace = true
 schemars.workspace = true
+semver.workspace = true
 serde.workspace = true
 statistical.workspace = true
 tokio.workspace = true

dsc/Cargo.toml

@@ -11,6 +11,7 @@ use dropshot::Path;
 use dropshot::RequestContext;
 use dropshot::{HttpResponseOk, HttpResponseUpdatedNoContent};
 use schemars::JsonSchema;
+use semver::Version;
 use serde::Deserialize;
 use std::sync::Arc;
 
@@ -51,7 +52,7 @@ pub async fn begin(dsci: Arc<DscInfo>, addr: SocketAddr) -> Result<(), String> {
     // Setup dropshot
     let config_dropshot = ConfigDropshot {
         bind_address: addr,
-        request_body_max_bytes: 1024,
+        default_request_body_max_bytes: 1024,
         default_handler_task_mode: HandlerTaskMode::Detached,
         log_headers: vec![],
     };
@@ -588,14 +589,15 @@ async fn dsc_enable_random_max(
 #[cfg(test)]
 mod test {
     use openapiv3::OpenAPI;
+    use semver::Version;
 
     use super::build_api;
 
     #[test]
     fn test_dsc_openapi() {
         let api = build_api();
         let mut raw = Vec::new();
-        api.openapi("DownStairs Control", "0.0.0")
+        api.openapi("DownStairs Control", Version::new(0, 0, 1))
             .write(&mut raw)
             .unwrap();
         let actual = String::from_utf8(raw).unwrap();

dsc/src/control.rs

@@ -2,7 +2,7 @@
   "openapi": "3.0.3",
   "info": {
     "title": "Crucible Agent",
-    "version": "0.0.0"
+    "version": "0.0.1"
   },
   "paths": {
     "/crucible/0/regions": {

openapi/crucible-agent.json

@@ -2,7 +2,7 @@
   "openapi": "3.0.3",
   "info": {
     "title": "Crucible Control",
-    "version": "0.0.0"
+    "version": "0.0.1"
   },
   "paths": {
     "/info": {

openapi/crucible-control.json

@@ -2,7 +2,7 @@
   "openapi": "3.0.3",
   "info": {
     "title": "Crucible Pantry",
-    "version": "0.0.0"
+    "version": "0.0.1"
   },
   "paths": {
     "/crucible/pantry/0": {

openapi/crucible-pantry.json

@@ -2,7 +2,7 @@
   "openapi": "3.0.3",
   "info": {
     "title": "Downstairs Repair",
-    "version": "0.0.0"
+    "version": "0.0.1"
   },
   "paths": {
     "/extent/{eid}/files": {

openapi/downstairs-repair.json

@@ -2,7 +2,7 @@
   "openapi": "3.0.3",
   "info": {
     "title": "DownStairs Control",
-    "version": "0.0.0"
+    "version": "0.0.1"
   },
   "paths": {
     "/allrunning": {

openapi/dsc-control.json

@@ -15,6 +15,7 @@ futures.workspace = true
 http.workspace = true
 hyper.workspace = true
 schemars.workspace = true
+semver.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 slog.workspace = true

pantry/Cargo.toml

@@ -2,6 +2,7 @@
 
 use anyhow::{anyhow, Result};
 use clap::Parser;
+use semver::Version;
 use std::io::Write;
 use std::net::SocketAddr;
 use std::path::PathBuf;
@@ -46,7 +47,7 @@ async fn main() -> Result<()> {
 
 fn write_openapi<W: Write>(f: &mut W) -> Result<()> {
     let api = server::make_api().map_err(|e| anyhow!(e))?;
-    api.openapi("Crucible Pantry", "0.0.0").write(f)?;
+    api.openapi("Crucible Pantry", Version::new(0, 0, 1)).write(f)?;
     Ok(())
 }
 

pantry/src/main.rs

@@ -851,7 +851,7 @@ impl Pantry {
                             "volume {} is no longer active!",
                             volume_id
                         )),
-                        hyper::StatusCode::GONE,
+                        dropshot::ClientErrorStatusCode::GONE,
                         format!("volume {} is no longer active!", volume_id),
                     ))
                 } else {

pantry/src/pantry.rs

@@ -469,7 +469,7 @@ pub fn run_server(
             bind_address,
             // max import, multiplied by worst case base64 overhead, plus room
             // for metadata
-            request_body_max_bytes: 1024
+            default_request_body_max_bytes: 1024
                 + crate::pantry::PantryEntry::MAX_CHUNK_SIZE * 2,
             default_handler_task_mode: HandlerTaskMode::Detached,
             log_headers: vec![],

pantry/src/server.rs

@@ -39,6 +39,7 @@ rand.workspace = true
 rayon.workspace = true
 ringbuffer.workspace = true
 schemars.workspace = true
+semver.workspace = true
 serde.workspace = true
 serde_json.workspace = true
 slog.workspace = true

upstairs/Cargo.toml

@@ -35,7 +35,7 @@ pub async fn start(
      */
     let config_dropshot = ConfigDropshot {
         bind_address: addr,
-        request_body_max_bytes: 1024,
+        default_request_body_max_bytes: 1024,
         default_handler_task_mode: HandlerTaskMode::Detached,
         log_headers: vec![],
     };
@@ -186,14 +186,15 @@ async fn downstairs_work_queue(
 #[cfg(test)]
 mod test {
     use openapiv3::OpenAPI;
+    use semver::Version;
 
     use super::build_api;
 
     #[test]
     fn test_crucible_control_openapi() {
         let api = build_api();
         let mut raw = Vec::new();
-        api.openapi("Crucible Control", "0.0.0")
+        api.openapi("Crucible Control", Version::new(0, 0, 1))
             .write(&mut raw)
             .unwrap();
         let actual = String::from_utf8(raw).unwrap();