Function updateImapState

apps/sim/lib/webhooks/polling/imap.ts:192–237

(
  webhookId: string,
  uidByMailbox: Record<string, number>,
  timestamp: string,
  config: ImapWebhookConfig,
  logger: Logger,
  uidValidityByMailbox: Record<string, string>
)

}

async function updateImapState(
  webhookId: string,
  uidByMailbox: Record<string, number>,
  timestamp: string,
  config: ImapWebhookConfig,
  logger: Logger,
  uidValidityByMailbox: Record<string, string>
) {
  const existingUidByMailbox = config.lastProcessedUidByMailbox || {}
  const prevUidValidity = config.uidValidityByMailbox || {}

  const resetMailboxes = new Set(
    Object.entries(uidValidityByMailbox)
      .filter(
        ([mailbox, validity]) =>
          prevUidValidity[mailbox] !== undefined && prevUidValidity[mailbox] !== validity
      )
      .map(([mailbox]) => mailbox)
  )

  const mergedUidByMailbox: Record<string, number> = {}

  for (const [mailbox, uid] of Object.entries(existingUidByMailbox)) {
    if (!resetMailboxes.has(mailbox)) {
      mergedUidByMailbox[mailbox] = uid
    }
  }

  for (const [mailbox, uid] of Object.entries(uidByMailbox)) {
    if (resetMailboxes.has(mailbox)) {
      mergedUidByMailbox[mailbox] = uid
    } else {
      mergedUidByMailbox[mailbox] = Math.max(uid, mergedUidByMailbox[mailbox] || 0)
    }
  }

  await updateWebhookProviderConfig(
    webhookId,
    {
      lastProcessedUidByMailbox: mergedUidByMailbox,
      lastCheckedTimestamp: timestamp,
      uidValidityByMailbox,
    },
    logger
  )
}

async function fetchNewEmails(
  client: ImapFlow,