milestones

crates/backend/src/main.rs

@@ -12,7 +12,10 @@ use axum::Router;
 use axum::TypedHeader;
 use common::Achievement;
 use common::CreateAchievement;
+use common::CreateMilestone;
 use common::DeleteAchievement;
+use common::DeleteMilestone;
+use common::Milestone;
 use common::ToggleAchievement;
 use serde::Deserialize;
 use serde::Serialize;
@@ -89,8 +92,10 @@ async fn main() {
         tokio::spawn(async move {
             let app = Router::new()
                 .route("/create", post(create_achievement))
-                .route("/toggle", post(toggle_achievement))
                 .route("/delete", post(delete_achievement))
+                .route("/toggle", post(toggle_achievement))
+                .route("/create-milestone", post(create_milestone))
+                .route("/delete-milestone", post(delete_milestone))
                 .route("/ws", get(ws_handler))
                 .layer(
                     ServiceBuilder::new()
@@ -178,6 +183,49 @@ async fn create_achievement(
     Ok((StatusCode::CREATED, ()))
 }
 
+async fn create_milestone(
+    Extension(app_state): Extension<SharedState>,
+    Json(create_milestone): Json<CreateMilestone>,
+) -> Result<(StatusCode, ()), HandlerError> {
+    tracing::debug!("Creating milestone: {create_milestone:?}.");
+
+    if create_milestone.goal > 100 {
+        return Ok((StatusCode::BAD_REQUEST, ()));
+    }
+
+    let milestone = Milestone {
+        goal: create_milestone.goal,
+        uuid: uuid::Uuid::new_v4(),
+    };
+    let mut lock = app_state.write().await;
+    lock.app_state.state.milestones.push(milestone);
+    lock.watcher_tx
+        .send(lock.app_state.state.clone())
+        .expect("watch channel is closed, every receiver was dropped.");
+    Ok((StatusCode::CREATED, ()))
+}
+
+async fn delete_milestone(
+    Extension(app_state): Extension<SharedState>,
+    Json(delete_milestone): Json<DeleteMilestone>,
+) -> Result<(StatusCode, ()), HandlerError> {
+    tracing::debug!("Deleting milestone: {delete_milestone:?}.");
+    let mut lock = app_state.write().await;
+    if let Some(pos) = lock
+        .app_state
+        .state
+        .milestones
+        .iter()
+        .position(|x| x.uuid == delete_milestone.uuid)
+    {
+        lock.app_state.state.milestones.remove(pos);
+        lock.watcher_tx
+            .send(lock.app_state.state.clone())
+            .expect("watch channel is closed, every receiver was dropped.");
+    }
+    Ok((StatusCode::OK, ()))
+}
+
 async fn toggle_achievement(
     Extension(app_state): Extension<SharedState>,
     Json(toggle_achievement): Json<ToggleAchievement>,