Mail-0
diff --git a/‎apps/mail/components/ui/app-sidebar.tsx‎
Lines changed: 21 additions & 21 deletions b/‎apps/mail/components/ui/app-sidebar.tsx‎
Lines changed: 21 additions & 21 deletions
diff --git a/‎apps/server/src/env.ts‎
Lines changed: 1 addition & 0 deletions b/‎apps/server/src/env.ts‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎apps/server/src/lib/server-utils.ts‎
Lines changed: 51 additions & 14 deletions b/‎apps/server/src/lib/server-utils.ts‎
Lines changed: 51 additions & 14 deletions
@@ -7,10 +7,10 @@ import {
 } from '@/components/ui/dialog';
 import { Sidebar, SidebarContent, SidebarFooter, SidebarHeader } from '@/components/ui/sidebar';
 import { navigationConfig, bottomNavItems } from '@/config/navigation';
-import { useTRPC } from '@/providers/query-provider';
+// import { useTRPC } from '@/providers/query-provider';
 import { useSidebar } from '@/components/ui/sidebar';
 import { CreateEmail } from '../create/create-email';
-import { useMutation } from '@tanstack/react-query';
+// import { useMutation } from '@tanstack/react-query';
 import { PencilCompose, X } from '../icons/icons';
 import { useBilling } from '@/hooks/use-billing';
 import { useIsMobile } from '@/hooks/use-mobile';
@@ -22,16 +22,16 @@ import { useStats } from '@/hooks/use-stats';
 import { useLocation } from 'react-router';
 import { cn, FOLDERS } from '@/lib/utils';
 import { m } from '@/paraglide/messages';
-import { Video } from 'lucide-react';
+// import { Video } from 'lucide-react';
 import { NavUser } from './nav-user';
 import { NavMain } from './nav-main';
 import { useQueryState } from 'nuqs';
-import { toast } from 'sonner';
+// import { toast } from 'sonner';
 
 export function AppSidebar({ ...props }: React.ComponentProps<typeof Sidebar>) {
   const { isPro, isLoading } = useBilling();
-  const trpc = useTRPC();
-  const { mutateAsync: createMeet } = useMutation(trpc.meet.create.mutationOptions());
+  //   const trpc = useTRPC();
+  //   const { mutateAsync: createMeet } = useMutation(trpc.meet.create.mutationOptions());
   const [showUpgrade, setShowUpgrade] = useState(() => {
     if (typeof window !== 'undefined') {
       return localStorage.getItem('hideUpgradeCard') !== 'true';
@@ -76,18 +76,18 @@ export function AppSidebar({ ...props }: React.ComponentProps<typeof Sidebar>) {
   const showComposeButton = currentSection === 'mail';
   const { state } = useSidebar();
 
-  const handleCreateMeet = async () => {
-    try {
-      const {
-        data: { id },
-      } = await createMeet();
-      navigator.clipboard.writeText(`https://meet.0.email/${id}`);
-      toast.success('Meeting linked copied to clipboard');
-    } catch (error) {
-      console.error(error);
-      toast.error('Failed to create meeting');
-    }
-  };
+  //   const handleCreateMeet = async () => {
+  //     try {
+  //       const {
+  //         data: { id },
+  //       } = await createMeet();
+  //       navigator.clipboard.writeText(`https://meet.0.email/${id}`);
+  //       toast.success('Meeting linked copied to clipboard');
+  //     } catch (error) {
+  //       console.error(error);
+  //       toast.error('Failed to create meeting');
+  //     }
+  //   };
 
   return (
     <div>
@@ -104,17 +104,17 @@ export function AppSidebar({ ...props }: React.ComponentProps<typeof Sidebar>) {
 
             {showComposeButton && (
               <div className="flex gap-1">
-                <div className={cn(isPro ? 'w-[80%]' : 'w-full')}>
+                <div className={cn('w-full')}>
                   <ComposeButton />
                 </div>
-                {isPro ? (
+                {/* {isPro ? (
                   <button
                     onClick={handleCreateMeet}
                     className="hover:bg-muted-foreground/10 inline-flex h-8 w-[20%] items-center justify-center gap-1 overflow-hidden rounded-lg border bg-white px-1.5 dark:border-none dark:bg-[#313131]"
                   >
                     <Video className="text-muted-foreground h-4 w-4" />
                   </button>
-                ) : null}
+                ) : null} */}
               </div>
             )}
           </SidebarHeader>
 
@@ -93,6 +93,7 @@ export type ZeroEnv = {
   DEV_PROXY: string;
   MEET_AUTH_HEADER: string;
   MEET_API_URL: string;
+  ENABLE_MEET: 'true' | 'false';
 };
 
 const env = _env as ZeroEnv;
 
@@ -2,6 +2,7 @@ import type { IGetThreadResponse, IGetThreadsResponse } from './driver/types';
 import { OutgoingMessageType } from '../routes/agent/types';
 import { getContext } from 'hono/context-storage';
 import { connection } from '../db/schema';
+import { defaultPageSize } from './utils';
 import type { HonoContext } from '../ctx';
 import { createClient } from 'dormroom';
 import { createDriver } from './driver';
@@ -350,21 +351,47 @@ export const getZeroAgent = async (connectionId: string, executionCtx?: Executio
   return agent;
 };
 
+export const getZeroAgentFromShard = async (connectionId: string, shardId: string) => {
+  const agent = await getShardClient(connectionId, shardId);
+  return agent;
+};
+
 export const forceReSync = async (connectionId: string) => {
   const registry = await getRegistryClient(connectionId);
   const allShards = await listShards(registry);
-  for (const { shard_id: id } of allShards) {
-    const shard = await getShardClient(connectionId, id);
-    await shard.exec(`DROP TABLE IF EXISTS threads`);
-    await shard.exec(`DROP TABLE IF EXISTS thread_labels`);
-    await shard.exec(`DROP TABLE IF EXISTS labels`);
-  }
+
+  await Promise.all(
+    allShards.map(async ({ shard_id: id }) => {
+      const shard = await getShardClient(connectionId, id);
+      await Promise.all([
+        shard.exec(`DROP TABLE IF EXISTS threads`),
+        shard.exec(`DROP TABLE IF EXISTS thread_labels`),
+        shard.exec(`DROP TABLE IF EXISTS labels`),
+      ]);
+    }),
+  );
+
   await deleteAllShards(registry);
+
   const agent = await getZeroAgent(connectionId);
   await agent.stub.forceReSync();
 };
 
-
+export const reSyncThread = async (connectionId: string, threadId: string) => {
+  try {
+    const { result: thread, shardId } = await getThread(connectionId, threadId);
+    const agent = await getZeroAgentFromShard(connectionId, shardId);
+    await agent.stub.syncThread({ threadId });
+  } catch (error) {
+    console.error(`[ZeroAgent] Thread not found for threadId: ${threadId}`);
+  }
+  if (thread) {
+    const agent = await getZeroAgentFromShard(connectionId, shardId);
+    await agent.stub.syncThread({ threadId });
+  } else {
+    console.error(`[ZeroAgent] Thread not found for threadId: ${threadId}`);
+  }
+};
 
 export const getThreadsFromDB = async (
   connectionId: string,
@@ -379,7 +406,17 @@ export const getThreadsFromDB = async (
   // Fire and forget - don't block the thread query on state updates
   void sendDoState(connectionId);
 
-  const maxResults = params.maxResults ?? 20;
+  const maxResults = params.maxResults ?? defaultPageSize;
+
+  if (maxResults === defaultPageSize && !params.pageToken && !params.q) {
+    return Effect.promise(async () => {
+      const agent = await getZeroAgent(connectionId);
+      return await agent.stub.getThreadsFromDB({
+        ...params,
+        maxResults: maxResults,
+      });
+    }).pipe(Effect.runPromise);
+  }
 
   return Effect.runPromise(
     aggregateShardDataEffect<IGetThreadsResponse>(
@@ -388,23 +425,23 @@ export const getThreadsFromDB = async (
         Effect.promise(() =>
           shard.stub.getThreadsFromDB({
             ...params,
-            maxResults: maxResults * 2, // Request more from each shard to ensure we have enough
+            maxResults: maxResults,
           }),
         ),
       (shardResults) => {
         // Combine all threads from all shards
         const allThreads = shardResults.flatMap((result) => result.threads);
-        
+
         // Sort by some criteria if needed (assuming threads have a sortable field)
         // allThreads.sort((a, b) => new Date(b.updated_at).getTime() - new Date(a.updated_at).getTime());
-        
+
         // Take only the requested amount
         const threads = allThreads.slice(0, maxResults);
-        
+
         // Determine if there's a next page token (simplified logic)
         const hasMoreResults = allThreads.length > maxResults;
-        const nextPageToken = hasMoreResults 
-          ? shardResults.find(r => r.nextPageToken)?.nextPageToken || null
+        const nextPageToken = hasMoreResults
+          ? shardResults.find((r) => r.nextPageToken)?.nextPageToken || null
           : null;
 
         return {