From 90cbcbba7c52018b24f0cbafbdb03f92f1b4b89a Mon Sep 17 00:00:00 2001
From: john <cynell@139.com>
Date: Sun, 12 Jul 2026 09:54:47 +0800
Subject: [PATCH] feat: bridge asset gateway controls to admin api

---
 server/app.mjs       | 28 ++++++++++++++++++++++++++++
 server/bootstrap.mjs |  5 +++++
 server/index.mjs     |  2 ++
 3 files changed, 35 insertions(+)

diff --git a/server/app.mjs b/server/app.mjs
index 0dcc25c..88c7fe4 100644
--- a/server/app.mjs
+++ b/server/app.mjs
@@ -91,6 +91,7 @@ export function createAdminApp(services) {
   const {
     userAuth,
     llmProviderService,
+    assetGatewayConfigService,
     pool,
     ready,
     wechatAdmin,
@@ -325,6 +326,33 @@ export function createAdminApp(services) {
     res.json({ config: result });
   });
 
+  adminApi.get('/asset-gateway/config', requireAdmin, async (_req, res) => {
+    if (!assetGatewayConfigService?.getConfig) {
+      return res.status(503).json({ message: '资产能力配置服务未启用' });
+    }
+    res.json(await assetGatewayConfigService.getConfig());
+  });
+
+  adminApi.put('/asset-gateway/config', requireAdmin, async (req, res) => {
+    if (!assetGatewayConfigService?.updateGlobalConfig) {
+      return res.status(503).json({ message: '资产能力配置服务未启用' });
+    }
+    res.json(await assetGatewayConfigService.updateGlobalConfig(req.body ?? {}, {
+      updatedBy: req.currentUser.id,
+    }));
+  });
+
+  adminApi.put('/asset-gateway/plugins/:pluginId', requireAdmin, async (req, res) => {
+    if (!assetGatewayConfigService?.updatePluginConfig) {
+      return res.status(503).json({ message: '资产能力配置服务未启用' });
+    }
+    const result = await assetGatewayConfigService.updatePluginConfig(req.params.pluginId, req.body ?? {}, {
+      updatedBy: req.currentUser.id,
+    });
+    if (!result.ok) return res.status(400).json({ message: result.message });
+    res.json(result);
+  });
+
   adminApi.get('/memory-v2/config', requireAdmin, async (_req, res) => {
     if (!memoryV2ConfigService) return res.status(503).json({ message: 'Memory V2 配置未启用' });
     res.json(await memoryV2ConfigService.getAdminConfig());
diff --git a/server/bootstrap.mjs b/server/bootstrap.mjs
index b4f7c30..d6c1104 100644
--- a/server/bootstrap.mjs
+++ b/server/bootstrap.mjs
@@ -29,6 +29,8 @@ export async function bootstrapAdminServices() {
     updateMindSpaceConfig,
   } = await importMemind('mindspace-config.mjs');
   const { createMemoryV2AdminConfigService } = await importMemind('memory-v2-admin-config.mjs');
+  const { createAssetGatewayConfigService } = await importMemind('asset-gateway.mjs');
+  const { ensureAssetGatewaySchema } = await importMemind('db.mjs');
   const { createWechatScheduleLlmConfigService } = await importMemind('wechat-schedule-llm-config.mjs');
   const { createAdminSystemTestService } = await importMemind('admin-system-tests.mjs');
   const { createOpsApi } = await importMemind('admin-routes.mjs');
@@ -86,6 +88,8 @@ export async function bootstrapAdminServices() {
     apiTarget,
     apiSecret,
   });
+  await ensureAssetGatewaySchema(pool);
+  const assetGatewayConfigService = createAssetGatewayConfigService(pool, { llmProviderService });
   const memoryV2ConfigService = createMemoryV2AdminConfigService(pool, {
     env: process.env,
   });
@@ -133,6 +137,7 @@ export async function bootstrapAdminServices() {
     pool,
     userAuth,
     llmProviderService,
+    assetGatewayConfigService,
     plazaOps,
     createOpsApi,
     wechatAdmin,
diff --git a/server/index.mjs b/server/index.mjs
index 5f3d003..4f96cdf 100644
--- a/server/index.mjs
+++ b/server/index.mjs
@@ -98,6 +98,7 @@ ready
       pool,
       userAuth,
       llmProviderService,
+      assetGatewayConfigService,
       plazaOps,
       createOpsApi,
       wechatAdmin,
@@ -120,6 +121,7 @@ ready
       pool,
       userAuth,
       llmProviderService,
+      assetGatewayConfigService,
       plazaOps,
       createOpsApi,
       wechatAdmin,