dataSources.query

client.dataSources.query(parameters: QueryDataSourceParameters): Promise<QueryDataSourceResponse>

import { Client } from "@notionhq/client"

const notion = new Client({ auth: process.env.NOTION_API_KEY })

const response = await notion.dataSources.query({
  data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890"
})

console.log(`Found ${response.results.length} pages`)
for (const page of response.results) {
  console.log(`- ${page.id}`)
}

const response = await notion.dataSources.query({
  data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  filter: {
    property: "Status",
    select: {
      equals: "Active"
    }
  }
})

const response = await notion.dataSources.query({
  data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  sorts: [
    {
      property: "Name",
      direction: "ascending"
    }
  ]
})

const response = await notion.dataSources.query({
  data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  filter: {
    and: [
      {
        property: "Status",
        select: {
          equals: "Active"
        }
      },
      {
        or: [
          {
            property: "Priority",
            select: {
              equals: "High"
            }
          },
          {
            property: "Priority",
            select: {
              equals: "Medium"
            }
          }
        ]
      }
    ]
  }
})

import { collectPaginatedAPI } from "@notionhq/client"

// Collect all results automatically
const allPages = await collectPaginatedAPI(
  notion.dataSources.query,
  {
    data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890"
  }
)

console.log(`Total pages: ${allPages.length}`)

let cursor = undefined
let hasMore = true

while (hasMore) {
  const response = await notion.dataSources.query({
    data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
    start_cursor: cursor,
    page_size: 50
  })
  
  // Process results
  for (const page of response.results) {
    console.log(page.id)
  }
  
  cursor = response.next_cursor
  hasMore = response.has_more
}

const response = await notion.dataSources.query({
  data_source_id: "a1b2c3d4-e5f6-7890-abcd-ef1234567890",
  filter: {
    timestamp: "last_edited_time",
    last_edited_time: {
      past_week: {}
    }
  },
  sorts: [
    {
      timestamp: "last_edited_time",
      direction: "descending"
    }
  ]
})