✨config ModelEngine Service

Author: Zhi-a

doc/docs/zh/opensource-memorial-wall.md

@@ -632,6 +632,19 @@ Nexent开发者加油
 开放原子大赛接触到了Nexent平台，祝越来越好！
 :::
 
-::: hongmuxiangxun - 2025-12-19
+::: info hongmuxiangxun - 2025-12-19
 开放原子大赛接触到了Nexent平台，祝越来越好，越来越容易上手。
 :::
+
+::: info jinmo - 2025-12-25
+无意中接触了Nexent平台，喜欢它的风格，祝它能被更多人知晓。
+:::
+
+::: tip 开源新手 - 2025-12-25
+感谢 Nexent 让我踏上了开源之旅！这个项目的文档真的很棒，帮助我快速上手，希望 Nexent 越来越好！
+:::
+
+::: info 1-xiaozheng-1 - 2025-12-25
+从modelengine中看到Nexent，发现这个平台创建智能体简直一绝，希望越来越好。
+:::
+

docker/.env.example

@@ -70,8 +70,9 @@ REDIS_URL=redis://redis:6379/0
 REDIS_BACKEND_URL=redis://redis:6379/1
 
 # Model Engine Config
-MODEL_ENGINE_HOST=https://localhost:30555
-MODEL_ENGINE_APIKEY=
+MODEL_ENGINE_ENABLED=true
+MODEL_ENGINE_HOST=""
+MODEL_ENGINE_API_KEY=""
 
 # Supabase Config
 DASHBOARD_USERNAME=supabase

frontend/services/modelSyncService.ts

@@ -0,0 +1,77 @@
+import { modelService } from "./modelService";
+import { ModelType } from "@/types/modelConfig";
+
+const TYPES_TO_SYNC: ModelType[] = [
+  ("llm" as unknown) as ModelType,
+  ("embedding" as unknown) as ModelType,
+  ("multi_embedding" as unknown) as ModelType,
+  ("vlm" as unknown) as ModelType,
+  ("tts" as unknown) as ModelType,
+  ("stt" as unknown) as ModelType,
+];
+
+/**
+ * Sync models from ModelEngine and verify connectivity.
+ * Returns an object with overall success and per-model verification results.
+ */
+export async function syncModelEngine(apiKey: string) {
+  let syncFailed = false;
+  try {
+    for (const type of TYPES_TO_SYNC) {
+      try {
+        const providerModels = await modelService.addProviderModel({
+          provider: "modelengine",
+          type: type as any,
+          apiKey,
+        });
+        if (providerModels && providerModels.length > 0) {
+          await modelService.addBatchCustomModel({
+            api_key: apiKey,
+            provider: "modelengine",
+            type,
+            models: providerModels,
+          });
+        }
+      } catch (err) {
+        // mark that at least one provider fetch failed
+        syncFailed = true;
+      }
+    }
+
+    // reload all models from backend
+    const allModelsAfter = await modelService.getAllModels();
+    const modelEngineModels = allModelsAfter.filter((m) => m.source === "modelengine");
+
+    // update persisted api keys for modelengine models if needed
+    if (modelEngineModels.length > 0 && apiKey) {
+      const updates = modelEngineModels.map((m) => ({
+        model_id: String(m.id || m.name || m.displayName),
+        apiKey: apiKey,
+      }));
+      try {
+        await modelService.updateBatchModel(updates);
+      } catch (err) {
+        // non-fatal; continue to verification but flag sync failure
+        syncFailed = true;
+      }
+    }
+
+    // verify each persistent model and collect results
+    const verificationResults: Array<{ displayName: string; type: string; connected: boolean }> = [];
+    for (const m of modelEngineModels) {
+      if (!m.displayName) continue;
+      try {
+        const connected = await modelService.verifyCustomModel(m.displayName);
+        verificationResults.push({ displayName: m.displayName, type: m.type, connected });
+      } catch (err) {
+        verificationResults.push({ displayName: m.displayName, type: m.type, connected: false });
+      }
+    }
+
+    const anyUnavailable = verificationResults.some((r) => !r.connected);
+    const success = !syncFailed && !anyUnavailable;
+    return { success, verificationResults, error: syncFailed ? "provider_fetch_failed" : undefined };
+  } catch (err: any) {
+    return { success: false, verificationResults: [], error: err?.message || String(err) };
+  }
+}