Refactor configuration management and environment setup

- Simplified config initialization with new `initDefaultConfigSources()` method
- Updated `.env.example` with more descriptive comments and reorganized API keys
- Added optional database configuration flag `ENABLE_DB`
- Removed redundant database initialization in multiple files
- Improved configuration source management in ConfigManager

Author: liyown

.env.example

@@ -1,38 +1,37 @@
+#如果需要使用数据库配置（先从数据库查找配置key，然后再env寻找）：
+ENABLE_DB=true
+DB_HOST=xxxx
+DB_PORT=xxxx
+DB_USER=xxxx
+DB_PASSWORD=xxxx
+DB_DATABASE=xxxx
 
-#Craw API
-## Required if monitoring web pages (https://www.firecrawl.dev/)
-FIRECRAWL_API_KEY=your_firecrawl_api_key
 
-# Required if monitoring Twitter/X trends (https://developer.x.com/)
-X_API_BEARER_TOKEN=your_twitter_api_bearer_token
+#微信文章获取的必备环境：
 
+# DeepseekAI API 配置 https://api-docs.deepseek.com/ 获取
+DEEPSEEK_API_KEY=your_api_key
 
-# Summarizer API
-## DeepSeek AI Required from https://www.deepseek.com/
-DEEPSEEK_API_KEY=your_deepseek_api_key
+# FireCrawl 配置 https://www.firecrawl.dev/ 获取
+FIRE_CRAWL_API_KEY=your_api_key
 
-## image generation api, required from https://www.getimg.ai/
-GETIMG_API_KEY=your_getimg_api_key
+# Twitter API 配置  https://twitterapi.io/ 获取
+X_API_BEARER_TOKEN=your_api_key
 
-# Required: API key from Together AI for trend analysis (https://www.together.ai/)
-TOGETHER_API_KEY=your_together_api_key
+# 千问 https://bailian.console.aliyun.com/ 获取
+DASHSCOPE_API_KEY=your_api_key
 
-
-# Public API
-## weixin gongzhonghao
+# 微信公众号配置
 WEIXIN_APP_ID=your_app_id
-WEIXIN_APP_SECRET=your_app_secret   
+WEIXIN_APP_SECRET=your_app_secret
 
 
-# Notification
-## Bark Push Key
-BARK_URL=https://api.day.app/
+#可选环境:
 
+# Bark 通知配置
+BARK_KEY=your_key
 
-# Database
-DB_HOST=your_db_host
-DB_PORT=your_db_port
-DB_USER=your_db_user
-DB_PASSWORD=your_db_password
-DB_DATABASE=your_db_database
+# 获取图片 API 配置 https://getimg.cc/ 获取
+GETIMG_API_KEY=your_api_key
 
+TOGETHER_API_KEY=your_api_key

src/index.ts

@@ -1,21 +1,9 @@
 import { startCronJobs } from "./controllers/cron";
 import { ConfigManager } from "./utils/config/config-manager";
-import { EnvConfigSource } from "./utils/config/sources/env-config.source";
-import { DbConfigSource } from "./utils/config/sources/db-config.source";
-import { MySQLDB } from "./utils/db/mysql.db";
 
 async function bootstrap() {
   const configManager = ConfigManager.getInstance();
-  configManager.addSource(new EnvConfigSource());
-
-  const db = await MySQLDB.getInstance({
-    host: process.env.DB_HOST,
-    port: Number(process.env.DB_PORT),
-    user: process.env.DB_USER,
-    password: process.env.DB_PASSWORD,
-    database: process.env.DB_DATABASE,
-  });
-  configManager.addSource(new DbConfigSource(db));
+  await configManager.initDefaultConfigSources();
 
   startCronJobs();
 }

src/test.ts

@@ -7,16 +7,8 @@ import { WeixinAIBenchWorkflow } from "./services/weixin-aibench.workflow";
 import { WeixinHelloGithubWorkflow } from "./services/weixin-hellogithub.workflow";
 async function bootstrap() {
   const configManager = ConfigManager.getInstance();
-  configManager.addSource(new EnvConfigSource());
+  await configManager.initDefaultConfigSources();
 
-  const db = await MySQLDB.getInstance({
-    host: process.env.DB_HOST,
-    port: Number(process.env.DB_PORT),
-    user: process.env.DB_USER,
-    password: process.env.DB_PASSWORD,
-    database: process.env.DB_DATABASE,
-  });
-  configManager.addSource(new DbConfigSource(db));
 
   const weixinWorkflow = new WeixinWorkflow();
 

src/utils/config/config-manager.ts

@@ -1,5 +1,7 @@
 import { IConfigSource } from "./interfaces/config-source.interface";
-
+import { DbConfigSource } from "./sources/db-config.source";
+import { EnvConfigSource } from "./sources/env-config.source";
+import { MySQLDB } from "../db/mysql.db";
 export class ConfigurationError extends Error {
   constructor(message: string) {
     super(message);
@@ -20,7 +22,7 @@ export class ConfigManager {
     delayMs: 1000,
   };
 
-  private constructor() {}
+  private constructor() { }
 
   public static getInstance(): ConfigManager {
     if (!ConfigManager.instance) {
@@ -49,7 +51,7 @@ export class ConfigManager {
     options: RetryOptions
   ): Promise<T | null> {
     let lastError: Error | null = null;
-    
+
     for (let attempt = 1; attempt <= options.maxAttempts; attempt++) {
       try {
         const value = await source.get<T>(key);
@@ -65,6 +67,21 @@ export class ConfigManager {
     console.warn(`Failed to get config "${key}" after ${options.maxAttempts} attempts. Last error: ${lastError?.message}`);
     return null;
   }
+  public async initDefaultConfigSources(): Promise<void> {
+    // 环境变量
+    this.addSource(new EnvConfigSource());
+    // Database
+    if (await this.get<boolean>('ENABLE_DB')) {
+      const db = await MySQLDB.getInstance({
+        host: process.env.DB_HOST,
+        port: Number(process.env.DB_PORT),
+        user: process.env.DB_USER,
+        password: process.env.DB_PASSWORD,
+        database: process.env.DB_DATABASE,
+      });
+      this.addSource(new DbConfigSource(db));
+    }
+  }
 
   /**
    * 获取配置值