diff --git a/apps/mail/components/ui/nav-main.tsx b/apps/mail/components/ui/nav-main.tsx index a6862fcc4e..33158bd09b 100644 --- a/apps/mail/components/ui/nav-main.tsx +++ b/apps/mail/components/ui/nav-main.tsx @@ -4,7 +4,6 @@ import { useCommandPalette } from '../context/command-palette-context.jsx'; import { LabelDialog } from '@/components/labels/label-dialog'; import { useActiveConnection } from '@/hooks/use-connections'; import { useMutation, useQuery } from '@tanstack/react-query'; -import { useSearchValue } from '@/hooks/use-search-value.js'; import Intercom, { show } from '@intercom/messenger-js-sdk'; import { MessageSquare, OldPhone } from '../icons/icons'; import { useSidebar } from '../context/sidebar-context'; diff --git a/apps/server/src/pipelines.effect.ts b/apps/server/src/pipelines.effect.ts index 86d5e70b13..ee9fcf879f 100644 --- a/apps/server/src/pipelines.effect.ts +++ b/apps/server/src/pipelines.effect.ts @@ -739,7 +739,7 @@ export const runThreadWorkflow = ( remove: labelsToRemove, }); await agent.modifyLabels([threadId.toString()], labelsToAdd, labelsToRemove); - await agent.syncThread(threadId.toString()); + await agent.syncThread({ threadId: threadId.toString() }); console.log('[THREAD_WORKFLOW] Successfully modified thread labels'); } else { console.log('[THREAD_WORKFLOW] No label changes needed - labels already match'); diff --git a/apps/server/src/routes/agent/mcp.ts b/apps/server/src/routes/agent/mcp.ts index 41a5f72542..5f1b713798 100644 --- a/apps/server/src/routes/agent/mcp.ts +++ b/apps/server/src/routes/agent/mcp.ts @@ -27,7 +27,7 @@ import { createDb } from '../../db'; import { generateText } from 'ai'; import z from 'zod'; -export class ZeroMCP extends McpAgent { +export class ZeroMCP extends McpAgent, { userId: string }> { server = new McpServer({ name: 'zero-mcp', version: '1.0.0', @@ -36,10 +36,6 @@ export class ZeroMCP extends McpAgent { activeConnectionId: string | undefined; - constructor(ctx: DurableObjectState, env: Env) { - super(ctx, env); - } - async init(): Promise { const { db, conn } = createDb(env.HYPERDRIVE.connectionString); const _connection = await db.query.connection.findFirst({ diff --git a/apps/server/src/routes/agent/rpc.ts b/apps/server/src/routes/agent/rpc.ts index 9692decb71..5cb4a1a5a6 100644 --- a/apps/server/src/routes/agent/rpc.ts +++ b/apps/server/src/routes/agent/rpc.ts @@ -90,7 +90,7 @@ export class AgentRpcDO extends RpcTarget { return result; } - async syncThread(threadId: string) { + async syncThread({ threadId }: { threadId: string }) { return await this.mainDo.syncThread({ threadId }); }