feat: init 2.0.0 config file edit

src/lib/admin.types.ts

@@ -1,4 +1,5 @@
 export interface AdminConfig {
+  ConfigFile: string;
   SiteConfig: {
     SiteName: string;
     Announcement: string;

src/lib/config.client.ts

@@ -0,0 +1,17 @@
+/* eslint-disable @typescript-eslint/no-explicit-any */
+
+'use client';
+
+export async function getCustomCategories(): Promise<{
+  name: string;
+  type: 'movie' | 'tv';
+  query: string;
+}[]> {
+  const res = await fetch('/api/config/custom_category');
+  const data = await res.json();
+  return data.filter((item: any) => !item.disabled).map((category: any) => ({
+    name: category.name || '',
+    type: category.type,
+    query: category.query,
+  }));
+}

src/lib/config.ts

@@ -3,7 +3,6 @@
 import { getStorage } from '@/lib/db';
 
 import { AdminConfig } from './admin.types';
-import runtimeConfig from './runtime';
 
 export interface ApiSite {
   key: string;
@@ -14,7 +13,7 @@ export interface ApiSite {
 
 interface ConfigFileStruct {
   cache_time?: number;
-  api_site: {
+  api_site?: {
     [key: string]: ApiSite;
   };
   custom_category?: {
@@ -48,244 +47,267 @@ export const API_CONFIG = {
 let fileConfig: ConfigFileStruct;
 let cachedConfig: AdminConfig;
 
-async function initConfig() {
-  if (cachedConfig) {
-    return;
+export function refineConfig(adminConfig: AdminConfig): AdminConfig {
+  try {
+    fileConfig = JSON.parse(adminConfig.ConfigFile) as ConfigFileStruct;
+  } catch (e) {
+    fileConfig = {} as ConfigFileStruct;
   }
+  // 合并文件中的源信息
+  const apiSiteEntries = Object.entries(fileConfig.api_site || []);
+  const sourceConfigMap = new Map(
+    (adminConfig.SourceConfig || []).map((s) => [s.key, s])
+  );
 
-  if (process.env.DOCKER_ENV === 'true') {
-    // eslint-disable-next-line @typescript-eslint/no-implied-eval
-    const _require = eval('require') as NodeRequire;
-    const fs = _require('fs') as typeof import('fs');
-    const path = _require('path') as typeof import('path');
-
-    const configPath = path.join(process.cwd(), 'config.json');
-    const raw = fs.readFileSync(configPath, 'utf-8');
-    fileConfig = JSON.parse(raw) as ConfigFileStruct;
-    console.log('load dynamic config success');
-  } else {
-    // 默认使用编译时生成的配置
-    fileConfig = runtimeConfig as unknown as ConfigFileStruct;
-  }
-  const storageType = process.env.NEXT_PUBLIC_STORAGE_TYPE || 'localstorage';
-  if (storageType !== 'localstorage') {
-    // 数据库存储，读取并补全管理员配置
-    const storage = getStorage();
-
-    try {
-      // 尝试从数据库获取管理员配置
-      let adminConfig: AdminConfig | null = null;
-      if (storage && typeof (storage as any).getAdminConfig === 'function') {
-        adminConfig = await (storage as any).getAdminConfig();
-      }
-
-      // 获取所有用户名，用于补全 Users
-      let userNames: string[] = [];
-      if (storage && typeof (storage as any).getAllUsers === 'function') {
-        try {
-          userNames = await (storage as any).getAllUsers();
-        } catch (e) {
-          console.error('获取用户列表失败:', e);
-        }
-      }
-
-      // 从文件中获取源信息，用于补全源
-      const apiSiteEntries = Object.entries(fileConfig.api_site);
-      const customCategories = fileConfig.custom_category || [];
-
-      if (adminConfig) {
-        // 补全 SourceConfig
-        const sourceConfigMap = new Map(
-          (adminConfig.SourceConfig || []).map((s) => [s.key, s])
-        );
-
-        apiSiteEntries.forEach(([key, site]) => {
-          sourceConfigMap.set(key, {
-            key,
-            name: site.name,
-            api: site.api,
-            detail: site.detail,
-            from: 'config',
-            disabled: false,
-          });
-        });
-
-        // 将 Map 转换回数组
-        adminConfig.SourceConfig = Array.from(sourceConfigMap.values());
-
-        // 检查现有源是否在 fileConfig.api_site 中，如果不在则标记为 custom
-        const apiSiteKeys = new Set(apiSiteEntries.map(([key]) => key));
-        adminConfig.SourceConfig.forEach((source) => {
-          if (!apiSiteKeys.has(source.key)) {
-            source.from = 'custom';
-          }
-        });
-
-        // 确保 CustomCategories 被初始化
-        if (!adminConfig.CustomCategories) {
-          adminConfig.CustomCategories = [];
-        }
-
-        // 补全 CustomCategories
-        const customCategoriesMap = new Map(
-          adminConfig.CustomCategories.map((c) => [c.query + c.type, c])
-        );
-
-        customCategories.forEach((category) => {
-          customCategoriesMap.set(category.query + category.type, {
-            name: category.name,
-            type: category.type,
-            query: category.query,
-            from: 'config',
-            disabled: false,
-          });
-        });
-
-        // 检查现有 CustomCategories 是否在 fileConfig.custom_category 中，如果不在则标记为 custom
-        const customCategoriesKeys = new Set(
-          customCategories.map((c) => c.query + c.type)
-        );
-        customCategoriesMap.forEach((category) => {
-          if (!customCategoriesKeys.has(category.query + category.type)) {
-            category.from = 'custom';
-          }
-        });
-
-        // 将 Map 转换回数组
-        adminConfig.CustomCategories = Array.from(customCategoriesMap.values());
-
-        const existedUsers = new Set(
-          (adminConfig.UserConfig.Users || []).map((u) => u.username)
-        );
-        userNames.forEach((uname) => {
-          if (!existedUsers.has(uname)) {
-            adminConfig!.UserConfig.Users.push({
-              username: uname,
-              role: 'user',
-            });
-          }
-        });
-        // 站长
-        const ownerUser = process.env.USERNAME;
-        if (ownerUser) {
-          adminConfig!.UserConfig.Users = adminConfig!.UserConfig.Users.filter(
-            (u) => u.username !== ownerUser
-          );
-          adminConfig!.UserConfig.Users.unshift({
-            username: ownerUser,
-            role: 'owner',
-          });
-        }
-      } else {
-        // 数据库中没有配置，创建新的管理员配置
-        let allUsers = userNames.map((uname) => ({
-          username: uname,
-          role: 'user',
-        }));
-        const ownerUser = process.env.USERNAME;
-        if (ownerUser) {
-          allUsers = allUsers.filter((u) => u.username !== ownerUser);
-          allUsers.unshift({
-            username: ownerUser,
-            role: 'owner',
-          });
-        }
-        adminConfig = {
-          SiteConfig: {
-            SiteName: process.env.NEXT_PUBLIC_SITE_NAME || 'MoonTV',
-            Announcement:
-              process.env.ANNOUNCEMENT ||
-              '本网站仅提供影视信息搜索服务，所有内容均来自第三方网站。本站不存储任何视频资源，不对任何内容的准确性、合法性、完整性负责。',
-            SearchDownstreamMaxPage:
-              Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5,
-            SiteInterfaceCacheTime: fileConfig.cache_time || 7200,
-            DoubanProxyType:
-              process.env.NEXT_PUBLIC_DOUBAN_PROXY_TYPE || 'direct',
-            DoubanProxy: process.env.NEXT_PUBLIC_DOUBAN_PROXY || '',
-            DoubanImageProxyType:
-              process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY_TYPE || 'direct',
-            DoubanImageProxy: process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY || '',
-            DisableYellowFilter:
-              process.env.NEXT_PUBLIC_DISABLE_YELLOW_FILTER === 'true',
-          },
-          UserConfig: {
-            AllowRegister: process.env.NEXT_PUBLIC_ENABLE_REGISTER === 'true',
-            Users: allUsers as any,
-          },
-          SourceConfig: apiSiteEntries.map(([key, site]) => ({
-            key,
-            name: site.name,
-            api: site.api,
-            detail: site.detail,
-            from: 'config',
-            disabled: false,
-          })),
-          CustomCategories: customCategories.map((category) => ({
-            name: category.name,
-            type: category.type,
-            query: category.query,
-            from: 'config',
-            disabled: false,
-          })),
-        };
-      }
-
-      // 写回数据库（更新/创建）
-      if (storage && typeof (storage as any).setAdminConfig === 'function') {
-        await (storage as any).setAdminConfig(adminConfig);
-      }
-
-      // 更新缓存
-      cachedConfig = adminConfig;
-    } catch (err) {
-      console.error('加载管理员配置失败:', err);
-    }
-  } else {
-    // 本地存储直接使用文件配置
-    cachedConfig = {
-      SiteConfig: {
-        SiteName: process.env.NEXT_PUBLIC_SITE_NAME || 'MoonTV',
-        Announcement:
-          process.env.ANNOUNCEMENT ||
-          '本网站仅提供影视信息搜索服务，所有内容均来自第三方网站。本站不存储任何视频资源，不对任何内容的准确性、合法性、完整性负责。',
-        SearchDownstreamMaxPage:
-          Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5,
-        SiteInterfaceCacheTime: fileConfig.cache_time || 7200,
-        DoubanProxyType: process.env.NEXT_PUBLIC_DOUBAN_PROXY_TYPE || 'direct',
-        DoubanProxy: process.env.NEXT_PUBLIC_DOUBAN_PROXY || '',
-        DoubanImageProxyType:
-          process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY_TYPE || 'direct',
-        DoubanImageProxy: process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY || '',
-        DisableYellowFilter:
-          process.env.NEXT_PUBLIC_DISABLE_YELLOW_FILTER === 'true',
-      },
-      UserConfig: {
-        AllowRegister: process.env.NEXT_PUBLIC_ENABLE_REGISTER === 'true',
-        Users: [],
-      },
-      SourceConfig: Object.entries(fileConfig.api_site).map(([key, site]) => ({
+  apiSiteEntries.forEach(([key, site]) => {
+    const existingSource = sourceConfigMap.get(key);
+    if (existingSource) {
+      // 如果已存在，只覆盖 name、api、detail 和 from
+      existingSource.name = site.name;
+      existingSource.api = site.api;
+      existingSource.detail = site.detail;
+      existingSource.from = 'config';
+    } else {
+      // 如果不存在，创建新条目
+      sourceConfigMap.set(key, {
         key,
         name: site.name,
         api: site.api,
         detail: site.detail,
         from: 'config',
         disabled: false,
-      })),
-      CustomCategories:
-        fileConfig.custom_category?.map((category) => ({
+      });
+    }
+  });
+
+  // 检查现有源是否在 fileConfig.api_site 中，如果不在则标记为 custom
+  const apiSiteKeys = new Set(apiSiteEntries.map(([key]) => key));
+  sourceConfigMap.forEach((source) => {
+    if (!apiSiteKeys.has(source.key)) {
+      source.from = 'custom';
+    }
+  });
+
+  // 将 Map 转换回数组
+  adminConfig.SourceConfig = Array.from(sourceConfigMap.values());
+
+  // 覆盖 CustomCategories
+  const customCategories = fileConfig.custom_category || [];
+  const customCategoriesMap = new Map(
+    (adminConfig.CustomCategories || []).map((c) => [c.query + c.type, c])
+  );
+
+  customCategories.forEach((category) => {
+    const key = category.query + category.type;
+    const existedCategory = customCategoriesMap.get(key);
+    if (existedCategory) {
+      existedCategory.name = category.name;
+      existedCategory.query = category.query;
+      existedCategory.type = category.type;
+      existedCategory.from = 'config';
+    } else {
+      customCategoriesMap.set(key, {
+        name: category.name,
+        type: category.type,
+        query: category.query,
+        from: 'config',
+        disabled: false,
+      });
+    }
+  });
+
+  // 检查现有 CustomCategories 是否在 fileConfig.custom_category 中，如果不在则标记为 custom
+  const customCategoriesKeys = new Set(
+    customCategories.map((c) => c.query + c.type)
+  );
+  customCategoriesMap.forEach((category) => {
+    if (!customCategoriesKeys.has(category.query + category.type)) {
+      category.from = 'custom';
+    }
+  });
+
+  // 将 Map 转换回数组
+  adminConfig.CustomCategories = Array.from(customCategoriesMap.values());
+
+  return adminConfig;
+}
+
+async function initConfig() {
+  if (cachedConfig) {
+    // 自检补全配置
+    cachedConfig = refineConfig(cachedConfig);
+    return;
+  }
+
+  // 数据库存储，读取并补全管理员配置
+  const storage = getStorage();
+
+  try {
+    // 尝试从数据库获取管理员配置
+    let adminConfig: AdminConfig | null = null;
+    if (storage && typeof (storage as any).getAdminConfig === 'function') {
+      adminConfig = await (storage as any).getAdminConfig();
+    }
+
+    // 获取所有用户名，用于补全 Users
+    let userNames: string[] = [];
+    if (storage && typeof (storage as any).getAllUsers === 'function') {
+      try {
+        userNames = await (storage as any).getAllUsers();
+      } catch (e) {
+        console.error('获取用户列表失败:', e);
+      }
+    }
+
+    if (adminConfig) {
+      try {
+        fileConfig = JSON.parse(adminConfig.ConfigFile) as ConfigFileStruct;
+      } catch (e) {
+        console.error('解析配置文件失败:', e);
+        fileConfig = {} as ConfigFileStruct;
+      }
+      const apiSiteEntries = Object.entries(fileConfig.api_site || []);
+      const customCategories = fileConfig.custom_category || [];
+
+      // 补全 SourceConfig
+      const sourceConfigMap = new Map(
+        (adminConfig.SourceConfig || []).map((s) => [s.key, s])
+      );
+
+      apiSiteEntries.forEach(([key, site]) => {
+        sourceConfigMap.set(key, {
+          key,
+          name: site.name,
+          api: site.api,
+          detail: site.detail,
+          from: 'config',
+          disabled: false,
+        });
+      });
+
+      // 将 Map 转换回数组
+      adminConfig.SourceConfig = Array.from(sourceConfigMap.values());
+
+      // 检查现有源是否在 fileConfig.api_site 中，如果不在则标记为 custom
+      const apiSiteKeys = new Set(apiSiteEntries.map(([key]) => key));
+      adminConfig.SourceConfig.forEach((source) => {
+        if (!apiSiteKeys.has(source.key)) {
+          source.from = 'custom';
+        }
+      });
+
+      // 确保 CustomCategories 被初始化
+      if (!adminConfig.CustomCategories) {
+        adminConfig.CustomCategories = [];
+      }
+
+      // 补全 CustomCategories
+      const customCategoriesMap = new Map(
+        adminConfig.CustomCategories.map((c) => [c.query + c.type, c])
+      );
+
+      customCategories.forEach((category) => {
+        customCategoriesMap.set(category.query + category.type, {
           name: category.name,
           type: category.type,
           query: category.query,
           from: 'config',
           disabled: false,
-        })) || [],
-    } as AdminConfig;
+        });
+      });
+
+      // 检查现有 CustomCategories 是否在 fileConfig.custom_category 中，如果不在则标记为 custom
+      const customCategoriesKeys = new Set(
+        customCategories.map((c) => c.query + c.type)
+      );
+      customCategoriesMap.forEach((category) => {
+        if (!customCategoriesKeys.has(category.query + category.type)) {
+          category.from = 'custom';
+        }
+      });
+
+      // 将 Map 转换回数组
+      adminConfig.CustomCategories = Array.from(customCategoriesMap.values());
+
+      const existedUsers = new Set(
+        (adminConfig.UserConfig.Users || []).map((u) => u.username)
+      );
+      userNames.forEach((uname) => {
+        if (!existedUsers.has(uname)) {
+          adminConfig!.UserConfig.Users.push({
+            username: uname,
+            role: 'user',
+          });
+        }
+      });
+      // 站长
+      const ownerUser = process.env.USERNAME;
+      if (ownerUser) {
+        adminConfig!.UserConfig.Users = adminConfig!.UserConfig.Users.filter(
+          (u) => u.username !== ownerUser
+        );
+        adminConfig!.UserConfig.Users.unshift({
+          username: ownerUser,
+          role: 'owner',
+        });
+      }
+    } else {
+      fileConfig = {} as ConfigFileStruct;
+      // 数据库中没有配置，创建新的管理员配置
+      let allUsers = userNames.map((uname) => ({
+        username: uname,
+        role: 'user',
+      }));
+      const ownerUser = process.env.USERNAME;
+      if (ownerUser) {
+        allUsers = allUsers.filter((u) => u.username !== ownerUser);
+        allUsers.unshift({
+          username: ownerUser,
+          role: 'owner',
+        });
+      }
+      adminConfig = {
+        ConfigFile: '',
+        SiteConfig: {
+          SiteName: process.env.NEXT_PUBLIC_SITE_NAME || 'MoonTV',
+          Announcement:
+            process.env.ANNOUNCEMENT ||
+            '本网站仅提供影视信息搜索服务，所有内容均来自第三方网站。本站不存储任何视频资源，不对任何内容的准确性、合法性、完整性负责。',
+          SearchDownstreamMaxPage:
+            Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5,
+          SiteInterfaceCacheTime: fileConfig.cache_time || 7200,
+          DoubanProxyType:
+            process.env.NEXT_PUBLIC_DOUBAN_PROXY_TYPE || 'direct',
+          DoubanProxy: process.env.NEXT_PUBLIC_DOUBAN_PROXY || '',
+          DoubanImageProxyType:
+            process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY_TYPE || 'direct',
+          DoubanImageProxy: process.env.NEXT_PUBLIC_DOUBAN_IMAGE_PROXY || '',
+          DisableYellowFilter:
+            process.env.NEXT_PUBLIC_DISABLE_YELLOW_FILTER === 'true',
+        },
+        UserConfig: {
+          AllowRegister: process.env.NEXT_PUBLIC_ENABLE_REGISTER === 'true',
+          Users: allUsers as any,
+        },
+        SourceConfig: [],
+        CustomCategories: [],
+      };
+    }
+
+    // 写回数据库（更新/创建）
+    if (storage && typeof (storage as any).setAdminConfig === 'function') {
+      await (storage as any).setAdminConfig(adminConfig);
+    }
+
+    // 更新缓存
+    cachedConfig = adminConfig;
+  } catch (err) {
+    console.error('加载管理员配置失败:', err);
   }
 }
 
 export async function getConfig(): Promise<AdminConfig> {
-  const storageType = process.env.NEXT_PUBLIC_STORAGE_TYPE || 'localstorage';
-  if (process.env.DOCKER_ENV === 'true' || storageType === 'localstorage') {
+  if (process.env.DOCKER_ENV === 'true') {
     await initConfig();
     return cachedConfig;
   }
@@ -320,9 +342,15 @@ export async function getConfig(): Promise<AdminConfig> {
     adminConfig.SiteConfig.DisableYellowFilter =
       process.env.NEXT_PUBLIC_DISABLE_YELLOW_FILTER === 'true';
 
+    try {
+      fileConfig = JSON.parse(adminConfig.ConfigFile) as ConfigFileStruct;
+    } catch (e) {
+      console.error('解析配置文件失败:', e);
+      fileConfig = {} as ConfigFileStruct;
+    }
+
     // 合并文件中的源信息
-    fileConfig = runtimeConfig as unknown as ConfigFileStruct;
-    const apiSiteEntries = Object.entries(fileConfig.api_site);
+    const apiSiteEntries = Object.entries(fileConfig.api_site || []);
     const sourceConfigMap = new Map(
       (adminConfig.SourceConfig || []).map((s) => [s.key, s])
     );
@@ -398,8 +426,19 @@ export async function getConfig(): Promise<AdminConfig> {
 }
 
 export async function resetConfig() {
-  const storageType = process.env.NEXT_PUBLIC_STORAGE_TYPE || 'localstorage';
+  let originConfig: AdminConfig | null = null;
   const storage = getStorage();
+  if (storage && typeof (storage as any).getAdminConfig === 'function') {
+    originConfig = await (storage as any).getAdminConfig();
+  }
+
+  if (originConfig) {
+    fileConfig = JSON.parse(originConfig.ConfigFile) as ConfigFileStruct;
+  } else {
+    fileConfig = {} as ConfigFileStruct;
+  }
+
+  const storageType = process.env.NEXT_PUBLIC_STORAGE_TYPE;
   // 获取所有用户名，用于补全 Users
   let userNames: string[] = [];
   if (storage && typeof (storage as any).getAllUsers === 'function') {
@@ -410,22 +449,7 @@ export async function resetConfig() {
     }
   }
 
-  if (process.env.DOCKER_ENV === 'true') {
-    // eslint-disable-next-line @typescript-eslint/no-implied-eval
-    const _require = eval('require') as NodeRequire;
-    const fs = _require('fs') as typeof import('fs');
-    const path = _require('path') as typeof import('path');
-
-    const configPath = path.join(process.cwd(), 'config.json');
-    const raw = fs.readFileSync(configPath, 'utf-8');
-    fileConfig = JSON.parse(raw) as ConfigFileStruct;
-    console.log('load dynamic config success');
-  } else {
-    // 默认使用编译时生成的配置
-    fileConfig = runtimeConfig as unknown as ConfigFileStruct;
-  }
-
-  const apiSiteEntries = Object.entries(fileConfig.api_site);
+  const apiSiteEntries = Object.entries(fileConfig.api_site || []);
   const customCategories = fileConfig.custom_category || [];
   let allUsers = userNames.map((uname) => ({
     username: uname,
@@ -440,6 +464,7 @@ export async function resetConfig() {
     });
   }
   const adminConfig = {
+    ConfigFile: originConfig?.ConfigFile || '',
     SiteConfig: {
       SiteName: process.env.NEXT_PUBLIC_SITE_NAME || 'MoonTV',
       Announcement:
@@ -471,12 +496,12 @@ export async function resetConfig() {
     CustomCategories:
       storageType === 'redis'
         ? customCategories?.map((category) => ({
-            name: category.name,
-            type: category.type,
-            query: category.query,
-            from: 'config',
-            disabled: false,
-          })) || []
+          name: category.name,
+          type: category.type,
+          query: category.query,
+          from: 'config',
+          disabled: false,
+        })) || []
         : [],
   } as AdminConfig;
 
@@ -487,10 +512,11 @@ export async function resetConfig() {
     // serverless 环境，直接使用 adminConfig
     cachedConfig = adminConfig;
   }
+  cachedConfig.ConfigFile = adminConfig.ConfigFile;
   cachedConfig.SiteConfig = adminConfig.SiteConfig;
   cachedConfig.UserConfig = adminConfig.UserConfig;
   cachedConfig.SourceConfig = adminConfig.SourceConfig;
-  cachedConfig.CustomCategories = adminConfig.CustomCategories;
+  cachedConfig.CustomCategories = adminConfig.CustomCategories || [];
 }
 
 export async function getCacheTime(): Promise<number> {