Improve OpenClaw Autonomy

- Implement atomic task checkout in heartbeat flow
- Filter locked objectives in loadObjectives
- Pass objective_context in advance_plan calls
- Wire CMS schema into operate mode and fix CMS load
- Prevent heartbeat state leakage into memory loading
- Update agent-execute cors headers and agent-operate cms integration

X-Lovable-Edit-ID: edt-fa9ad225-c1d1-4b74-b025-a2797e44852e
Co-authored-by: magnusfroste <38864257+magnusfroste@users.noreply.github.com>

Author: lovable-dev[bot]

supabase/functions/_shared/agent-reason.ts

@@ -467,7 +467,7 @@ export async function loadMemories(supabase: any): Promise<string> {
   const { data } = await supabase
     .from('agent_memory')
     .select('key, value, category')
-    .not('key', 'in', '("soul","identity")')
+    .not('key', 'in', '("soul","identity","heartbeat_state")')
     .order('updated_at', { ascending: false })
     .limit(30);
 
@@ -694,8 +694,9 @@ async function summarizeMessages(messages: any[], supabase: any): Promise<string
 export async function loadObjectives(supabase: any): Promise<string> {
   const { data } = await supabase
     .from('agent_objectives')
-    .select('id, goal, status, constraints, success_criteria, progress, created_at, updated_at')
+    .select('id, goal, status, constraints, success_criteria, progress, created_at, updated_at, locked_by, locked_at')
     .eq('status', 'active')
+    .is('locked_by', null)
     .order('created_at', { ascending: false })
     .limit(10);
 
@@ -855,6 +856,12 @@ async function handleAdvancePlan(supabase: any, supabaseUrl: string, serviceKey:
   const maxSteps = chain ? MAX_CHAIN_DEPTH : 1;
   const chainResults: any[] = [];
 
+  // Atomic checkout — prevent concurrent heartbeat instances from advancing the same objective
+  const locked = await checkoutObjective(supabase, objective_id);
+  if (!locked) {
+    return { status: 'locked', message: 'Objective is currently being worked on by another process.' };
+  }
+
   for (let depth = 0; depth < maxSteps; depth++) {
     const { data: obj, error } = await supabase.from('agent_objectives')
       .select('id, goal, progress')
@@ -931,6 +938,9 @@ async function handleAdvancePlan(supabase: any, supabaseUrl: string, serviceKey:
     if (!success || !nextStep.skill_name || allDone) break;
   }
 
+  // Release the lock
+  await releaseObjective(supabase, objective_id);
+
   const lastResult = chainResults[chainResults.length - 1];
   return {
     status: chainResults.some(r => r.status === 'failed') ? 'chain_partial' : 'chain_completed',

supabase/functions/agent-execute/index.ts

@@ -3,7 +3,7 @@ import { createClient, SupabaseClient } from 'https://esm.sh/@supabase/supabase-
 
 const corsHeaders = {
   'Access-Control-Allow-Origin': '*',
-  'Access-Control-Allow-Headers': 'authorization, x-client-info, apikey, content-type',
+  'Access-Control-Allow-Headers': 'authorization, x-client-info, apikey, content-type, x-supabase-client-platform, x-supabase-client-platform-version, x-supabase-client-runtime, x-supabase-client-runtime-version',
 };
 
 interface ExecuteRequest {

supabase/functions/agent-operate/index.ts

@@ -13,6 +13,7 @@ import {
   getBuiltInTools,
   executeBuiltInTool,
   isBuiltInTool,
+  loadCMSSchema,
 } from "../_shared/agent-reason.ts";
 
 /**
@@ -47,10 +48,11 @@ serve(async (req) => {
     const { apiKey, apiUrl, model } = await resolveAiConfig(supabase);
 
     // Load context in parallel
-    const [{ soul, identity }, memoryContext, objectiveContext] = await Promise.all([
+    const [{ soul, identity }, memoryContext, objectiveContext, cmsSchemaCtx] = await Promise.all([
       loadSoulIdentity(supabase),
       loadMemories(supabase),
       loadObjectives(supabase),
+      loadCMSSchema(supabase),
     ]);
 
     // Use prompt compiler (OpenClaw Layer 1)
@@ -59,6 +61,7 @@ serve(async (req) => {
       soulPrompt: buildSoulPrompt(soul, identity),
       memoryContext,
       objectiveContext,
+      cmsSchemaContext: cmsSchemaCtx,
     });
 
     // Build tools