feat(uptime): basic http endpoint (#435)

Just returning a 500 for gets; useful for testing.

Author: klochek

Cargo.lock

@@ -65,6 +65,7 @@ iprange = "0.6.7"
 http = "1.2.0"
 relay-pattern = { git = "https://github.com/getsentry/relay", rev = "7ba03b5f6ffe95c2429ba315f661d2b8ee3c0efe" }
 pest = "2.7.15"
+axum = "0.8.6"
 
 [patch.crates-io]
 rdkafka = { git = "https://github.com/fede1024/rust-rdkafka" }

Cargo.toml

@@ -159,6 +159,8 @@ pub struct Config {
 
     /// Whether this uptime checker will write to redis or not.
     pub redis_readonly: bool,
+
+    pub webserver_port: u16,
 }
 
 impl Default for Config {
@@ -201,6 +203,7 @@ impl Default for Config {
             redis_timeouts_ms: 30_000,
             enable_metrics: false,
             redis_readonly: false,
+            webserver_port: 12345,
         }
     }
 }
@@ -357,6 +360,7 @@ mod tests {
                         redis_timeouts_ms: 30_000,
                         enable_metrics: false,
                         redis_readonly: false,
+                        webserver_port: 12345,
                     }
                 );
             },
@@ -404,6 +408,7 @@ mod tests {
                 ),
                 ("UPTIME_CHECKER_INTERFACE", "eth0"),
                 ("UPTIME_CHECKER_REDIS_READONLY", "true"),
+                ("UPTIME_CHECKER_WEBSERVER_PORT", "81"),
             ],
             |config| {
                 assert_eq!(
@@ -452,6 +457,7 @@ mod tests {
                         redis_timeouts_ms: 30_000,
                         enable_metrics: false,
                         redis_readonly: true,
+                        webserver_port: 81,
                     }
                 );
             },

src/app/config.rs

@@ -0,0 +1,28 @@
+use crate::endpoint::EndpointState;
+use axum::{extract::State, response::IntoResponse, Json};
+use http::StatusCode;
+use serde::Serialize;
+use std::sync::Arc;
+
+#[derive(Debug, Serialize)]
+#[serde(tag = "error")]
+#[serde(rename_all = "snake_case")]
+pub(crate) enum ExecuteError {
+    Unknown,
+}
+
+impl IntoResponse for ExecuteError {
+    fn into_response(self) -> axum::response::Response {
+        let status = match &self {
+            ExecuteError::Unknown => StatusCode::INTERNAL_SERVER_ERROR,
+        };
+
+        (status, Json(self)).into_response()
+    }
+}
+
+pub(crate) async fn execute_config(
+    State(_state): State<Arc<EndpointState>>,
+) -> Result<(), ExecuteError> {
+    Err(ExecuteError::Unknown)
+}