feat:优化

.envExample

@@ -5,3 +5,6 @@ TOKEN=54188
 OPENLIST_API_BASE_URL=http://127.0.0.1:5244
 OPENLIST_API_BASE_USERNAME=USER
 OPENLIST_API_BASE_PASSWORD=123456
+OPENLIST_API_MEME_PATH=/crystelf/meme
+OPENLIST_API_CDN_PATH=/crystelf/cdn
+

src/config/config.service.ts

@@ -1,9 +1,13 @@
 import { Inject, Injectable, Logger, OnModuleInit } from '@nestjs/common';
 import { ConfigService as NestConfigService } from '@nestjs/config';
+import * as fs from 'fs';
+import * as path from 'path';
 
 @Injectable()
 export class AppConfigService implements OnModuleInit {
   private readonly logger = new Logger(AppConfigService.name);
+  private readonly envPath = path.resolve(process.cwd(), '.env');
+  private readonly envExamplePath = path.resolve(process.cwd(), '.envExample');
 
   constructor(
     @Inject(NestConfigService)
@@ -11,13 +15,11 @@ export class AppConfigService implements OnModuleInit {
   ) {}
 
   onModuleInit() {
-    this.checkRequiredVariables();
+    this.checkAndSyncEnv();
   }
 
   /**
    * 获取环境变量
-   * @param key 键值
-   * @param defaultValue 默认
    */
   public get<T = string>(key: string, defaultValue?: T): T | undefined {
     const value = this.nestConfigService.get<T>(key);
@@ -30,17 +32,60 @@ export class AppConfigService implements OnModuleInit {
     return value;
   }
 
-  private checkRequiredVariables(): void {
-    this.logger.log('检查必要环境变量..');
-    const requiredVariables = ['RD_PORT', 'RD_ADD', 'WS_SECRET'];
+  /**
+   * 检查并补全 .env 文件
+   */
+  private checkAndSyncEnv(): void {
+    this.logger.log('检查并同步 .env 与 .env.example ...');
 
-    requiredVariables.forEach((key) => {
-      const value = this.nestConfigService.get(key);
-      if (value === undefined || value === null) {
-        this.logger.fatal(`必需环境变量缺失: ${key}`);
-      } else {
-        this.logger.debug(`检测到环境变量: ${key}`);
+    if (!fs.existsSync(this.envExamplePath)) {
+      this.logger.error(`缺少 ${this.envExamplePath} 文件，无法校验`);
+      return;
+    }
+
+    const exampleContent = fs.readFileSync(this.envExamplePath, 'utf8');
+    const exampleVars = this.parseEnv(exampleContent);
+
+    let envContent = fs.existsSync(this.envPath)
+      ? fs.readFileSync(this.envPath, 'utf8')
+      : '';
+    const envVars = this.parseEnv(envContent);
+
+    let updated = false;
+    for (const key of Object.keys(exampleVars)) {
+      if (!(key in envVars)) {
+        const value = exampleVars[key] ?? '';
+        envContent += `\n${key}=${value}`;
+        this.logger.warn(`补全缺失环境变量: ${key}=${value}`);
+        updated = true;
       }
-    });
+    }
+
+    if (updated) {
+      fs.writeFileSync(this.envPath, envContent.trim() + '\n', {
+        encoding: 'utf8',
+      });
+      this.logger.log('.env 已自动补全缺失项');
+    } else {
+      this.logger.log('.env 已与 .env.example 保持一致');
+    }
+  }
+
+  /**
+   * 解析.env为对象
+   * @param content
+   * @private
+   */
+  private parseEnv(content: string): Record<string, string> {
+    const result: Record<string, string> = {};
+    content
+      .split('\n')
+      .map((line) => line.trim())
+      .filter((line) => line && !line.startsWith('#'))
+      .forEach((line) => {
+        const [key, ...rest] = line.split('=');
+        result[key.trim()] = rest.join('=').trim();
+      });
+    return result;
   }
 }