feat(plan): add Plan tab as the first project surface

A new home for everything that happens BEFORE building: - Vision — one-line elevator pitch (mirrors productVision) - Ideas — the "park-it" bin for raw thoughts - Tasks — what needs to happen next (open / done) - Decisions — log of "we chose X over Y because Z" Storage is appended under fs_projects.data.plan so no schema migration is needed. CRUD lives at /api/projects/[projectId]/plan. The bare project URL now redirects to /plan instead of /product, and the AI chat receives decisions + open tasks in its active-project context block — so it stops re-litigating settled questions and knows what's queued up. Made-with: Cursor
2026-04-29 18:02:02 -07:00
parent b706fa0e89
commit 5ecb0349d7
5 changed files with 899 additions and 7 deletions
--- a/app/api/projects/[projectId]/plan/route.ts
+++ b/app/api/projects/[projectId]/plan/route.ts
@@ -0,0 +1,220 @@
+/**
+ * /api/projects/[projectId]/plan
+ *
+ * Project-level "thinking" surface — the home of the Plan tab.
+ * Stores everything that happens BEFORE building:
+ *   - vision      — one-line elevator pitch (mirrored to data.productVision)
+ *   - ideas       — unstructured capture (the "park-it" bin)
+ *   - tasks       — what needs to happen next (status: open | done)
+ *   - decisions   — log of "we chose X over Y because Z"
+ *
+ * Storage lives under fs_projects.data.plan.{ideas,tasks,decisions}
+ * so we don't need a schema migration. Items are appended-and-mutated
+ * in place; we never load the full document back to the client without
+ * an ownership check.
+ *
+ * Methods:
+ *   GET                                   → full plan snapshot
+ *   POST  { kind: "vision",   text }      → set vision (also mirrors to productVision)
+ *   POST  { kind: "idea",     text }      → add idea
+ *   POST  { kind: "task",     text }      → add task (status="open")
+ *   POST  { kind: "decision", title, choice, why? } → add decision
+ *   PATCH { kind, id, ... }               → update one item (toggle task, edit text)
+ *   DELETE?kind=…&id=…                    → remove one item
+ */
+import { NextResponse } from "next/server";
+import { authSession } from "@/lib/auth/session-server";
+import { query } from "@/lib/db-postgres";
+
+interface Idea     { id: string; text: string; createdAt: string }
+interface Task     { id: string; text: string; status: "open" | "done"; createdAt: string; doneAt?: string }
+interface Decision { id: string; title: string; choice: string; why?: string; createdAt: string }
+interface PlanShape {
+  vision?: string;
+  ideas: Idea[];
+  tasks: Task[];
+  decisions: Decision[];
+}
+
+function emptyPlan(): PlanShape {
+  return { ideas: [], tasks: [], decisions: [] };
+}
+
+function newId(): string {
+  return Math.random().toString(36).slice(2, 11);
+}
+
+async function loadOwnedProject(projectId: string, email: string) {
+  const rows = await query<{ id: string; data: any }>(
+    `SELECT p.id, p.data FROM fs_projects p
+       JOIN fs_users u ON u.id = p.user_id
+      WHERE p.id = $1 AND u.data->>'email' = $2 LIMIT 1`,
+    [projectId, email],
+  );
+  return rows[0] ?? null;
+}
+
+function readPlan(data: any): PlanShape {
+  const raw = (data?.plan ?? {}) as Partial<PlanShape>;
+  return {
+    vision: data?.productVision ?? raw.vision,
+    ideas: Array.isArray(raw.ideas) ? raw.ideas : [],
+    tasks: Array.isArray(raw.tasks) ? raw.tasks : [],
+    decisions: Array.isArray(raw.decisions) ? raw.decisions : [],
+  };
+}
+
+async function writePlan(projectId: string, plan: PlanShape, alsoVision?: string) {
+  // Use a single jsonb_set call so we don't race with other writers.
+  // When the vision changes we also mirror it to productVision since
+  // it's the canonical field elsewhere in the app.
+  if (alsoVision !== undefined) {
+    await query(
+      `UPDATE fs_projects
+          SET data = jsonb_set(
+                       jsonb_set(data, '{plan}', $2::jsonb, true),
+                       '{productVision}', to_jsonb($3::text), true
+                     )
+        WHERE id = $1`,
+      [projectId, JSON.stringify({ ...plan, vision: undefined }), alsoVision],
+    );
+  } else {
+    await query(
+      `UPDATE fs_projects
+          SET data = jsonb_set(data, '{plan}', $2::jsonb, true)
+        WHERE id = $1`,
+      [projectId, JSON.stringify({ ...plan, vision: undefined })],
+    );
+  }
+}
+
+export async function GET(
+  _req: Request,
+  ctx: { params: Promise<{ projectId: string }> },
+) {
+  const { projectId } = await ctx.params;
+  const session = await authSession();
+  if (!session?.user?.email) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+
+  const project = await loadOwnedProject(projectId, session.user.email);
+  if (!project) return NextResponse.json({ error: "Not found" }, { status: 404 });
+
+  return NextResponse.json({ plan: readPlan(project.data) });
+}
+
+export async function POST(
+  req: Request,
+  ctx: { params: Promise<{ projectId: string }> },
+) {
+  const { projectId } = await ctx.params;
+  const session = await authSession();
+  if (!session?.user?.email) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+
+  const project = await loadOwnedProject(projectId, session.user.email);
+  if (!project) return NextResponse.json({ error: "Not found" }, { status: 404 });
+
+  const body = await req.json().catch(() => ({}));
+  const kind = String(body.kind ?? "");
+  const plan = readPlan(project.data);
+  const now = new Date().toISOString();
+
+  if (kind === "vision") {
+    const text = String(body.text ?? "").trim();
+    plan.vision = text;
+    await writePlan(projectId, plan, text);
+    return NextResponse.json({ plan });
+  }
+  if (kind === "idea") {
+    const text = String(body.text ?? "").trim();
+    if (!text) return NextResponse.json({ error: "text required" }, { status: 400 });
+    plan.ideas.unshift({ id: newId(), text, createdAt: now });
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  if (kind === "task") {
+    const text = String(body.text ?? "").trim();
+    if (!text) return NextResponse.json({ error: "text required" }, { status: 400 });
+    plan.tasks.unshift({ id: newId(), text, status: "open", createdAt: now });
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  if (kind === "decision") {
+    const title = String(body.title ?? "").trim();
+    const choice = String(body.choice ?? "").trim();
+    const why = body.why ? String(body.why).trim() : undefined;
+    if (!title || !choice) return NextResponse.json({ error: "title and choice required" }, { status: 400 });
+    plan.decisions.unshift({ id: newId(), title, choice, why, createdAt: now });
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  return NextResponse.json({ error: "unknown kind" }, { status: 400 });
+}
+
+export async function PATCH(
+  req: Request,
+  ctx: { params: Promise<{ projectId: string }> },
+) {
+  const { projectId } = await ctx.params;
+  const session = await authSession();
+  if (!session?.user?.email) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+
+  const project = await loadOwnedProject(projectId, session.user.email);
+  if (!project) return NextResponse.json({ error: "Not found" }, { status: 404 });
+
+  const body = await req.json().catch(() => ({}));
+  const { kind, id } = body;
+  const plan = readPlan(project.data);
+
+  if (kind === "task" && id) {
+    const t = plan.tasks.find((x) => x.id === id);
+    if (!t) return NextResponse.json({ error: "task not found" }, { status: 404 });
+    if (typeof body.text === "string") t.text = body.text.trim();
+    if (body.status === "open" || body.status === "done") {
+      t.status = body.status;
+      t.doneAt = body.status === "done" ? new Date().toISOString() : undefined;
+    }
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  if (kind === "idea" && id) {
+    const i = plan.ideas.find((x) => x.id === id);
+    if (!i) return NextResponse.json({ error: "idea not found" }, { status: 404 });
+    if (typeof body.text === "string") i.text = body.text.trim();
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  if (kind === "decision" && id) {
+    const d = plan.decisions.find((x) => x.id === id);
+    if (!d) return NextResponse.json({ error: "decision not found" }, { status: 404 });
+    if (typeof body.title === "string") d.title = body.title.trim();
+    if (typeof body.choice === "string") d.choice = body.choice.trim();
+    if (typeof body.why === "string") d.why = body.why.trim();
+    await writePlan(projectId, plan);
+    return NextResponse.json({ plan });
+  }
+  return NextResponse.json({ error: "unsupported patch" }, { status: 400 });
+}
+
+export async function DELETE(
+  req: Request,
+  ctx: { params: Promise<{ projectId: string }> },
+) {
+  const { projectId } = await ctx.params;
+  const session = await authSession();
+  if (!session?.user?.email) return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
+
+  const project = await loadOwnedProject(projectId, session.user.email);
+  if (!project) return NextResponse.json({ error: "Not found" }, { status: 404 });
+
+  const { searchParams } = new URL(req.url);
+  const kind = searchParams.get("kind") || "";
+  const id = searchParams.get("id") || "";
+  const plan = readPlan(project.data);
+
+  if (kind === "task")     plan.tasks     = plan.tasks.filter((x) => x.id !== id);
+  if (kind === "idea")     plan.ideas     = plan.ideas.filter((x) => x.id !== id);
+  if (kind === "decision") plan.decisions = plan.decisions.filter((x) => x.id !== id);
+
+  await writePlan(projectId, plan);
+  return NextResponse.json({ plan });
+}