Function mondayGraphQL

apps/sim/connectors/monday/monday.ts:116–157

* Executes a GraphQL query against the monday.com API, surfacing GraphQL-level * errors (which return HTTP 200 with an `errors` array) as thrown errors.

(
  accessToken: string,
  query: string,
  variables: Record<string, unknown> = {},
  retryOptions?: Parameters<typeof fetchWithRetry>[2]
)

 * errors (which return HTTP 200 with an `errors` array) as thrown errors.
 */
async function mondayGraphQL<T>(
  accessToken: string,
  query: string,
  variables: Record<string, unknown> = {},
  retryOptions?: Parameters<typeof fetchWithRetry>[2]
): Promise<T> {
  const response = await fetchWithRetry(
    MONDAY_API_URL,
    {
      method: 'POST',
      headers: mondayHeaders(accessToken),
      body: JSON.stringify({ query, variables }),
    },
    retryOptions
  )

  if (!response.ok) {
    const errorText = await response.text().catch(() => '')
    throw new Error(
      `monday.com API HTTP error: ${response.status}${errorText ? ` — ${errorText.slice(0, 200)}` : ''}`
    )
  }

  const data = (await response.json()) as {
    data?: T
    errors?: { message?: string }[]
    error_message?: string
  }

  if (data.errors && data.errors.length > 0) {
    const message = data.errors
      .map((e) => e.message)
      .filter(Boolean)
      .join('; ')
    throw new Error(`monday.com API error: ${message || 'Unknown GraphQL error'}`)
  }
  if (data.error_message) {
    throw new Error(`monday.com API error: ${data.error_message}`)
  }

  return data.data as T
}

/**
 * GraphQL selection set for an item, shared between listing and single-item