refactor(canvas): simplify-pass cleanups on the client remodel

Restore the canvas context editor's save path (it lost its writer in the
remodel): the editor now buffers locally and commits through the saveContext
mutation, and the freeform store shrinks to runtime-error + version-browse
state only. Scope revert/reset/sync invalidations to the one canvas via a
shared helper; poll builds at the record cadence until a build actually
starts; request explicit page sizes on paginated lists. Collapse the
duplicated channels query onto useTaskChannels, find the personal channel by
type everywhere, and collapse ChannelTaskRecord's duplicate id/taskId.
Extract the version-navigation arithmetic into a tested pure helper, replace
the currentCode sentinel with a real isEdit flag, seed the home canvas from
the shared contract constants, and delete dead code (orphaned freeform
version schemas, unreferenced channel client methods, the pruned
canvas-contracts validators, a stray local redis dump).

Generated-By: PostHog Code
Task-Id: b548ad79-52a8-496c-a064-6dfc4c61b688

Author: k11kirky

.gitignore

@@ -88,3 +88,4 @@ apps/mobile/ROADMAP.md
 # to the PostHog Visual Review product; the committed baseline is the signed
 # hash manifest apps/code/snapshots.yml.
 apps/code/.storybook/__snapshots__/
+dump.rdb

dump.rdb

@@ -2094,20 +2094,6 @@ export class PostHogAPIClient {
     return (await response.json()) as TaskChannel;
   }
 
-  async getTaskChannel(id: string): Promise<TaskChannel> {
-    const teamId = await this.getTeamId();
-    const urlPath = `/api/projects/${teamId}/task_channels/${encodeURIComponent(id)}/`;
-    const response = await this.api.fetcher.fetch({
-      method: "get",
-      url: new URL(`${this.api.baseUrl}${urlPath}`),
-      path: urlPath,
-    });
-    if (!response.ok) {
-      throw new Error(`Failed to fetch task channel: ${response.statusText}`);
-    }
-    return (await response.json()) as TaskChannel;
-  }
-
   // Rename a channel. The server normalizes the name (lowercase-dashed).
   async renameTaskChannel(id: string, name: string): Promise<TaskChannel> {
     const teamId = await this.getTeamId();
@@ -2262,49 +2248,6 @@ export class PostHogAPIClient {
     return all;
   }
 
-  // The task currently generating this channel's CONTEXT.md, shared across the
-  // project so any user sees an in-progress generation (instead of fragile
-  // local state). Returns null when nothing is generating.
-  async getChannelGenerationTask(channelId: string): Promise<string | null> {
-    const teamId = await this.getTeamId();
-    const urlPath = `/api/projects/${teamId}/task_channels/${encodeURIComponent(channelId)}/context_generation/`;
-    const response = await this.api.fetcher.fetch({
-      method: "get",
-      url: new URL(`${this.api.baseUrl}${urlPath}`),
-      path: urlPath,
-    });
-    if (response.status === 404) return null;
-    if (!response.ok) {
-      throw new Error(
-        `Failed to fetch channel generation task: ${response.statusText}`,
-      );
-    }
-    const data = (await response.json()) as { task_id?: string | null };
-    return data.task_id ?? null;
-  }
-
-  // Record (or clear, with null) the task generating this channel's CONTEXT.md.
-  async setChannelGenerationTask(
-    channelId: string,
-    taskId: string | null,
-  ): Promise<void> {
-    const teamId = await this.getTeamId();
-    const urlPath = `/api/projects/${teamId}/task_channels/${encodeURIComponent(channelId)}/context_generation/`;
-    const response = await this.api.fetcher.fetch({
-      method: "put",
-      url: new URL(`${this.api.baseUrl}${urlPath}`),
-      path: urlPath,
-      overrides: {
-        body: JSON.stringify({ task_id: taskId }),
-      },
-    });
-    if (!response.ok && response.status !== 404) {
-      throw new Error(
-        `Failed to set channel generation task: ${response.statusText}`,
-      );
-    }
-  }
-
   // A channel's system-announcement feed (context created, CONTEXT.md being
   // built), chronological. Durable + team-visible, rendered alongside task cards.
   async getChannelFeed(channelId: string): Promise<ChannelFeedMessage[]> {

packages/api-client/src/posthog-client.ts

@@ -1,7 +1,8 @@
 import { z } from "zod";
 
+// A filing is the task's `channel` field on the tasks API, so the task id IS
+// the record's identity — there is no separate row id.
 export const channelTaskRecordSchema = z.object({
-  id: z.string(),
   channelId: z.string(),
   taskId: z.string(),
   createdAt: z.number(),
@@ -17,4 +18,4 @@ export const fileChannelTaskInput = z.object({
   taskId: z.string().min(1),
 });
 
-export const channelTaskIdInput = z.object({ id: z.string().min(1) });
+export const unfileChannelTaskInput = z.object({ taskId: z.string().min(1) });

packages/core/src/canvas/channelTaskSchemas.ts

@@ -23,9 +23,9 @@ export class ChannelTasksService {
     const rows = await this.api.listPaginated<ApiTask>(
       `tasks/?channel=${encodeURIComponent(channelId)}`,
       "list channel tasks",
+      { limit: 200 },
     );
     return rows.map((task) => ({
-      id: task.id,
       channelId,
       taskId: task.id,
       createdAt: Date.parse(task.created_at) || 0,
@@ -38,7 +38,6 @@ export class ChannelTasksService {
   }): Promise<ChannelTaskRecord> {
     const task = await this.setChannel(input.taskId, input.channelId);
     return {
-      id: task.id,
       channelId: input.channelId,
       taskId: task.id,
       createdAt: Date.parse(task.created_at) || 0,

packages/core/src/canvas/channelTasksService.ts

@@ -1,3 +1,8 @@
+import {
+  CANVAS_COMPONENT_PATH,
+  CANVAS_ENTRY_HTML,
+  CANVAS_SOURCE_SCHEMA_VERSION,
+} from "@posthog/shared";
 import { inject, injectable } from "inversify";
 import {
   type CanvasBuildActionInput,
@@ -19,7 +24,7 @@ import { PROJECT_API_CLIENT, type ProjectApiClient } from "./projectApiClient";
 const HOME_CANVAS_NAME = "Home";
 
 // The entry shell for a client-authored single-file project (the home canvas
-// seed): the runtime mounts the default export of src/canvas.tsx.
+// seed): the runtime mounts the default export of the canvas component file.
 const SINGLE_FILE_INDEX_HTML = `<!doctype html>
 <html>
   <head>
@@ -28,7 +33,7 @@ const SINGLE_FILE_INDEX_HTML = `<!doctype html>
   </head>
   <body>
     <div id="root"></div>
-    <script type="module" src="/src/canvas.tsx"></script>
+    <script type="module" src="/${CANVAS_COMPONENT_PATH}"></script>
   </body>
 </html>
 `;
@@ -127,6 +132,7 @@ export class DashboardsService {
     const rows = await this.api.listPaginated<ApiCanvas>(
       `canvases/?channel=${encodeURIComponent(channelId)}`,
       "list canvases",
+      { limit: 200 },
     );
     return rows.map(toRecord);
   }
@@ -326,6 +332,7 @@ export class DashboardsService {
     const rows = await this.api.listPaginated<ApiCanvas>(
       `canvases/?channel=${encodeURIComponent(channelId)}&is_home=true`,
       "find home canvas",
+      { limit: 200 },
     );
     return rows.length ? toRecord(rows[0]) : null;
   }
@@ -338,12 +345,12 @@ export class DashboardsService {
     channelId: string,
   ): Promise<DashboardRecord> {
     const project = {
-      schemaVersion: 1,
+      schemaVersion: CANVAS_SOURCE_SCHEMA_VERSION,
       files: {
-        "index.html": SINGLE_FILE_INDEX_HTML,
-        "src/canvas.tsx": buildHomeCanvasCode(channelId, record.id),
+        [CANVAS_ENTRY_HTML]: SINGLE_FILE_INDEX_HTML,
+        [CANVAS_COMPONENT_PATH]: buildHomeCanvasCode(channelId, record.id),
       },
-      entryHtml: "index.html",
+      entryHtml: CANVAS_ENTRY_HTML,
       dependencies: { react: "19.0.0" },
       canvasSdkVersion: "0.1.0",
       capabilities: {
@@ -407,7 +414,7 @@ function sql(v: string): string {
   return "'" + String(v).replace(/'/g, "''") + "'";
 }
 
-type Row = { id: string; title: string; ref: string | null; createdAt: string };
+type Row = { id: string; title: string; createdAt: string };
 
 // Paginated reader for the channel's canvases or tasks, newest first.
 function useChannelRows(kind: "dashboard" | "task") {
@@ -434,7 +441,6 @@ function useChannelRows(kind: "dashboard" | "task") {
       const batch: Row[] = ((res && res.results) || []).map((r: any[]) => ({
         id: String(r[0]),
         title: String(r[1]),
-        ref: kind === "task" ? String(r[0]) : null,
         createdAt: String(r[2]),
       }));
       offsetRef.current += batch.length;
@@ -665,10 +671,7 @@ function TasksSection() {
           key={r.id}
           title={r.title}
           meta={r.createdAt.slice(0, 10)}
-          // A task row's file-system id is NOT the task id; the task id is the
-          // row's ref (ChannelTasksService files it as ref=taskId). Only rows
-          // with a ref are navigable.
-          onClick={r.ref ? () => ph.navigate?.toTask(r.ref as string) : undefined}
+          onClick={() => ph.navigate?.toTask(r.id)}
         />
       ))}
     </Section>

packages/core/src/canvas/dashboardsService.ts

@@ -5,44 +5,6 @@ import { z } from "zod";
 // generation path can resolve the right system prompt.
 export const FREEFORM_TEMPLATE_ID = "freeform";
 
-// A single point in a freeform canvas's edit history. Every agent turn appends
-// one full-file snapshot (Q7: full-file rewrite); the user can revert to any of
-// them and the `currentVersionId` pointer is what publishes. We keep whole-file
-// snapshots rather than diffs because canvases are small and a snapshot can
-// never fail to reconstruct.
-export const freeformVersionSchema = z.object({
-  id: z.string(),
-  // The complete single-file React source for this version.
-  code: z.string(),
-  // The author-written context (markdown) passed to the agent, as it stood for
-  // this version. Snapshotted so reverting restores the context too. Absent on
-  // versions saved before the Context tab existed.
-  context: z.string().optional(),
-  // The user prompt that produced this version (absent for the seed/empty one,
-  // and for a version created by a context-only edit).
-  prompt: z.string().optional(),
-  // Epoch ms the version was created.
-  createdAt: z.number(),
-});
-export type FreeformVersion = z.infer<typeof freeformVersionSchema>;
-
-// The freeform-specific payload that rides in a canvas's file-system `meta` blob.
-export const freeformCanvasSchema = z.object({
-  // The currently-rendered source (mirrors the version pointed to by
-  // currentVersionId; duplicated so the renderer needs only this field).
-  code: z.string(),
-  // Full, ordered edit history (oldest first). Always contains >= 1 entry once
-  // the agent has produced anything.
-  versions: z.array(freeformVersionSchema).default([]),
-  // Which version is live. Undo/redo moves this pointer; a new agent turn
-  // truncates any "redo" tail (Q8: linear-discard) and appends.
-  currentVersionId: z.string().optional(),
-  // The live author-written context (markdown), mirrors the version pointed to by
-  // currentVersionId. Prepended to every agent turn so the build is anchored to it.
-  context: z.string().default(""),
-});
-export type FreeformCanvas = z.infer<typeof freeformCanvasSchema>;
-
 // ---------------------------------------------------------------------------
 // Canvas data avenue: the host-side query the postMessage `ph.query` shim calls.
 // Routed through PostHog's cached query runner (the same avenue insights use, so

packages/core/src/canvas/freeformSchemas.ts

@@ -40,10 +40,21 @@ export class ProjectApiClient {
     return (await res.json()) as T;
   }
 
-  /** List a DRF-paginated collection, walking `next` links until exhausted. */
-  async listPaginated<T>(path: string, errorLabel: string): Promise<T[]> {
+  /**
+   * List a DRF-paginated collection, walking `next` links until exhausted.
+   * `options.limit` sets the page size on the first request (subsequent pages
+   * follow the server's `next` links, which carry the limit forward).
+   */
+  async listPaginated<T>(
+    path: string,
+    errorLabel: string,
+    options?: { limit?: number },
+  ): Promise<T[]> {
     const all: T[] = [];
-    let suffix = path;
+    let suffix =
+      options?.limit != null
+        ? `${path}${path.includes("?") ? "&" : "?"}limit=${options.limit}`
+        : path;
     for (let i = 0; i < MAX_PAGES; i++) {
       const page = await this.json<{ next: string | null; results: T[] }>(
         suffix,

packages/core/src/canvas/projectApiClient.ts

@@ -1,8 +1,8 @@
 import {
-  channelTaskIdInput,
   channelTaskRecordSchema,
   fileChannelTaskInput,
   listChannelTasksInput,
+  unfileChannelTaskInput,
 } from "@posthog/core/canvas/channelTaskSchemas";
 import { CHANNEL_TASKS_SERVICE } from "@posthog/core/canvas/identifiers";
 import type { IChannelTasksService } from "@posthog/core/canvas/services";
@@ -27,10 +27,10 @@ export const channelTasksRouter = router({
         .file(input),
     ),
   unfile: publicProcedure
-    .input(channelTaskIdInput)
+    .input(unfileChannelTaskInput)
     .mutation(({ ctx, input }) =>
       ctx.container
         .get<IChannelTasksService>(CHANNEL_TASKS_SERVICE)
-        .unfile(input.id),
+        .unfile(input.taskId),
     ),
 });