Search Messages

//native

/**

 * Search Messages

 * List messages matching a Gmail search query (same operators as the Gmail search box, e.g. `from:alice@example.com is:unread newer_than:7d`). Returns each message's headers, labels and snippet, plus `nextPageToken` for the next page.

 */

export async function main(

  auth: RT.Gmail,

  q: string | undefined,

  label_ids: string[] | undefined,

  max_results: number = 25,

  page_token: string | undefined,

  include_spam_trash: boolean = false

) {

  const base = "https://gmail.googleapis.com/gmail/v1/users/me/messages"

  const headers = {

    Authorization: `Bearer ${auth.token}`,

    Accept: "application/json",

  }

  const url = new URL(base)

  url.searchParams.append("maxResults", String(max_results))

  url.searchParams.append("includeSpamTrash", String(include_spam_trash))

  if (q !== undefined && q !== "") url.searchParams.append("q", q)

  if (page_token !== undefined && page_token !== "")

    url.searchParams.append("pageToken", page_token)

  for (const id of label_ids ?? []) url.searchParams.append("labelIds", id)

  const response = await fetch(url, { headers })

  if (!response.ok) {

    throw new Error(`${response.status} ${await response.text()}`)

  }

  const list = (await response.json()) as {

    messages?: { id: string }[]

    nextPageToken?: string

    resultSizeEstimate: number

  }

  // messages.list only returns ids; fetch headers + snippet for each.

  const messages = await Promise.all(

    (list.messages ?? []).map(async ({ id }) => {

      const msgUrl = new URL(`${base}/${id}`)

      msgUrl.searchParams.append("format", "metadata")

      for (const h of ["From", "To", "Cc", "Subject", "Date"])

        msgUrl.searchParams.append("metadataHeaders", h)

      const r = await fetch(msgUrl, { headers })

      if (!r.ok) throw new Error(`${r.status} ${await r.text()}`)

      return await r.json()

    })

  )

  return {

    messages,

    nextPageToken: list.nextPageToken,

    resultSizeEstimate: list.resultSizeEstimate,

  }

}