1 files changed, 35 insertions, 0 deletions
diff --git a/makima/src/daemon/api/supervisor.rs b/makima/src/daemon/api/supervisor.rs
index 1dc699e..26d786c 100644
--- a/makima/src/daemon/api/supervisor.rs
+++ b/makima/src/daemon/api/supervisor.rs
@@ -248,4 +248,39 @@ impl ApiClient {
         self.get(&format!("/api/v1/mesh/tasks/{}/output", task_id))
             .await
     }
+
+    /// Mark a contract as complete.
+    /// This will update contract status to 'completed', stop the supervisor, and clean up worktrees.
+    pub async fn supervisor_complete(&self, contract_id: Uuid) -> Result<JsonValue, ApiError> {
+        #[derive(Serialize)]
+        #[serde(rename_all = "camelCase")]
+        struct CompleteContractRequest {
+            status: String,
+        }
+        let req = CompleteContractRequest {
+            status: "completed".to_string(),
+        };
+        self.put(&format!("/api/v1/contracts/{}", contract_id), &req)
+            .await
+    }
+
+    /// Resume a completed contract (reactivate it).
+    ///
+    /// This updates the contract status from 'completed' back to 'active'
+    /// and optionally respawns the supervisor task.
+    pub async fn supervisor_resume_contract(
+        &self,
+        contract_id: Uuid,
+    ) -> Result<JsonValue, ApiError> {
+        #[derive(Serialize)]
+        #[serde(rename_all = "camelCase")]
+        struct ResumeContractRequest {
+            status: String,
+        }
+        let req = ResumeContractRequest {
+            status: "active".to_string(),
+        };
+        self.put(&format!("/api/v1/contracts/{}", contract_id), &req)
+            .await
+    }
 }