OpenClaw + Vercel + Supabase로 AI 회사를 만들었습니다 — 2주 후, 스스로 운영합니다

// Heartbeat는 이제 4가지만 수행합니다
const triggerResult = await evaluateTriggers(sb, 4_000);
const reactionResult = await processReactionQueue(sb, 3_000);
const learningResult = await promoteInsights(sb);
const staleResult = await recoverStaleSteps(sb);

*/5 * * * * curl -s -H "Authorization: Bearer $KEY" https://yoursite.com/api/ops/heartbeat

// proposal-service.ts — 모든 제안 생성을 위한 단일 진입점
export async function createProposalAndMaybeAutoApprove(
  sb: SupabaseClient,
  input: ProposalServiceInput,  // source: 'api' | 'trigger' | 'reaction' 포함
): Promise<ProposalServiceResult> {
  // 1. 일일 한도 확인
  // 2. Cap Gates 확인 (아래 설명)
  // 3. 제안 삽입
  // 4. 이벤트 발생
  // 5. 자동 승인 평가
  // 6. 승인되면 → 임무 + 단계 생성
  // 7. 결과 반환
}

// trigger-evaluator.ts
if (outcome.fired && outcome.proposal) {
  await createProposalAndMaybeAutoApprove(sb, {
    ...outcome.proposal,
    source: 'trigger',
  });
}

// proposal-service.ts 내부의 게이트 시스템
const STEP_KIND_GATES: Record<string, StepKindGate> = {
  write_content: checkWriteContentGate,  // 일일 콘텐츠 한도 확인
  post_tweet:    checkPostTweetGate,     // 트윗 할당량 확인
  deploy:        checkDeployGate,        // 배포 정책 확인
};

async function checkPostTweetGate(sb: SupabaseClient) {
  const autopost = await getOpsPolicyJson(sb, 'x_autopost', {});
  if (autopost.enabled === false) return { ok: false, reason: 'x_autopost disabled' };

  const quota = await getOpsPolicyJson(sb, 'x_daily_quota', {});
  const limit = Number(quota.limit ?? 10);
  const { count } = await sb
    .from('ops_tweet_drafts')
    .select('id', { count: 'exact', head: true })
    .eq('status', 'posted')
    .gte('posted_at', startOfTodayUtcIso());

  if ((count ?? 0) >= limit) return { ok: false, reason: `Daily tweet quota reached (${count}/${limit})` };
  return { ok: true };
}

{
  "patterns": [
    { "source": "twitter-alt", "tags": ["tweet","posted"], "target": "growth",
      "type": "analyze", "probability": 0.3, "cooldown": 120 },
    { "source": "*", "tags": ["mission:failed"], "target": "brain",
      "type": "diagnose", "probability": 1.0, "cooldown": 60 }
  ]
}

// 30분 동안 진행 없음 → 실패로 표시 → 미션 종료 여부 확인
const STALE_THRESHOLD_MS = 30 * 60 * 1000;

const { data: stale } = await sb
  .from('ops_mission_steps')
  .select('id, mission_id')
  .eq('status', 'running')
  .lt('reserved_at', staleThreshold);

for (const step of stale) {
  await sb.from('ops_mission_steps').update({
    status: 'failed',
    last_error: 'Stale: no progress for 30 minutes',
  }).eq('id', step.id);
  await maybeFinalizeMissionIfDone(sb, step.mission_id);
}

// auto_approve: 자동 통과가 허용되는 단계 종류
{ "enabled": true, "allowed_step_kinds": ["draft_tweet","crawl","analyze","write_content"] }

// x_daily_quota: 일일 트윗 상한
{ "limit": 8 }

// worker_policy: Vercel이 단계를 실행하는지 여부 (false = VPS 전용)
{ "enabled": false }