Function searchEmails

apps/sim/lib/webhooks/polling/gmail.ts:295–383

(
  accessToken: string,
  config: GmailWebhookConfig,
  requestId: string,
  logger: Logger
)

}

async function searchEmails(
  accessToken: string,
  config: GmailWebhookConfig,
  requestId: string,
  logger: Logger
) {
  try {
    const baseQuery = buildGmailSearchQuery(config)
    let timeConstraint = ''

    if (config.lastCheckedTimestamp) {
      const lastCheckedTime = new Date(config.lastCheckedTimestamp)
      const now = new Date()
      const minutesSinceLastCheck = (now.getTime() - lastCheckedTime.getTime()) / (60 * 1000)

      if (minutesSinceLastCheck < 60) {
        const bufferSeconds = Math.max(1 * 60 * 2, 180)
        const cutoffTime = new Date(lastCheckedTime.getTime() - bufferSeconds * 1000)
        const timestamp = Math.floor(cutoffTime.getTime() / 1000)
        timeConstraint = ` after:${timestamp}`
      } else if (minutesSinceLastCheck < 24 * 60) {
        const hours = Math.ceil(minutesSinceLastCheck / 60) + 1
        timeConstraint = ` newer_than:${hours}h`
      } else {
        const days = Math.min(Math.ceil(minutesSinceLastCheck / (24 * 60)), 7) + 1
        timeConstraint = ` newer_than:${days}d`
      }
    } else {
      timeConstraint = ' newer_than:1d'
    }

    const query = `${baseQuery}${timeConstraint}`
    const searchUrl = `https://gmail.googleapis.com/gmail/v1/users/me/messages?q=${encodeURIComponent(query)}&maxResults=${config.maxEmailsPerPoll || 25}`

    const searchResponse = await fetch(searchUrl, {
      headers: { Authorization: `Bearer ${accessToken}` },
    })

    if (!searchResponse.ok) {
      const errorData = await searchResponse.json()
      logger.error(`[${requestId}] Gmail search API error:`, {
        status: searchResponse.status,
        statusText: searchResponse.statusText,
        query,
        error: errorData,
      })
      throw new Error(
        `Gmail API error: ${searchResponse.status} ${searchResponse.statusText} - ${JSON.stringify(errorData)}`
      )
    }

    const searchData = await searchResponse.json()

    if (!searchData.messages || !searchData.messages.length) {
      logger.info(`[${requestId}] No emails found matching query: ${query}`)
      return { emails: [], latestHistoryId: config.historyId }
    }