Method materializeTasks

apps/sim/lib/copilot/vfs/workspace-vfs.ts:1879–1964

* Materialize mothership task chats as browsable conversation files. * Returns a summary for WORKSPACE.md generation.

(
    workspaceId: string,
    userId: string
  )

   * Returns a summary for WORKSPACE.md generation.
   */
  private async materializeTasks(
    workspaceId: string,
    userId: string
  ): Promise<WorkspaceMdData['tasks']> {
    try {
      const taskRows = await db
        .select({
          id: copilotChats.id,
          title: copilotChats.title,
          messageCount: sql<number>`COALESCE((
            SELECT COUNT(*) FROM copilot_messages cm
            WHERE cm.chat_id = ${copilotChats.id} AND cm.deleted_at IS NULL
          ), 0)`,
          messages: sql<unknown[]>`COALESCE((
            SELECT jsonb_agg(
              jsonb_build_object(
                'role', cm.content->>'role',
                'content', cm.content->'content',
                'contentBlocks', COALESCE((
                  SELECT jsonb_agg(jsonb_build_object('type', 'text', 'content', b.value->'content') ORDER BY b.ord)
                  FROM jsonb_array_elements(
                    CASE WHEN jsonb_typeof(cm.content->'contentBlocks') = 'array'
                         THEN cm.content->'contentBlocks'
                         ELSE '[]'::jsonb
                    END
                  ) WITH ORDINALITY AS b(value, ord)
                  WHERE b.value->>'type' = 'text'
                ), '[]'::jsonb)
              )
              ORDER BY cm.seq ASC NULLS LAST, cm.created_at ASC, cm.id ASC
            )
            FROM copilot_messages cm
            WHERE cm.chat_id = ${copilotChats.id}
              AND cm.deleted_at IS NULL
              AND cm.content->>'role' IN ('user', 'assistant')
          ), '[]'::jsonb)`,
          createdAt: copilotChats.createdAt,
          updatedAt: copilotChats.updatedAt,
        })
        .from(copilotChats)
        .where(
          and(
            eq(copilotChats.workspaceId, workspaceId),
            eq(copilotChats.userId, userId),
            eq(copilotChats.type, 'mothership')
          )
        )
        .orderBy(desc(copilotChats.updatedAt))
        .limit(5)

      for (const task of taskRows) {
        const title = task.title || 'Untitled task'
        const safeName = sanitizeName(title)
        const prefix = `tasks/${safeName}/`
        const messages = Array.isArray(task.messages) ? task.messages : []
        const messageCount = Number(task.messageCount) || 0

        this.files.set(