Method embedBatch

packages/memos-core/src/embedding/index.ts:50–87

(texts: string[])

  }

  private async embedBatch(texts: string[]): Promise<number[][]> {
    const provider = this.provider;
    const cfg = this.cfg;

    const modelInfo = `${provider}/${cfg?.model ?? "default"}`;
    try {
      let result: number[][];
      switch (provider) {
        case "openai":
        case "openai_compatible":
        case "azure_openai":
        case "zhipu":
        case "siliconflow":
        case "bailian":
          result = await embedOpenAI(texts, cfg!, this.log); break;
        case "gemini":
          result = await embedGemini(texts, cfg!, this.log); break;
        case "cohere":
          result = await embedCohere(texts, cfg!, this.log); break;
        case "mistral":
          result = await embedMistral(texts, cfg!, this.log); break;
        case "voyage":
          result = await embedVoyage(texts, cfg!, this.log); break;
        case "local":
        default:
          result = await embedLocal(texts, this.log); break;
      }
      modelHealth.recordSuccess("embedding", modelInfo);
      return result;
    } catch (err) {
      modelHealth.recordError("embedding", modelInfo, String(err));
      if (provider !== "local") {
        this.log.warn(`Embedding provider '${provider}' failed, falling back to local: ${err}`);
        return await embedLocal(texts, this.log);
      }
      throw err;
    }
  }

  private async embedOpenClaw(texts: string[]): Promise<number[][]> {
    if (!this.openclawAPI) {