Edits history of script submission #23028 for ' Search Messages (gmail)'

• bunnative

  Ap­pro­ved version

  Edit in Windmill

  Embed

  //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,
    }
  }
  

  Submitted by hugo989 4 hours ago