Function queryWorkItemIds

apps/sim/connectors/azure-devops/azure-devops.ts:572–606

* Runs a WIQL query for work items in the project and returns their IDs. * WIQL itself is not paginated and returns at most 20,000 ids; pagination * happens over the resulting ID list via the workitemsbatch endpoint.

(
  accessToken: string,
  organization: string,
  project: string,
  wiql: string,
  top: number = WIQL_MAX_RESULTS
)

 * happens over the resulting ID list via the workitemsbatch endpoint.
 */
async function queryWorkItemIds(
  accessToken: string,
  organization: string,
  project: string,
  wiql: string,
  top: number = WIQL_MAX_RESULTS
): Promise<number[]> {
  const url = `${ADO_BASE_URL}/${encodeURIComponent(organization)}/${encodeURIComponent(project)}/_apis/wit/wiql?$top=${top}&api-version=${WIQL_API_VERSION}`
  const response = await fetchWithRetry(url, {
    method: 'POST',
    headers: {
      Accept: 'application/json',
      'Content-Type': 'application/json',
      Authorization: patAuthHeader(accessToken),
    },
    body: JSON.stringify({ query: wiql }),
  })
  if (!response.ok) {
    const errorText = await response.text().catch(() => '')
    logger.error('Failed to query Azure DevOps work items', {
      status: response.status,
      error: errorText,
    })
    throw new Error(`Failed to query work items: ${response.status}`)
  }
  const data = await response.json()
  const refs = (data.workItems as WorkItemRef[] | undefined) ?? []
  if (refs.length >= WIQL_MAX_RESULTS) {
    logger.warn('WIQL result hit the 20,000-item cap; narrow work-item filters to sync all items', {
      organization,
      project,
    })
  }
  return refs.map((ref) => ref.id)
}

/**
 * Fetches full field details for a batch of work item IDs (max 200 per call).