decocms
diff --git a/‎AGENTS.md‎
Lines changed: 23 additions & 0 deletions b/‎AGENTS.md‎
Lines changed: 23 additions & 0 deletions
diff --git a/‎apps/docs/package.json‎
Lines changed: 0 additions & 1 deletion b/‎apps/docs/package.json‎
Lines changed: 0 additions & 1 deletion
diff --git a/‎apps/mesh/src/storage/threads.ts‎
Lines changed: 67 additions & 7 deletions b/‎apps/mesh/src/storage/threads.ts‎
Lines changed: 67 additions & 7 deletions
diff --git a/‎apps/mesh/src/tools/monitoring/stats.ts‎
Lines changed: 3 additions & 2 deletions b/‎apps/mesh/src/tools/monitoring/stats.ts‎
Lines changed: 3 additions & 2 deletions
diff --git a/‎apps/mesh/src/tools/thread/list.ts‎
Lines changed: 33 additions & 1 deletion b/‎apps/mesh/src/tools/thread/list.ts‎
Lines changed: 33 additions & 1 deletion
diff --git a/‎apps/mesh/src/tools/thread/schema.ts‎
Lines changed: 12 additions & 0 deletions b/‎apps/mesh/src/tools/thread/schema.ts‎
Lines changed: 12 additions & 0 deletions
diff --git a/‎apps/mesh/src/web/components/chat/chat-context.tsx‎
Lines changed: 8 additions & 0 deletions b/‎apps/mesh/src/web/components/chat/chat-context.tsx‎
Lines changed: 8 additions & 0 deletions
diff --git a/‎apps/mesh/src/web/components/chat/context.tsx‎
Lines changed: 2 additions & 0 deletions b/‎apps/mesh/src/web/components/chat/context.tsx‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎apps/mesh/src/web/components/chat/message/assistant.tsx‎
Lines changed: 2 additions & 2 deletions b/‎apps/mesh/src/web/components/chat/message/assistant.tsx‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎apps/mesh/src/web/components/chat/message/parts/tool-call-part/generic.tsx‎
Lines changed: 31 additions & 12 deletions b/‎apps/mesh/src/web/components/chat/message/parts/tool-call-part/generic.tsx‎
Lines changed: 31 additions & 12 deletions
@@ -59,6 +59,29 @@ bun run --cwd=apps/mesh migrate
 bun run --cwd=apps/mesh better-auth:migrate
 ```
 
+#### Querying local postgres during development
+The dev server uses embedded postgres on a **dynamic port**. To query it while `bun run dev` is running:
+
+1. Find the port:
+```bash
+ps aux | grep "postgres -D" | grep -v grep
+# Look for -p <PORT> at the end of the command
+```
+
+2. Run queries via a bun inline script (uses the `pg` package from apps/mesh):
+```bash
+cat << 'EOF' | bun run --cwd apps/mesh -
+import pg from "pg";
+const client = new pg.Client("postgresql://postgres:postgres@localhost:<PORT>/postgres");
+await client.connect();
+const { rows } = await client.query("SELECT * FROM <table> LIMIT 5");
+console.log(JSON.stringify(rows, null, 2));
+await client.end();
+EOF
+```
+
+Replace `<PORT>` with the port found in step 1. The `--cwd apps/mesh` is required so bun resolves the `pg` dependency from the mesh workspace.
+
 ### Build & Deploy
 ```bash
 # Build runtime package
 
@@ -22,7 +22,6 @@
   },
   "devDependencies": {
     "@tailwindcss/typography": "^0.5.16",
-    "typescript": "^5.9.3",
     "wrangler": "^4.40.3"
   },
   "engines": {
 
@@ -67,7 +67,16 @@ export class OrgScopedThreadStorage {
 
   list(
     createdBy?: string,
-    options?: { limit?: number; offset?: number; virtualMcpId?: string },
+    options?: {
+      limit?: number;
+      offset?: number;
+      virtualMcpId?: string;
+      startDate?: string;
+      endDate?: string;
+      search?: string;
+      status?: string;
+      agentId?: string;
+    },
   ): Promise<{ threads: Thread[]; total: number }> {
     return this.inner.list(this.requireOrg(), createdBy, options);
   }
@@ -237,7 +246,16 @@ export class SqlThreadStorage implements ThreadStoragePort {
   async list(
     organizationId: string,
     createdBy?: string,
-    options?: { limit?: number; offset?: number; virtualMcpId?: string },
+    options?: {
+      limit?: number;
+      offset?: number;
+      virtualMcpId?: string;
+      startDate?: string;
+      endDate?: string;
+      search?: string;
+      status?: string;
+      agentId?: string;
+    },
   ): Promise<{ threads: Thread[]; total: number }> {
     let query = this.db
       .selectFrom("threads")
@@ -249,8 +267,30 @@ export class SqlThreadStorage implements ThreadStoragePort {
     if (createdBy) {
       query = query.where("created_by", "=", createdBy);
     }
-    if (options?.virtualMcpId) {
-      query = query.where("virtual_mcp_id", "=", options.virtualMcpId);
+    const virtualMcpFilter = options?.virtualMcpId ?? options?.agentId;
+    if (virtualMcpFilter) {
+      query = query.where("virtual_mcp_id", "=", virtualMcpFilter);
+    }
+    if (options?.startDate) {
+      // updated_at is stored as ISO text — string comparison is correct for ISO dates
+      query = query.where(
+        "updated_at",
+        ">=",
+        options.startDate as unknown as Date,
+      );
+    }
+    if (options?.endDate) {
+      query = query.where(
+        "updated_at",
+        "<=",
+        options.endDate as unknown as Date,
+      );
+    }
+    if (options?.search) {
+      query = query.where("title", "ilike", `%${options.search}%`);
+    }
+    if (options?.status) {
+      query = query.where("status", "=", options.status as ThreadStatus);
     }
 
     let countQuery = this.db
@@ -262,11 +302,31 @@ export class SqlThreadStorage implements ThreadStoragePort {
     if (createdBy) {
       countQuery = countQuery.where("created_by", "=", createdBy);
     }
-    if (options?.virtualMcpId) {
+    if (virtualMcpFilter) {
+      countQuery = countQuery.where("virtual_mcp_id", "=", virtualMcpFilter);
+    }
+    if (options?.startDate) {
+      countQuery = countQuery.where(
+        "updated_at",
+        ">=",
+        options.startDate as unknown as Date,
+      );
+    }
+    if (options?.endDate) {
+      countQuery = countQuery.where(
+        "updated_at",
+        "<=",
+        options.endDate as unknown as Date,
+      );
+    }
+    if (options?.search) {
+      countQuery = countQuery.where("title", "ilike", `%${options.search}%`);
+    }
+    if (options?.status) {
       countQuery = countQuery.where(
-        "virtual_mcp_id",
+        "status",
         "=",
-        options.virtualMcpId,
+        options.status as ThreadStatus,
       );
     }
 
 
@@ -33,10 +33,11 @@ export const MONITORING_STATS = defineTool({
       .optional()
       .describe("Filter by end date (ISO 8601 datetime string)"),
     interval: z
-      .enum(["1m", "1h", "1d"])
+      .string()
+      .regex(/^\d+[mhd]$/)
       .optional()
       .describe(
-        "Bucket interval for timeseries data. When provided, returns timeseries array.",
+        "Bucket interval for timeseries data (e.g. 1m, 5m, 2h, 1d). When provided, returns timeseries array.",
       ),
     connectionIds: z
       .array(z.string())
 
@@ -23,6 +23,32 @@ const ThreadListInputSchema = CollectionListInputSchema.extend({
       virtual_mcp_id: z.string().optional(),
     })
     .optional(),
+  startDate: z
+    .string()
+    .datetime()
+    .optional()
+    .describe("Filter threads updated at or after this ISO timestamp"),
+  endDate: z
+    .string()
+    .datetime()
+    .optional()
+    .describe("Filter threads updated at or before this ISO timestamp"),
+  search: z
+    .string()
+    .optional()
+    .describe("Full-text search on thread title (case-insensitive)"),
+  status: z
+    .string()
+    .optional()
+    .describe("Filter by thread status (e.g. completed, failed, in_progress)"),
+  userId: z
+    .string()
+    .optional()
+    .describe("Filter by the user who created the thread"),
+  agentId: z
+    .string()
+    .optional()
+    .describe("Filter by agent (connection or virtual MCP) ID"),
 });
 
 /**
@@ -58,7 +84,8 @@ export const COLLECTION_THREADS_LIST = defineTool({
     const virtualMcpId = input.where?.virtual_mcp_id;
     // "me" is a reserved value meaning "filter by the authenticated user"
     const createdBy =
-      input.where?.created_by === "me" ? userId : input.where?.created_by;
+      input.userId ??
+      (input.where?.created_by === "me" ? userId : input.where?.created_by);
 
     const { threads, total } = triggerIds?.length
       ? await ctx.storage.threads.listByTriggerIds(triggerIds, {
@@ -69,6 +96,11 @@ export const COLLECTION_THREADS_LIST = defineTool({
           limit,
           offset,
           virtualMcpId,
+          startDate: input.startDate,
+          endDate: input.endDate,
+          search: input.search,
+          status: input.status,
+          agentId: input.agentId,
         });
 
     const hasMore = offset + limit < total;
 
@@ -55,6 +55,18 @@ export const ThreadEntitySchema = z.object({
     .string()
     .nullable()
     .describe("User ID who last updated the thread"),
+  virtual_mcp_id: z
+    .string()
+    .optional()
+    .describe("Virtual MCP (agent) this thread was initiated with"),
+  // Typed as a loose record to stay compatible with the Kysely storage type
+  // (Thread.run_config: Record<string, unknown> | null). Callers that need the
+  // typed shape should parse with PersistedRunConfigSchema from run-config.ts.
+  run_config: z
+    .record(z.string(), z.unknown())
+    .nullable()
+    .optional()
+    .describe("Persisted run configuration (contains agent and model info)"),
 });
 
 export type ThreadEntity = z.infer<typeof ThreadEntitySchema>;
 
@@ -754,6 +754,10 @@ export function useChatStream(): ChatStreamContextValue {
   return ctx;
 }
 
+export function useOptionalChatStream(): ChatStreamContextValue | null {
+  return useContext(ChatStreamCtx);
+}
+
 export function useChatTask(): ChatTaskContextValue {
   const ctx = useContext(ChatTaskCtx);
   if (!ctx)
@@ -768,6 +772,10 @@ export function useChatPrefs(): ChatPrefsContextValue {
   return ctx;
 }
 
+export function useOptionalChatPrefs(): ChatPrefsContextValue | null {
+  return useContext(ChatPrefsCtx);
+}
+
 export function useChatBridge(): ChatBridgeValue {
   return useContext(ChatBridgeCtx);
 }
@@ -13,7 +13,9 @@ export {
   ActiveTaskProvider,
   useChatTask,
   useChatStream,
+  useOptionalChatStream,
   useChatPrefs,
+  useOptionalChatPrefs,
   useChatBridge,
   type ChatStreamContextValue,
   type ChatTaskContextValue,
 
@@ -15,7 +15,7 @@ import {
 import { SmartAutoScroll } from "./smart-auto-scroll.tsx";
 import { type DataParts, useFilterParts } from "./use-filter-parts.ts";
 import { addUsage, emptyUsageStats } from "@decocms/mesh-sdk";
-import { useChatStream } from "../context.tsx";
+import { useOptionalChatStream } from "../context.tsx";
 
 type ThinkingStage = "planning" | "thinking";
 
@@ -374,7 +374,7 @@ export function MessageAssistant({
   className,
   isLast = false,
 }: MessageAssistantProps) {
-  const { isRunInProgress } = useChatStream();
+  const { isRunInProgress = false } = useOptionalChatStream() ?? {};
   const isStreaming = status === "streaming";
   const isSubmitted = status === "submitted";
   const isLoading = isStreaming || isSubmitted;
 
@@ -3,7 +3,10 @@
 import { contentBlocksToTiptapDoc } from "@/mcp-apps/content-blocks.ts";
 import { MCPAppRenderer as MCPAppIframeRenderer } from "@/mcp-apps/mcp-app-renderer.tsx";
 import { getUIResourceUri } from "@/mcp-apps/types.ts";
-import { useChatStream, useChatPrefs } from "@/web/components/chat/context.tsx";
+import {
+  useOptionalChatStream,
+  useOptionalChatPrefs,
+} from "@/web/components/chat/context.tsx";
 import { Button } from "@deco/ui/components/button.tsx";
 import {
   Tooltip,
@@ -29,9 +32,9 @@ import {
 } from "@untitledui/icons";
 import type { DynamicToolUIPart, ToolUIPart } from "ai";
 import type React from "react";
-import { Suspense } from "react";
+import { Suspense, useContext } from "react";
 import { ErrorBoundary } from "@/web/components/error-boundary.tsx";
-import { useChatPanel } from "@/web/contexts/panel-context.tsx";
+import { PanelContext } from "@/web/contexts/panel-context.tsx";
 import { getToolPartErrorText, safeStringify } from "../utils.ts";
 import { ToolCallShell } from "./common.tsx";
 import { getEffectiveState, getFriendlyToolName } from "./utils.tsx";
@@ -166,10 +169,24 @@ export function GenericToolCallPart({
         : part.type.replace("tool-", "") || "Tool";
   const friendlyName = getFriendlyToolName(toolName);
 
-  const { sendMessage } = useChatStream();
-  const { selectedVirtualMcp, setAppContext, clearAppContext } = useChatPrefs();
+  const chatStream = useOptionalChatStream();
+  const chatPrefs = useOptionalChatPrefs();
   const { org } = useProjectContext();
-  const [, setChatOpen] = useChatPanel();
+
+  // Panel context may not be available when rendering read-only thread history
+  // (e.g. monitoring Threads tab), so we read the context directly.
+  const panelControls = useContext(PanelContext);
+  const setChatOpen = panelControls
+    ? (open: boolean) => {
+        if (open) {
+          panelControls.chatPanelRef.current?.resize(
+            Math.min(panelControls.chatPanelWidth, 35),
+          );
+        } else {
+          panelControls.chatPanelRef.current?.collapse();
+        }
+      }
+    : undefined;
 
   const uiResourceUri = getUIResourceUri(toolMeta);
 
@@ -181,16 +198,16 @@ export function GenericToolCallPart({
     toolMeta.connectionId != null &&
     toolMeta.connectionId !== ""
       ? String(toolMeta.connectionId)
-      : (selectedVirtualMcp?.id ?? null);
+      : (chatPrefs?.selectedVirtualMcp?.id ?? null);
 
   const hasMCPApp = !!uiResourceUri && part.state === "output-available";
   const sourceId = connectionId ? `${connectionId}:${toolName}` : null;
 
   const handleAppMessage = (params: McpUiMessageRequest["params"]) => {
     const doc = contentBlocksToTiptapDoc(params.content);
     if (doc.content.length > 0) {
-      setChatOpen(true);
-      sendMessage(doc);
+      setChatOpen?.(true);
+      chatStream?.sendMessage(doc);
     }
   };
 
@@ -289,12 +306,14 @@ export function GenericToolCallPart({
               toolMeta={toolMeta as Record<string, unknown> | undefined}
               onMessage={handleAppMessage}
               onUpdateModelContext={
-                sourceId
-                  ? (params) => setAppContext(sourceId, params)
+                sourceId && chatPrefs
+                  ? (params) => chatPrefs.setAppContext(sourceId, params)
                   : undefined
               }
               onTeardown={
-                sourceId ? () => clearAppContext(sourceId) : undefined
+                sourceId && chatPrefs
+                  ? () => chatPrefs.clearAppContext(sourceId)
+                  : undefined
               }
             />
           </Suspense>
Original file line number	Diff line number	Diff line change
`@@ -754,6 +754,10 @@ export function useChatStream(): ChatStreamContextValue {`
`754`	`754`	`return ctx;`
`755`	`755`	`}`
`756`	`756`
	`757`	`+export function useOptionalChatStream(): ChatStreamContextValue \| null {`
	`758`	`+ return useContext(ChatStreamCtx);`
	`759`	`+}`
	`760`	`+`
`757`	`761`	`export function useChatTask(): ChatTaskContextValue {`
`758`	`762`	`const ctx = useContext(ChatTaskCtx);`
`759`	`763`	`if (!ctx)`
`@@ -768,6 +772,10 @@ export function useChatPrefs(): ChatPrefsContextValue {`
`768`	`772`	`return ctx;`
`769`	`773`	`}`
`770`	`774`
	`775`	`+export function useOptionalChatPrefs(): ChatPrefsContextValue \| null {`
	`776`	`+ return useContext(ChatPrefsCtx);`
	`777`	`+}`
	`778`	`+`
`771`	`779`	`export function useChatBridge(): ChatBridgeValue {`
`772`	`780`	`return useContext(ChatBridgeCtx);`
`773`	`781`	`}`