Function embedBatchAdaptive

src/core/embeddings.ts:228–247

(batch: string[])

}

async function embedBatchAdaptive(batch: string[]): Promise<number[][]> {
  try {
    const timeoutCtrl = AbortSignal.timeout(EMBED_TIMEOUT_MS);
    const signal = AbortSignal.any([embedAbortController.signal, timeoutCtrl]);
    const embeddings = await callProviderEmbed(batch, signal);
    if (embeddings.length !== batch.length) {
      throw new Error(`Embedding response size mismatch: expected ${batch.length}, got ${embeddings.length}`);
    }
    return embeddings;
  } catch (error) {
    if (!isContextLengthError(error)) throw error;
    if (batch.length === 1) {
      return [await embedSingleAdaptive(batch[0])];
    }
    const middle = Math.ceil(batch.length / 2);
    const left = await embedBatchAdaptive(batch.slice(0, middle));
    const right = await embedBatchAdaptive(batch.slice(middle));
    return [...left, ...right];
  }
}

function splitEmbeddingInput(input: string): string[] {
  const chunkChars = getEmbedChunkChars();