feat: roughly admin info struct and interface

src/lib/admin.types.ts

@@ -0,0 +1,30 @@
+export interface AdminConfig {
+  SiteConfig: {
+    SiteName: string;
+    Announcement: string;
+    SearchDownstreamMaxPage: number;
+    SiteInterfaceCacheTime: number;
+    SearchResultDefaultAggregate: boolean;
+  };
+  UserConfig: {
+    AllowRegister: boolean;
+    Users: {
+      username: string;
+      role: 'user' | 'admin' | 'owner';
+      banned?: boolean;
+    }[];
+  };
+  SourceConfig: {
+    key: string;
+    name: string;
+    api: string;
+    detail?: string;
+    from: 'config' | 'custom';
+    disabled?: boolean;
+  }[];
+}
+
+export interface AdminConfigResult {
+  Role: 'owner' | 'admin';
+  Config: AdminConfig;
+}

src/lib/config.ts

@@ -1,5 +1,8 @@
-/* eslint-disable @typescript-eslint/no-explicit-any, no-console */
+/* eslint-disable @typescript-eslint/no-explicit-any, no-console, @typescript-eslint/no-non-null-assertion */
 
+import { getStorage } from '@/lib/db';
+
+import { AdminConfig } from './admin.types';
 import runtimeConfig from './runtime';
 
 export interface ApiSite {
@@ -9,23 +12,11 @@ export interface ApiSite {
   detail?: string;
 }
 
-export interface StorageConfig {
-  type: 'localstorage' | 'database';
-  database?: {
-    host?: string;
-    port?: number;
-    username?: string;
-    password?: string;
-    database?: string;
-  };
-}
-
-export interface Config {
+interface ConfigFileStruct {
   cache_time?: number;
   api_site: {
     [key: string]: ApiSite;
   };
-  storage?: StorageConfig;
 }
 
 export const API_CONFIG = {
@@ -49,7 +40,8 @@ export const API_CONFIG = {
 };
 
 // 在模块加载时根据环境决定配置来源
-let cachedConfig: Config;
+let fileConfig: ConfigFileStruct;
+let cachedConfig: AdminConfig;
 
 if (process.env.DOCKER_ENV === 'true') {
   // 这里用 eval("require") 避开静态分析，防止 Edge Runtime 打包时报 "Can't resolve 'fs'"
@@ -61,26 +53,171 @@ if (process.env.DOCKER_ENV === 'true') {
 
   const configPath = path.join(process.cwd(), 'config.json');
   const raw = fs.readFileSync(configPath, 'utf-8');
-  cachedConfig = JSON.parse(raw) as Config;
+  fileConfig = JSON.parse(raw) as ConfigFileStruct;
   console.log('load dynamic config success');
 } else {
   // 默认使用编译时生成的配置
-  cachedConfig = runtimeConfig as unknown as Config;
+  fileConfig = runtimeConfig as unknown as ConfigFileStruct;
+}
+const storageType = process.env.NEXT_PUBLIC_STORAGE_TYPE || 'localstorage';
+if (storageType !== 'localstorage') {
+  // 数据库存储，读取并补全管理员配置
+  const storage = getStorage();
+  (async () => {
+    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);
+
+      if (adminConfig) {
+        // 补全 SourceConfig
+        const existed = new Set(
+          (adminConfig.SourceConfig || []).map((s) => s.key)
+        );
+        apiSiteEntries.forEach(([key, site]) => {
+          if (!existed.has(key)) {
+            adminConfig!.SourceConfig.push({
+              key,
+              name: site.name,
+              api: site.api,
+              detail: site.detail,
+              from: 'config',
+              disabled: false,
+            });
+          }
+        });
+        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 adminUser = process.env.USERNAME;
+        if (adminUser) {
+          adminConfig!.UserConfig.Users = adminConfig!.UserConfig.Users.filter(
+            (u) => u.username !== adminUser
+          );
+          adminConfig!.UserConfig.Users.unshift({
+            username: adminUser,
+            role: 'owner',
+          });
+        }
+      } else {
+        // 数据库中没有配置，创建新的管理员配置
+        let allUsers = userNames.map((uname) => ({
+          username: uname,
+          role: 'user',
+        }));
+        const adminUser = process.env.USERNAME;
+        if (adminUser) {
+          allUsers = allUsers.filter((u) => u.username !== adminUser);
+          allUsers.unshift({
+            username: adminUser,
+            role: 'owner',
+          });
+        }
+        adminConfig = {
+          SiteConfig: {
+            SiteName: process.env.NEXT_PUBLIC_SITE_NAME || 'MoonTV',
+            Announcement:
+              process.env.NEXT_PUBLIC_ANNOUNCEMENT ||
+              '本网站仅提供影视信息搜索服务，所有内容均来自第三方网站。本站不存储任何视频资源，不对任何内容的准确性、合法性、完整性负责。',
+            SearchDownstreamMaxPage:
+              Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5,
+            SiteInterfaceCacheTime: fileConfig.cache_time || 7200,
+            SearchResultDefaultAggregate:
+              process.env.NEXT_PUBLIC_AGGREGATE_SEARCH_RESULT !== 'false',
+          },
+          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,
+          })),
+        };
+      }
+
+      // 写回数据库（更新/创建）
+      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.NEXT_PUBLIC_ANNOUNCEMENT ||
+        '本网站仅提供影视信息搜索服务，所有内容均来自第三方网站。本站不存储任何视频资源，不对任何内容的准确性、合法性、完整性负责。',
+      SearchDownstreamMaxPage:
+        Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5,
+      SiteInterfaceCacheTime: fileConfig.cache_time || 7200,
+      SearchResultDefaultAggregate:
+        process.env.NEXT_PUBLIC_AGGREGATE_SEARCH_RESULT !== 'false',
+    },
+    UserConfig: {
+      AllowRegister: process.env.NEXT_PUBLIC_ENABLE_REGISTER === 'true',
+      Users: [],
+    },
+    SourceConfig: Object.entries(fileConfig.api_site).map(([key, site]) => ({
+      key,
+      name: site.name,
+      api: site.api,
+      detail: site.detail,
+      from: 'config',
+      disabled: false,
+    })),
+  } as AdminConfig;
 }
 
-export function getConfig(): Config {
+export function getConfig(): AdminConfig {
   return cachedConfig;
 }
 
 export function getCacheTime(): number {
   const config = getConfig();
-  return config.cache_time || 300; // 默认5分钟缓存
+  return config.SiteConfig.SiteInterfaceCacheTime || 7200;
 }
 
-export function getApiSites(): ApiSite[] {
+export function getAvailableApiSites(): ApiSite[] {
   const config = getConfig();
-  return Object.entries(config.api_site).map(([key, site]) => ({
-    ...site,
-    key,
+  return config.SourceConfig.filter((s) => !s.disabled).map((s) => ({
+    key: s.key,
+    name: s.name,
+    api: s.api,
+    detail: s.detail,
   }));
 }

src/lib/db.ts

@@ -1,5 +1,7 @@
 /* eslint-disable no-console, @typescript-eslint/no-explicit-any, @typescript-eslint/no-non-null-assertion */
 
+import { AdminConfig } from './admin.types';
+
 // storage type 常量: 'localstorage' | 'database'，默认 'localstorage'
 const STORAGE_TYPE =
   (process.env.NEXT_PUBLIC_STORAGE_TYPE as
@@ -64,6 +66,10 @@ export interface IStorage {
 
   // 用户列表
   getAllUsers(): Promise<string[]>;
+
+  // 管理员配置相关
+  getAdminConfig(): Promise<AdminConfig | null>;
+  setAdminConfig(config: AdminConfig): Promise<void>;
 }
 
 // ---------------- Redis 实现 ----------------
@@ -221,6 +227,20 @@ class RedisStorage implements IStorage {
       })
       .filter((u): u is string => typeof u === 'string');
   }
+
+  // ---------- 管理员配置 ----------
+  private adminConfigKey() {
+    return 'admin:config';
+  }
+
+  async getAdminConfig(): Promise<AdminConfig | null> {
+    const val = await this.client.get(this.adminConfigKey());
+    return val ? (JSON.parse(val) as AdminConfig) : null;
+  }
+
+  async setAdminConfig(config: AdminConfig): Promise<void> {
+    await this.client.set(this.adminConfigKey(), JSON.stringify(config));
+  }
 }
 
 // 创建存储实例
@@ -394,6 +414,20 @@ export class DbManager {
     }
     return [];
   }
+
+  // ---------- 管理员配置 ----------
+  async getAdminConfig(): Promise<AdminConfig | null> {
+    if (typeof (this.storage as any).getAdminConfig === 'function') {
+      return (this.storage as any).getAdminConfig();
+    }
+    return null;
+  }
+
+  async saveAdminConfig(config: AdminConfig): Promise<void> {
+    if (typeof (this.storage as any).setAdminConfig === 'function') {
+      await (this.storage as any).setAdminConfig(config);
+    }
+  }
 }
 
 // 导出默认实例

src/lib/downstream.ts

@@ -1,10 +1,9 @@
-import { API_CONFIG, ApiSite } from '@/lib/config';
+import { API_CONFIG, ApiSite, getConfig } from '@/lib/config';
 import { SearchResult, VideoDetail } from '@/lib/types';
 import { cleanHtmlTags } from '@/lib/utils';
 
-// 根据环境变量决定最大搜索页数，默认 5
-const MAX_SEARCH_PAGES: number =
-  Number(process.env.NEXT_PUBLIC_SEARCH_MAX_PAGE) || 5;
+const config = getConfig();
+const MAX_SEARCH_PAGES: number = config.SiteConfig.SearchDownstreamMaxPage;
 
 interface ApiSearchItem {
   vod_id: string;

src/lib/fetchVideoDetail.ts

@@ -1,4 +1,4 @@
-import { getApiSites } from '@/lib/config';
+import { getAvailableApiSites } from '@/lib/config';
 import { SearchResult } from '@/lib/types';
 
 import { getDetailFromApi, searchFromApi } from './downstream';
@@ -34,7 +34,7 @@ export async function fetchVideoDetail({
   fallbackTitle = '',
 }: FetchVideoDetailOptions): Promise<VideoDetail> {
   // 优先通过搜索接口查找精确匹配
-  const apiSites = getApiSites();
+  const apiSites = getAvailableApiSites();
   const apiSite = apiSites.find((site) => site.key === source);
   if (!apiSite) {
     throw new Error('无效的API来源');

src/lib/runtime.ts

@@ -4,19 +4,19 @@
 export const config = {
   cache_time: 7200,
   api_site: {
-    dyttzy: {
-      api: 'http://caiji.dyttzyapi.com/api.php/provide/vod',
-      name: '电影天堂资源',
-      detail: 'http://caiji.dyttzyapi.com',
+    heimuer: {
+      api: 'https://json.heimuer.xyz/api.php/provide/vod',
+      name: '黑木耳',
+      detail: 'https://heimuer.tv',
     },
     ruyi: {
       api: 'https://cj.rycjapi.com/api.php/provide/vod',
       name: '如意资源',
     },
-    heimuer: {
-      api: 'https://json.heimuer.xyz/api.php/provide/vod',
-      name: '黑木耳',
-      detail: 'https://heimuer.tv',
+    dyttzy: {
+      api: 'http://caiji.dyttzyapi.com/api.php/provide/vod',
+      name: '电影天堂资源',
+      detail: 'http://caiji.dyttzyapi.com',
     },
     bfzy: {
       api: 'https://bfzyapi.com/api.php/provide/vod',