feat(rest): add flag submission endpoint

crates/kriger_common/src/models/requests.rs

@@ -4,3 +4,8 @@ use serde::{Deserialize, Serialize};
 pub struct FlagHintQuery {
     pub service: String,
 }
+
+#[derive(Serialize, Deserialize)]
+pub struct FlagSubmitRequest {
+    pub flags: Vec<String>,
+}

crates/kriger_rest/src/lib.rs

@@ -49,6 +49,7 @@ pub async fn main(runtime: AppRuntime, config: Config) -> eyre::Result<()> {
             "/exploits/:name/execute",
             post(routes::exploits::execute_exploit),
         )
+        .route("/flags", post(routes::flags::submit_flags))
         .route(
             "/competition/services",
             get(routes::competition::get_services),

crates/kriger_rest/src/routes/flags.rs

@@ -0,0 +1,28 @@
+use crate::support::{AppError, AppJson};
+use crate::AppState;
+use axum::response::IntoResponse;
+use axum::{extract::State, Json};
+use kriger_common::messaging::model;
+use kriger_common::models;
+use std::sync::Arc;
+
+pub(crate) async fn submit_flags(
+    state: State<Arc<AppState>>,
+    AppJson(request): AppJson<models::requests::FlagSubmitRequest>,
+) -> Result<impl IntoResponse, AppError> {
+    let flags_svc = state.runtime.messaging.flags();
+
+    // FIXME: Probably parallelize this, but whatever
+    for flag in request.flags {
+        flags_svc
+            .submit_flag(&model::FlagSubmission {
+                flag,
+                team_id: None,
+                service: None,
+                exploit: None,
+            })
+            .await?;
+    }
+
+    Ok(Json(models::responses::AppResponse::Ok(())))
+}

crates/kriger_rest/src/routes/mod.rs

@@ -1,3 +1,4 @@
 pub(crate) mod competition;
 pub(crate) mod config;
 pub(crate) mod exploits;
+pub(crate) mod flags;