chore: promote dev→main — pgserve, fire-and-forget, scheduler

.claude-plugin/marketplace.json

@@ -10,7 +10,7 @@
   "plugins": [
     {
       "name": "genie",
-      "version": "3.260318.7",
+      "version": "3.260319.1",
       "source": "./plugins/genie",
       "description": "Human-AI partnership for Claude Code. Share a terminal, orchestrate workers, evolve together. Brainstorm ideas, wish them into plans, make with parallel agents, ship as one team. A coding genie that grows with your project."
     }

openclaw.plugin.json

@@ -2,7 +2,7 @@
   "id": "genie",
   "name": "Genie",
   "description": "Skills, agents, and hooks for the Genie CLI terminal orchestration toolkit",
-  "version": "3.260318.7",
+  "version": "3.260319.1",
   "configSchema": {
     "type": "object",
     "additionalProperties": false,

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@automagik/genie",
-  "version": "3.260318.7",
+  "version": "3.260319.1",
   "description": "Collaborative terminal toolkit for human + AI workflows",
   "type": "module",
   "bin": {
@@ -26,6 +26,8 @@
     "@inquirer/prompts": "^7.0.0",
     "commander": "^12.1.0",
     "js-yaml": "^4.1.1",
+    "pgserve": "^1.1.6",
+    "postgres": "^3.4.8",
     "uuid": "^11.1.0",
     "zod": "^3.25.0"
   },
@@ -54,5 +56,5 @@
   "publishConfig": {
     "access": "public"
   },
-  "trustedDependencies": ["@biomejs/biome"]
+  "trustedDependencies": ["@biomejs/biome", "bun"]
 }

plugins/genie/.claude-plugin/plugin.json

@@ -1,6 +1,6 @@
 {
   "name": "genie",
-  "version": "3.260318.7",
+  "version": "3.260319.1",
   "description": "Human-AI partnership for Claude Code. Share a terminal, orchestrate workers, evolve together. Brainstorm ideas, turn them into wishes, execute with /work, validate with /review, and ship as one team.",
   "author": {
     "name": "Namastex Labs"

plugins/genie/package.json

@@ -1,6 +1,6 @@
 {
   "name": "genie-plugin",
-  "version": "3.260318.7",
+  "version": "3.260319.1",
   "private": true,
   "description": "Runtime dependencies for genie bundled CLIs",
   "type": "module",

src/db/migrations/001_initial.sql

@@ -0,0 +1,131 @@
+-- 001_initial.sql — Core genie schema
+-- Tables: schedules, triggers, runs, heartbeats, audit_events, agent_checkpoints
+
+-- ============================================================================
+-- Schedules — cron-like schedule definitions
+-- ============================================================================
+CREATE TABLE schedules (
+  id TEXT PRIMARY KEY,
+  name TEXT NOT NULL,
+  cron_expression TEXT NOT NULL,
+  timezone TEXT DEFAULT 'UTC',
+  command TEXT,
+  metadata JSONB DEFAULT '{}',
+  status TEXT NOT NULL DEFAULT 'active'
+    CHECK (status IN ('active', 'paused', 'deleted')),
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
+  updated_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX idx_schedules_status ON schedules(status);
+CREATE INDEX idx_schedules_name ON schedules(name);
+
+-- ============================================================================
+-- Triggers — individual fire instances of a schedule
+-- ============================================================================
+CREATE TABLE triggers (
+  id TEXT PRIMARY KEY,
+  schedule_id TEXT NOT NULL REFERENCES schedules(id) ON DELETE CASCADE,
+  due_at TIMESTAMPTZ NOT NULL,
+  status TEXT NOT NULL DEFAULT 'pending'
+    CHECK (status IN ('pending', 'executing', 'completed', 'failed', 'skipped')),
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now(),
+  started_at TIMESTAMPTZ,
+  completed_at TIMESTAMPTZ
+);
+
+CREATE INDEX idx_triggers_schedule_id ON triggers(schedule_id);
+CREATE INDEX idx_triggers_status ON triggers(status);
+CREATE INDEX idx_triggers_due_pending ON triggers(due_at)
+  WHERE status = 'pending';
+
+-- ============================================================================
+-- Runs — execution attempts for a trigger
+-- ============================================================================
+CREATE TABLE runs (
+  id TEXT PRIMARY KEY,
+  trigger_id TEXT NOT NULL REFERENCES triggers(id) ON DELETE CASCADE,
+  worker_id TEXT,
+  status TEXT NOT NULL DEFAULT 'pending'
+    CHECK (status IN ('pending', 'leased', 'running', 'completed', 'failed', 'timeout', 'cancelled')),
+  output TEXT,
+  error TEXT,
+  started_at TIMESTAMPTZ,
+  completed_at TIMESTAMPTZ,
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX idx_runs_trigger_id ON runs(trigger_id);
+CREATE INDEX idx_runs_worker_id ON runs(worker_id);
+CREATE INDEX idx_runs_status ON runs(status);
+CREATE INDEX idx_runs_leased ON runs(status, started_at)
+  WHERE status IN ('leased', 'running');
+
+-- ============================================================================
+-- Heartbeats — worker liveness tracking
+-- ============================================================================
+CREATE TABLE heartbeats (
+  id TEXT PRIMARY KEY,
+  worker_id TEXT NOT NULL,
+  run_id TEXT REFERENCES runs(id) ON DELETE SET NULL,
+  status TEXT NOT NULL DEFAULT 'alive'
+    CHECK (status IN ('alive', 'idle', 'busy', 'dead')),
+  context JSONB DEFAULT '{}',
+  last_seen_at TIMESTAMPTZ NOT NULL DEFAULT now(),
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX idx_heartbeats_worker_id ON heartbeats(worker_id);
+CREATE INDEX idx_heartbeats_run_id ON heartbeats(run_id);
+CREATE INDEX idx_heartbeats_last_seen ON heartbeats(last_seen_at);
+
+-- ============================================================================
+-- Audit events — immutable log of state transitions
+-- ============================================================================
+CREATE TABLE audit_events (
+  id BIGINT GENERATED ALWAYS AS IDENTITY PRIMARY KEY,
+  entity_type TEXT NOT NULL,
+  entity_id TEXT NOT NULL,
+  event_type TEXT NOT NULL,
+  actor TEXT,
+  details JSONB DEFAULT '{}',
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX idx_audit_entity ON audit_events(entity_type, entity_id);
+CREATE INDEX idx_audit_created ON audit_events(created_at);
+CREATE INDEX idx_audit_actor ON audit_events(actor);
+
+-- ============================================================================
+-- Agent checkpoints — session resume state for agents
+-- ============================================================================
+CREATE TABLE agent_checkpoints (
+  worker_id TEXT PRIMARY KEY,
+  wish_slug TEXT,
+  group_name TEXT,
+  phase TEXT CHECK (phase IN ('executing', 'validating', 'reporting')),
+  context_summary TEXT,
+  dispatch_context TEXT,
+  branch_name TEXT,
+  last_checkpoint TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX idx_checkpoints_wish ON agent_checkpoints(wish_slug);
+CREATE INDEX idx_checkpoints_group ON agent_checkpoints(group_name);
+
+-- ============================================================================
+-- LISTEN/NOTIFY — real-time trigger-due notifications
+-- ============================================================================
+CREATE OR REPLACE FUNCTION notify_trigger_due()
+RETURNS trigger AS $$
+BEGIN
+  PERFORM pg_notify('genie_trigger_due', NEW.id::text);
+  RETURN NEW;
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE TRIGGER trg_notify_due
+  AFTER INSERT ON triggers
+  FOR EACH ROW
+  WHEN (NEW.status = 'pending')
+  EXECUTE FUNCTION notify_trigger_due();

src/db/migrations/002_scheduler_extensions.sql

@@ -0,0 +1,33 @@
+-- 002_scheduler_extensions.sql — Scheduler daemon extensions
+-- Adds lease columns to triggers, trace_id to runs, run_spec to schedules
+
+-- ============================================================================
+-- Schedules — add interval support and run specification
+-- ============================================================================
+ALTER TABLE schedules ADD COLUMN IF NOT EXISTS interval_ms BIGINT;
+ALTER TABLE schedules ADD COLUMN IF NOT EXISTS run_spec JSONB DEFAULT '{}';
+
+-- ============================================================================
+-- Triggers — add lease columns and idempotency key
+-- ============================================================================
+ALTER TABLE triggers ADD COLUMN IF NOT EXISTS idempotency_key TEXT;
+ALTER TABLE triggers ADD COLUMN IF NOT EXISTS leased_by TEXT;
+ALTER TABLE triggers ADD COLUMN IF NOT EXISTS leased_until TIMESTAMPTZ;
+
+CREATE UNIQUE INDEX IF NOT EXISTS idx_triggers_idempotency
+  ON triggers(idempotency_key)
+  WHERE idempotency_key IS NOT NULL;
+
+CREATE INDEX IF NOT EXISTS idx_triggers_leased
+  ON triggers(status, leased_until)
+  WHERE status = 'executing';
+
+-- ============================================================================
+-- Runs — add trace_id and lease_timeout_ms
+-- ============================================================================
+ALTER TABLE runs ADD COLUMN IF NOT EXISTS trace_id TEXT;
+ALTER TABLE runs ADD COLUMN IF NOT EXISTS lease_timeout_ms INTEGER DEFAULT 300000;
+ALTER TABLE runs ADD COLUMN IF NOT EXISTS exit_code INTEGER;
+
+CREATE INDEX IF NOT EXISTS idx_runs_trace_id ON runs(trace_id)
+  WHERE trace_id IS NOT NULL;

src/db/migrations/003_machine_snapshots.sql

@@ -0,0 +1,15 @@
+-- 003_machine_snapshots.sql — Machine state snapshots for scheduler observability
+
+CREATE TABLE IF NOT EXISTS machine_snapshots (
+  id TEXT PRIMARY KEY,
+  active_workers INTEGER NOT NULL DEFAULT 0,
+  active_teams INTEGER NOT NULL DEFAULT 0,
+  tmux_sessions INTEGER NOT NULL DEFAULT 0,
+  cpu_percent REAL,
+  memory_mb REAL,
+  context JSONB DEFAULT '{}',
+  created_at TIMESTAMPTZ NOT NULL DEFAULT now()
+);
+
+CREATE INDEX IF NOT EXISTS idx_machine_snapshots_created
+  ON machine_snapshots(created_at);

src/genie-commands/__tests__/session.test.ts

@@ -72,14 +72,14 @@ describe('buildClaudeCommand', () => {
     expect(cmd).not.toContain('--resume');
   });
 
-  test('with undefined continueName does NOT include --continue', () => {
+  test('with undefined continueName does NOT include --resume', () => {
     const cmd = buildClaudeCommand('genie', undefined, undefined);
-    expect(cmd).not.toContain('--continue');
+    expect(cmd).not.toContain('--resume');
   });
 
-  test('with a continueName DOES include --continue', () => {
+  test('with a continueName DOES include --resume', () => {
     const cmd = buildClaudeCommand('my-team', undefined, 'my-team');
-    expect(cmd).toContain("--continue 'my-team'");
+    expect(cmd).toContain("--resume 'my-team'");
   });
 
   test('file path is passed directly, no content inlined', () => {

src/genie-commands/session.ts

@@ -194,11 +194,11 @@ async function createSession(
 }
 
 /**
- * Launch Claude Code in a tmux pane with --continue fallback.
+ * Launch Claude Code in a tmux pane with --resume fallback.
  *
- * Tries --continue first (preserves conversation history). Waits ~3 seconds,
- * then checks #{pane_current_command} — if the pane shows a shell, --continue
- * failed (no prior conversation) so we retry fresh without --continue.
+ * Tries --resume first (preserves conversation history). Waits ~3 seconds,
+ * then checks #{pane_current_command} — if the pane shows a shell, --resume
+ * failed (no prior session) so we retry fresh without --resume.
  */
 async function launchWithContinueFallback(
   target: string,
@@ -209,17 +209,17 @@ async function launchWithContinueFallback(
   const continueCmd = buildClaudeCommand(windowName, systemPromptFile || undefined, continueName);
   const freshCmd = buildClaudeCommand(windowName, systemPromptFile || undefined, undefined);
 
-  // Try --continue first (preserves conversation history)
+  // Try --resume first (preserves conversation history)
   await tmux.executeTmux(`send-keys -t ${shellQuote(target)} ${shellQuote(continueCmd)} Enter`);
 
   // Wait briefly then check if CC is running or fell back to shell
-  // CC fails fast on missing conversations (~1s), 3s is conservative
+  // CC fails fast on missing sessions (~1s), 3s is conservative
   await new Promise((r) => setTimeout(r, 3000));
   const afterCmd = (await tmux.executeTmux(`display -t ${shellQuote(target)} -p '#{pane_current_command}'`)).trim();
 
   if (['bash', 'zsh', 'sh', 'fish'].includes(afterCmd)) {
-    // --continue failed, start fresh
-    console.log('No prior conversation found, starting fresh session...');
+    // --resume failed, start fresh
+    console.log('No prior session found, starting fresh session...');
     await tmux.executeTmux(`send-keys -t ${shellQuote(target)} ${shellQuote(freshCmd)} Enter`);
   }
 }