summaryrefslogtreecommitdiff
path: root/makima/src/server/handlers/mesh_chat.rs
diff options
context:
space:
mode:
authorsoryu <soryu@soryu.co>2026-01-26 18:39:19 +0000
committersoryu <soryu@soryu.co>2026-01-26 18:39:19 +0000
commitb6118a540aa18173ab0db2796915453a4828094b (patch)
treeec19fba1b33aca7c8cd9f25c59f6d45f0efd6e10 /makima/src/server/handlers/mesh_chat.rs
parent27e5efc8f69425e963e82f621655faf2680f2a88 (diff)
downloadsoryu-makima/task-task-372e6a1a-372e6a1a.tar.gz
soryu-makima/task-task-372e6a1a-372e6a1a.zip
[WIP] Heartbeat checkpoint - 2026-01-26 18:39:19 UTCmakima/task-task-372e6a1a-372e6a1a
Diffstat (limited to 'makima/src/server/handlers/mesh_chat.rs')
-rw-r--r--makima/src/server/handlers/mesh_chat.rs11
1 files changed, 11 insertions, 0 deletions
diff --git a/makima/src/server/handlers/mesh_chat.rs b/makima/src/server/handlers/mesh_chat.rs
index 1ff0724..eb35728 100644
--- a/makima/src/server/handlers/mesh_chat.rs
+++ b/makima/src/server/handlers/mesh_chat.rs
@@ -1131,6 +1131,16 @@ async fn handle_mesh_request(
}
};
+ // Get local_only from contract if task has one
+ let local_only = if let Some(contract_id) = task.contract_id {
+ match repository::get_contract_for_owner(pool, contract_id, owner_id).await {
+ Ok(Some(contract)) => contract.local_only,
+ _ => false,
+ }
+ } else {
+ false
+ };
+
// Send SpawnTask command to daemon
let command = DaemonCommand::SpawnTask {
task_id,
@@ -1153,6 +1163,7 @@ async fn handle_mesh_request(
conversation_history: None,
patch_data: None,
patch_base_sha: None,
+ local_only,
};
match state.send_daemon_command(target_daemon_id, command).await {