improvement(org): list Gmail threads and read the mailbox address together

Author: waleedlatif1

apps/sim/lib/organizations/home/provider-reads.test.ts

@@ -325,6 +325,27 @@ describe('sharing a Gmail read across accounts', () => {
     expect(reconnected.threads[0].url).toBe(gmailThreadUrl('t', 'new@example.com'))
   })
 
+  it('does not wait for the listing before asking for the mailbox address', async () => {
+    let listed: (response: Response) => void = () => {}
+    providerFetch.mockImplementation((url: string) =>
+      url.includes('/threads?')
+        ? new Promise((resolve) => {
+            listed = resolve
+          })
+        : Promise.resolve(respond(gmailThread('t', [metadataMessage('Ada', 'S', 'P')])))
+    )
+    const read = readGmailThreadsPage({
+      accessToken: 'token',
+      signal,
+      credentialId: 'mailbox-parallel',
+      accountId: 'account',
+      count: 1,
+    })
+    await vi.waitFor(() => expect(mailboxEmail).toHaveBeenCalledOnce())
+    listed(respond({ threads: [{ id: 't' }] }))
+    await expect(read).resolves.toMatchObject({ threads: [{ id: 't' }] })
+  })
+
   it('does not cache a failed mailbox lookup', async () => {
     providerFetch.mockImplementation(async (url: string) =>
       url.includes('/threads?')

apps/sim/lib/organizations/home/provider-reads.ts

@@ -217,13 +217,15 @@ export async function readGmailThreads({
   threads: HomeEmailThread[]
   cursor: GmailThreadCursor
 }> {
-  const list = await runTool(
-    gmailListThreadsV2Tool,
-    { accessToken, labelIds: 'INBOX', maxResults: HOME_EMAIL_THREAD_LIMIT },
-    signal
-  )
+  const [list, mailbox] = await Promise.all([
+    runTool(
+      gmailListThreadsV2Tool,
+      { accessToken, labelIds: 'INBOX', maxResults: HOME_EMAIL_THREAD_LIMIT },
+      signal
+    ),
+    readGmailMailbox({ accessToken, signal, credentialId, accountId }),
+  ])
   if (!list.success) throw new HomeProviderReadError('unavailable')
-  const mailbox = await readGmailMailbox({ accessToken, signal, credentialId, accountId })
   const cursor: GmailThreadCursor = {
     mailbox,
     unreadThreadIds: list.output.threads