// SPDX-License-Identifier: AGPL-3.0-only // Copyright (C) 2026 Giancarlo Erra - Altaire Limited import { afterEach, beforeEach, describe, expect, it, } from "vitest"; import { resetEmbeddingConfig } from "../../src/services/embedding-config.js"; import { getEmbeddingProvider, resetEmbeddingProvider } from "../../src/services/embedding-provider.js"; describe("embedding-provider", () => { const originalEnv = { ...process.env }; beforeEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); delete process.env.EMBEDDING_PROVIDER; delete process.env.OLLAMA_MODE; delete process.env.OLLAMA_URL; delete process.env.EMBEDDING_MODEL; delete process.env.EMBEDDING_DIMENSIONS; delete process.env.EMBEDDING_CONTEXT_LENGTH; delete process.env.OLLAMA_API_KEY; delete process.env.OPENAI_API_KEY; delete process.env.GOOGLE_API_KEY; }); afterEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); process.env = { ...originalEnv }; }); describe("factory", () => { it("defaults to OllamaEmbeddingProvider", async () => { const provider = await getEmbeddingProvider(); expect(provider.name).toBe("ollama"); }); it("creates OpenAIEmbeddingProvider when configured", async () => { process.env.EMBEDDING_PROVIDER = "openai"; const provider = await getEmbeddingProvider(); expect(provider.name).toBe("openai"); }); it("creates GoogleEmbeddingProvider when configured", async () => { process.env.EMBEDDING_PROVIDER = "google"; const provider = await getEmbeddingProvider(); expect(provider.name).toBe("google"); }); it("caches provider instance", async () => { const p1 = await getEmbeddingProvider(); const p2 = await getEmbeddingProvider(); expect(p1).toBe(p2); }); it("recreates provider when config changes", async () => { const p1 = await getEmbeddingProvider(); expect(p1.name).toBe("ollama"); resetEmbeddingConfig(); resetEmbeddingProvider(); process.env.EMBEDDING_PROVIDER = "openai"; const p2 = await getEmbeddingProvider(); expect(p2.name).toBe("openai"); expect(p2).not.toBe(p1); }); }); }); describe("OpenAIEmbeddingProvider", () => { const originalEnv = { ...process.env }; beforeEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); delete process.env.EMBEDDING_PROVIDER; delete process.env.OPENAI_API_KEY; delete process.env.EMBEDDING_MODEL; delete process.env.EMBEDDING_DIMENSIONS; }); afterEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); process.env = { ...originalEnv }; }); it("throws when OPENAI_API_KEY is not set", async () => { process.env.EMBEDDING_PROVIDER = "openai"; const provider = await getEmbeddingProvider(); await expect(provider.ensureReady()).rejects.toThrow("OPENAI_API_KEY"); }); it("reports missing API key in health check", async () => { process.env.EMBEDDING_PROVIDER = "openai"; const provider = await getEmbeddingProvider(); const health = await provider.healthCheck(); expect(health.available).toBe(false); expect(health.modelReady).toBe(false); expect(health.statusLines.some((l) => l.includes("Missing"))).toBe(true); }); }); describe("GoogleEmbeddingProvider", () => { const originalEnv = { ...process.env }; beforeEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); delete process.env.EMBEDDING_PROVIDER; delete process.env.GOOGLE_API_KEY; delete process.env.EMBEDDING_MODEL; delete process.env.EMBEDDING_DIMENSIONS; }); afterEach(() => { resetEmbeddingConfig(); resetEmbeddingProvider(); process.env = { ...originalEnv }; }); it("throws when GOOGLE_API_KEY is not set", async () => { process.env.EMBEDDING_PROVIDER = "google"; const provider = await getEmbeddingProvider(); await expect(provider.ensureReady()).rejects.toThrow("GOOGLE_API_KEY"); }); it("reports missing API key in health check", async () => { process.env.EMBEDDING_PROVIDER = "google"; const provider = await getEmbeddingProvider(); const health = await provider.healthCheck(); expect(health.available).toBe(false); expect(health.modelReady).toBe(false); expect(health.statusLines.some((l) => l.includes("Missing"))).toBe(true); }); });