Function embedSingleAdaptive

src/core/embeddings.ts:207–226

(input: string)

}

async function embedSingleAdaptive(input: string): Promise<number[]> {
  let candidate = input;

  for (let attempt = 0; attempt <= MAX_SINGLE_INPUT_RETRIES; attempt++) {
    try {
      const timeoutCtrl = AbortSignal.timeout(EMBED_TIMEOUT_MS);
      const signal = AbortSignal.any([embedAbortController.signal, timeoutCtrl]);
      const embeddings = await callProviderEmbed([candidate], signal);
      if (!embeddings[0]) throw new Error("Missing embedding vector in response");
      return embeddings[0];
    } catch (error) {
      if (!isContextLengthError(error)) throw error;
      const nextCandidate = shrinkEmbeddingInput(candidate);
      if (nextCandidate.length === candidate.length) throw error;
      candidate = nextCandidate;
    }
  }

  throw new Error("Unable to embed oversized input after adaptive retries");
}

async function embedBatchAdaptive(batch: string[]): Promise<number[][]> {
  try {