Function processEmails

apps/sim/lib/webhooks/polling/gmail.ts:439–575

(
  emails: GmailEmail[],
  webhookData: PollWebhookContext['webhookData'],
  workflowData: PollWebhookContext['workflowData'],
  config: GmailWebhookConfig,
  accessToken: string,
  requestId: string,
  logger: Logger
)

}

async function processEmails(
  emails: GmailEmail[],
  webhookData: PollWebhookContext['webhookData'],
  workflowData: PollWebhookContext['workflowData'],
  config: GmailWebhookConfig,
  accessToken: string,
  requestId: string,
  logger: Logger
) {
  let processedCount = 0
  let failedCount = 0

  for (const email of emails) {
    try {
      await pollingIdempotency.executeWithIdempotency(
        'gmail',
        `${webhookData.id}:${email.id}`,
        async () => {
          const headers: Record<string, string> = {}
          const payload = email.payload as Record<string, unknown> | undefined
          if (payload?.headers && Array.isArray(payload.headers)) {
            for (const header of payload.headers as { name: string; value: string }[]) {
              headers[header.name.toLowerCase()] = header.value
            }
          }

          let textContent = ''
          let htmlContent = ''

          const extractContent = (part: Record<string, unknown>) => {
            if (!part) return

            if (part.mimeType === 'text/plain') {
              const body = part.body as { data?: string } | undefined
              if (body?.data) {
                textContent = Buffer.from(body.data, 'base64').toString('utf-8')
              }
            } else if (part.mimeType === 'text/html') {
              const body = part.body as { data?: string } | undefined
              if (body?.data) {
                htmlContent = Buffer.from(body.data, 'base64').toString('utf-8')
              }
            }

            if (part.parts && Array.isArray(part.parts)) {
              for (const subPart of part.parts) {
                extractContent(subPart as Record<string, unknown>)
              }
            }
          }

          if (payload) {
            extractContent(payload)
          }

          let date: string | null = null
          if (headers.date) {
            try {