Method #executeBatch

packages/client/src/plugins/batch.ts:212–309

(
    method: 'GET' | 'POST',
    group: BatchLinkPluginGroup<T>,
    groupItems: typeof this.pending extends Map<any, infer U> ? U : never,
  )

  }

  async #executeBatch(
    method: 'GET' | 'POST',
    group: BatchLinkPluginGroup<T>,
    groupItems: typeof this.pending extends Map<any, infer U> ? U : never,
  ): Promise<void> {
    if (!groupItems.length) {
      return
    }

    const batchItems = groupItems as [typeof groupItems[number], ...typeof groupItems[number][]]

    if (batchItems.length === 1) {
      batchItems[0][0].next().then(batchItems[0][1]).catch(batchItems[0][2])
      return
    }

    try {
      const options = batchItems.map(([options]) => options) as [
        InterceptorOptions<StandardLinkClientInterceptorOptions<T>, Promise<StandardLazyResponse>>,
        ...InterceptorOptions<StandardLinkClientInterceptorOptions<T>, Promise<StandardLazyResponse>>[],
      ]

      const maxSize = await value(this.maxSize, options)

      if (batchItems.length > maxSize) {
        const [first, second] = splitInHalf(batchItems)
        this.#executeBatch(method, group, first)
        this.#executeBatch(method, group, second)
        return
      }

      const batchUrl = new URL(await value(this.batchUrl, options))
      const batchHeaders = await value(this.batchHeaders, options)
      const mappedItems = batchItems.map(([options]) => this.mapRequestItem({ ...options, batchUrl, batchHeaders }))

      const batchRequest = toBatchRequest({
        method,
        url: batchUrl,
        headers: batchHeaders,
        requests: mappedItems,
      })

      const maxUrlLength = await value(this.maxUrlLength, options)

      if (batchRequest.url.toString().length > maxUrlLength) {
        const [first, second] = splitInHalf(batchItems)
        this.#executeBatch(method, group, first)
        this.#executeBatch(method, group, second)
        return
      }

      const mode = value(this.mode, options)

      try {
        const lazyResponse = await options[0].next({
          request: { ...batchRequest, headers: { ...batchRequest.headers, 'x-orpc-batch': mode } },
          signal: batchRequest.signal,
          context: group.context,