Function pollWebhook

apps/sim/lib/webhooks/polling/imap.ts:78–189

(ctx: PollWebhookContext)

  label: 'IMAP',

  async pollWebhook(ctx: PollWebhookContext): Promise<'success' | 'failure'> {
    const { webhookData, workflowData, requestId, logger } = ctx
    const webhookId = webhookData.id

    try {
      const config = getProviderConfig<ImapWebhookConfig>(webhookData.providerConfig)

      if (!config.host || !config.username || !config.password) {
        logger.error(`[${requestId}] Missing IMAP credentials for webhook ${webhookId}`)
        await markWebhookFailed(webhookId, logger)
        return 'failure'
      }

      const hostValidation = await validateDatabaseHost(config.host, 'host')
      if (!hostValidation.isValid) {
        logger.error(
          `[${requestId}] IMAP host validation failed for webhook ${webhookId}: ${hostValidation.error}`
        )
        await markWebhookFailed(webhookId, logger)
        return 'failure'
      }

      const client = new ImapFlow({
        host: hostValidation.resolvedIP!,
        servername: config.host,
        port: config.port || 993,
        secure: config.secure ?? true,
        auth: {
          user: config.username,
          pass: config.password,
        },
        tls: { rejectUnauthorized: true },
        logger: false,
      })

      let emails: Awaited<ReturnType<typeof fetchNewEmails>>['emails'] = []
      let latestUidByMailbox: Record<string, number> = {}
      let uidValidityByMailbox: Record<string, string> = {}

      try {
        await client.connect()

        const result = await fetchNewEmails(client, config, requestId, logger)
        emails = result.emails
        latestUidByMailbox = result.latestUidByMailbox
        uidValidityByMailbox = result.uidValidityByMailbox

        const pollTimestamp = new Date().toISOString()

        if (!emails.length) {
          await updateImapState(
            webhookId,
            latestUidByMailbox,
            pollTimestamp,
            config,
            logger,
            uidValidityByMailbox
          )