[WIP] Heartbeat checkpoint - 2026-01-26 18:19:03 UTCmakima/task-task-e6b5334f-e6b5334f

3 files changed, 34 insertions, 7 deletions

diff --git a/makima/migrations/20260126000000_add_local_only_mode.sql b/makima/migrations/20260126000000_add_local_only_mode.sql
new file mode 100644
index 0000000..27af087
--- /dev/null
+++ b/makima/migrations/20260126000000_add_local_only_mode.sql
@@ -0,0 +1,7 @@
+-- Add local_only column to contracts
+ALTER TABLE contracts ADD COLUMN local_only BOOLEAN NOT NULL DEFAULT false;
+
+-- Index for filtering by local_only mode
+CREATE INDEX idx_contracts_local_only ON contracts(local_only) WHERE local_only = true;
+
+COMMENT ON COLUMN contracts.local_only IS 'When true, tasks do not auto-execute completion actions and work stays in worktrees';
diff --git a/makima/src/db/models.rs b/makima/src/db/models.rs
index 0c1d9f2..d6cc42a 100644
--- a/makima/src/db/models.rs
+++ b/makima/src/db/models.rs
@@ -1321,6 +1321,10 @@ pub struct Contract {
     /// phase outputs (like plans, requirements, etc.) before continuing.
     #[serde(default)]
     pub phase_guard: bool,
+    /// When true, tasks do not auto-execute completion actions and work stays in worktrees.
+    /// Used for local-only workflows where changes are managed manually.
+    #[serde(default)]
+    pub local_only: bool,
     pub version: i32,
     pub created_at: DateTime<Utc>,
     pub updated_at: DateTime<Utc>,
@@ -1417,6 +1421,9 @@ pub struct ContractSummary {
     pub status: String,
     /// Supervisor task ID for contract orchestration
     pub supervisor_task_id: Option<Uuid>,
+    /// When true, tasks do not auto-execute completion actions and work stays in worktrees.
+    #[serde(default)]
+    pub local_only: bool,
     pub file_count: i64,
     pub task_count: i64,
     pub repository_count: i64,
@@ -1471,6 +1478,10 @@ pub struct CreateContractRequest {
     /// phase outputs before progressing to the next phase.
     #[serde(default)]
     pub phase_guard: Option<bool>,
+    /// Enable local-only mode for this contract.
+    /// When true, tasks do not auto-execute completion actions and work stays in worktrees.
+    #[serde(default)]
+    pub local_only: Option<bool>,
 }
 
 /// Request payload for updating a contract
@@ -1492,6 +1503,10 @@ pub struct UpdateContractRequest {
     /// phase outputs before progressing to the next phase.
     #[serde(default)]
     pub phase_guard: Option<bool>,
+    /// Enable or disable local-only mode for this contract.
+    /// When true, tasks do not auto-execute completion actions and work stays in worktrees.
+    #[serde(default)]
+    pub local_only: Option<bool>,
     /// Version for optimistic locking
     pub version: Option<i32>,
 }
diff --git a/makima/src/db/repository.rs b/makima/src/db/repository.rs
index d3e4c56..b45bdea 100644
--- a/makima/src/db/repository.rs
+++ b/makima/src/db/repository.rs
@@ -2175,11 +2175,12 @@ pub async fn create_contract_for_owner(
 
     let autonomous_loop = req.autonomous_loop.unwrap_or(false);
     let phase_guard = req.phase_guard.unwrap_or(false);
+    let local_only = req.local_only.unwrap_or(false);
 
     sqlx::query_as::<_, Contract>(
         r#"
-        INSERT INTO contracts (owner_id, name, description, contract_type, phase, autonomous_loop, phase_guard)
-        VALUES ($1, $2, $3, $4, $5, $6, $7)
+        INSERT INTO contracts (owner_id, name, description, contract_type, phase, autonomous_loop, phase_guard, local_only)
+        VALUES ($1, $2, $3, $4, $5, $6, $7, $8)
         RETURNING *
         "#,
     )
@@ -2190,6 +2191,7 @@ pub async fn create_contract_for_owner(
     .bind(phase)
     .bind(autonomous_loop)
     .bind(phase_guard)
+    .bind(local_only)
     .fetch_one(pool)
     .await
 }
@@ -2222,7 +2224,7 @@ pub async fn list_contracts_for_owner(
         r#"
         SELECT
             c.id, c.name, c.description, c.contract_type, c.phase, c.status,
-            c.supervisor_task_id, c.version, c.created_at,
+            c.supervisor_task_id, c.local_only, c.version, c.created_at,
             (SELECT COUNT(*) FROM files WHERE contract_id = c.id) as file_count,
             (SELECT COUNT(*) FROM tasks WHERE contract_id = c.id) as task_count,
             (SELECT COUNT(*) FROM contract_repositories WHERE contract_id = c.id) as repository_count
@@ -2246,7 +2248,7 @@ pub async fn get_contract_summary_for_owner(
         r#"
         SELECT
             c.id, c.name, c.description, c.contract_type, c.phase, c.status,
-            c.supervisor_task_id, c.version, c.created_at,
+            c.supervisor_task_id, c.local_only, c.version, c.created_at,
             (SELECT COUNT(*) FROM files WHERE contract_id = c.id) as file_count,
             (SELECT COUNT(*) FROM tasks WHERE contract_id = c.id) as task_count,
             (SELECT COUNT(*) FROM contract_repositories WHERE contract_id = c.id) as repository_count
@@ -2290,14 +2292,15 @@ pub async fn update_contract_for_owner(
     let supervisor_task_id = req.supervisor_task_id.or(existing.supervisor_task_id);
     let autonomous_loop = req.autonomous_loop.unwrap_or(existing.autonomous_loop);
     let phase_guard = req.phase_guard.unwrap_or(existing.phase_guard);
+    let local_only = req.local_only.unwrap_or(existing.local_only);
 
     let result = if req.version.is_some() {
         sqlx::query_as::<_, Contract>(
             r#"
             UPDATE contracts
             SET name = $3, description = $4, phase = $5, status = $6,
-                supervisor_task_id = $7, autonomous_loop = $8, phase_guard = $9, version = version + 1, updated_at = NOW()
-            WHERE id = $1 AND owner_id = $2 AND version = $10
+                supervisor_task_id = $7, autonomous_loop = $8, phase_guard = $9, local_only = $10, version = version + 1, updated_at = NOW()
+            WHERE id = $1 AND owner_id = $2 AND version = $11
             RETURNING *
             "#,
         )
@@ -2310,6 +2313,7 @@ pub async fn update_contract_for_owner(
         .bind(supervisor_task_id)
         .bind(autonomous_loop)
         .bind(phase_guard)
+        .bind(local_only)
         .bind(req.version.unwrap())
         .fetch_optional(pool)
         .await?
@@ -2318,7 +2322,7 @@ pub async fn update_contract_for_owner(
             r#"
             UPDATE contracts
             SET name = $3, description = $4, phase = $5, status = $6,
-                supervisor_task_id = $7, autonomous_loop = $8, phase_guard = $9, version = version + 1, updated_at = NOW()
+                supervisor_task_id = $7, autonomous_loop = $8, phase_guard = $9, local_only = $10, version = version + 1, updated_at = NOW()
             WHERE id = $1 AND owner_id = $2
             RETURNING *
             "#,
@@ -2332,6 +2336,7 @@ pub async fn update_contract_for_owner(
         .bind(supervisor_task_id)
         .bind(autonomous_loop)
         .bind(phase_guard)
+        .bind(local_only)
         .fetch_optional(pool)
         .await?
     };