thearyanahmed · thearyanahmed · Jan 31, 2026 · Jan 31, 2026 · Jan 31, 2026 · Jan 31, 2026
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "luxctl"
-version = "0.6.3"
+version = "0.7.0"
 edition = "2021"
 description = "Learn by building - CLI for projectlighthouse.io"
 license = "AGPL-3.0-only"

diff --git a/Makefile b/Makefile
@@ -1,8 +1,4 @@
-.PHONY: build run test fmt lint clean dev check all local\:me local\:get release\:build
-
-# ==============================================================================
-# Local API Testing
-# ==============================================================================
+.PHONY: build run test e2e fmt lint clean dev check all local\:me local\:get release\:build
 
 LOCAL_API_URL := http://0.0.0.0:8000/api/v1
 DEV_TOKEN_FILE := dev_token
@@ -43,6 +39,10 @@ run:
 test:
 	cargo test
 
+# Run E2E tests (requires local API running)
+e2e:
+	cargo test --test e2e -- --ignored --nocapture
+
 # Format code
 fmt:
 	cargo fmt

diff --git a/src/api/client.rs b/src/api/client.rs
@@ -9,8 +9,8 @@ use crate::{config::Config, VERSION};
 
 use super::types::{
     ApiError, ApiUser, HealthCheckResponse, HintsResponse, Lab, PaginatedResponse,
-    SubmitAnswerRequest, SubmitAnswerResponse, SubmitAttemptRequest, SubmitAttemptResponse,
-    UnlockHintResponse,
+    RestartLabResponse, SubmitAnswerRequest, SubmitAnswerResponse, SubmitAttemptRequest,
+    SubmitAttemptResponse, UnlockHintResponse,
 };
 
 pub struct LighthouseAPIClient {
@@ -212,6 +212,14 @@ impl LighthouseAPIClient {
         self.post::<SubmitAnswerResponse, _>(&endpoint, request, Some(headers))
             .await
     }
+
+    /// restart a lab from scratch (creates new attempt group)
+    pub async fn restart_lab(&self, slug: &str) -> Result<RestartLabResponse> {
+        let headers = self.auth_headers()?;
+        let endpoint = format!("labs/{}/restart", slug);
+        self.post::<RestartLabResponse, _>(&endpoint, &serde_json::json!({}), Some(headers))
+            .await
+    }
 }
 
 #[derive(Clone, Copy)]

diff --git a/src/api/types.rs b/src/api/types.rs
@@ -294,6 +294,19 @@ pub struct SubmitAnswerResponse {
     pub already_completed: Option<bool>,
 }
 
+/// response from restarting a lab
+#[derive(Debug, Deserialize)]
+pub struct RestartLabResponse {
+    pub message: String,
+    pub data: RestartLabData,
+}
+
+#[derive(Debug, Deserialize)]
+pub struct RestartLabData {
+    pub attempt_group_id: i32,
+    pub created_at: String,
+}
+
 impl ApiUser {
     pub fn id(&self) -> i32 {
         self.id

diff --git a/src/commands/lab.rs b/src/commands/lab.rs
@@ -197,3 +197,60 @@ pub fn set_workspace(workspace: &str) -> Result<()> {
 
     Ok(())
 }
+
+/// handle `luxctl lab restart`
+pub async fn restart() -> Result<()> {
+    let config = Config::load()?;
+    if !config.has_auth_token() {
+        UI::error(
+            "not authenticated",
+            Some("run `luxctl auth --token $token`"),
+        );
+        return Ok(());
+    }
+
+    let mut state = LabState::load(config.expose_token())?;
+
+    let lab = match state.get_active() {
+        Some(l) => l.clone(),
+        None => {
+            UI::error("no active lab", None);
+            UI::note("run `luxctl lab start --slug <SLUG>` first");
+            return Ok(());
+        }
+    };
+
+    let client = LighthouseAPIClient::from_config(&config);
+
+    match client.restart_lab(&lab.slug).await {
+        Ok(response) => {
+            // refresh tasks from server
-            // refresh tasks from server
+            // Refresh tasks from server
-            // refresh tasks from server
+            // Refresh tasks from server
+            match client.lab_by_slug(&lab.slug).await {
+                Ok(refreshed_lab) => {
+                    let tasks = refreshed_lab.tasks.as_deref().unwrap_or(&[]);
+                    state.set_active(
+                        &lab.slug,
+                        &lab.name,
+                        tasks,
+                        &lab.workspace,
+                        lab.runtime.as_deref(),
+                    );
+                    state.save(config.expose_token())?;
+                }
+                Err(_) => {
+                    // if refresh fails, just clear local progress
-                    // if refresh fails, just clear local progress
+                    // If refresh fails, just clear local progress
-                    // if refresh fails, just clear local progress
+                    // If refresh fails, just clear local progress
+                    state.clear_progress();
+                    state.save(config.expose_token())?;
+                }
+            }
+
+            UI::success(&format!("restarted lab: {}", lab.name));
+            UI::info(&response.message);
+        }
+        Err(err) => {
+            UI::error("failed to restart lab", Some(&format!("{}", err)));
+        }
+    }
+
+    Ok(())
+}
diff --git a/src/lib.rs b/src/lib.rs
@@ -10,4 +10,4 @@ pub mod tasks;
 pub mod ui;
 pub mod validators;
 
-pub const VERSION: &str = "0.6.3";
+pub const VERSION: &str = "0.7.0";
diff --git a/src/main.rs b/src/main.rs
@@ -104,6 +104,8 @@ enum LabAction {
         #[arg(short = 'w', long)]
         workspace: Option<String>,
     },
+    /// Start fresh - reset all progress on the current lab
+    Restart,
 }
 
 #[derive(Subcommand)]
@@ -255,6 +257,9 @@ async fn main() -> Result<()> {
                     oops!("provide --runtime or --workspace to set");
                 }
             }
+            LabAction::Restart => {
+                commands::lab::restart().await?;
+            }
         },
 
         Commands::Task { action } => match action {

diff --git a/src/state.rs b/src/state.rs
@@ -228,6 +228,16 @@ impl LabState {
         });
     }
 
+    /// reset all task progress to initial state (for lab restart)
+    pub fn clear_progress(&mut self) {
+        self.with_active_mut(|l| {
+            for task in &mut l.tasks {
+                task.status = TaskStatus::ChallengeAwaits;
+                task.points_earned = 0;
+            }
+        });
+    }
+
     /// compute HMAC-SHA256 checksum of lab data
     /// returns empty string if HMAC creation fails (should never happen for SHA256)
     fn compute_checksum(lab: &Option<ActiveLab>, token: &str) -> String {