fix:meme服务修复

src/config/config.service.ts

@@ -36,7 +36,7 @@ export class AppConfigService implements OnModuleInit {
    * 检查并补全 .env 文件
    */
   private checkAndSyncEnv(): void {
-    this.logger.log('检查并同步 .env 与 .env.example ...');
+    this.logger.log('检查并同步 .env 与 .envExample ...');
 
     if (!fs.existsSync(this.envExamplePath)) {
       this.logger.error(`缺少 ${this.envExamplePath} 文件，无法校验`);
@@ -67,7 +67,7 @@ export class AppConfigService implements OnModuleInit {
       });
       this.logger.log('.env 已自动补全缺失项');
     } else {
-      this.logger.log('.env 已与 .env.example 保持一致');
+      this.logger.log('.env 已与 .envExample 保持一致');
     }
   }
 

src/core/openlist/openlist.service.ts

@@ -66,7 +66,7 @@ export class OpenListService {
 
   /**
    * 列出目录下的所有文件
-   * @param path 目录路径
+   * @param path 服务器目录路径
    * @returns 目录下的文件列表
    */
   public async listFiles(path: string): Promise<FsList> {

src/core/openlist/openlist.types.ts

@@ -5,18 +5,18 @@ export interface FsList {
   code: number;
   message: string;
   data: {
-    content: [
-      name: string,
-      size: number,
-      is_dir: boolean,
-      modified: string, //修改时间
-      sign: string, //签名
-      thumb: string, //略缩图
-      type: number, //类型
-    ];
-    total: number; //总数
-    readme: string; //说明?
-    write: boolean; //是否可写入
+    content: Array<{
+      name: string;
+      size: number;
+      is_dir: boolean;
+      modified: string; // 修改时间
+      sign: string; // 签名
+      thumb: string; // 略缩图
+      type: number; // 类型
+    }> | null; // 可能为空数组
+    total: number; // 总数
+    readme: string; // 说明?
+    write: boolean; // 是否可写入
     provider: string;
     header: string;
   };

src/core/openlist/openlist.utils.ts

@@ -50,10 +50,20 @@ export class OpenListUtils {
   static async listDirectory(token: string, path: string): Promise<FsList> {
     const url = `${this.apiBaseUrl}/api/fs/list`;
     try {
-      const response = await axios.get(url, {
-        params: { path },
-        headers: { Authorization: `Bearer ${token}` },
+      let data = JSON.stringify({
+        path: path,
       });
+      //this.logger.debug(path);
+      let config = {
+        method: 'post',
+        url: `${url}`,
+        headers: {
+          'Content-Type': 'application/json',
+          Authorization: `${token}`,
+        },
+        data: data,
+      };
+      let response = await axios(config);
       this.logger.log(`列出目录${path}成功..`);
       return response.data;
     } catch (error) {
@@ -72,7 +82,7 @@ export class OpenListUtils {
     try {
       const response = await axios.get(url, {
         params: { path: filePath },
-        headers: { Authorization: `Bearer ${token}` },
+        headers: { Authorization: `${token}` },
       });
       this.logger.log('获取文件信息成功..');
       return response.data;
@@ -96,6 +106,7 @@ export class OpenListUtils {
     try {
       const fileInfo = await this.getFileInfo(token, filePath);
       const rawUrl = fileInfo.data.raw_url;
+      this.logger.debug(`rawUrl: ${rawUrl}`);
       if (!rawUrl) {
         this.logger.error('文件没有找到 raw_url 地址..');
         throw new Error('文件没有找到 raw_url 地址..');

src/core/path/path.service.ts

@@ -71,7 +71,6 @@ export class PathService {
       this.logger.debug(`成功创建目录: ${dirToCreate}`);
     } catch (err) {
       this.logger.error(`创建目录失败: ${err}`);
-      throw err;
     }
   }
 }

src/modules/meme/meme.module.ts

@@ -5,9 +5,16 @@ import { PathModule } from '../../core/path/path.module';
 import { ToolsModule } from '../../core/tools/tools.module';
 import { RedisModule } from '../../core/redis/redis.module';
 import { OpenListModule } from '../../core/openlist/openlist.module';
+import { AppConfigModule } from '../../config/config.module';
 
 @Module({
-  imports: [PathModule, OpenListModule, ToolsModule, RedisModule],
+  imports: [
+    PathModule,
+    OpenListModule,
+    ToolsModule,
+    RedisModule,
+    AppConfigModule,
+  ],
   providers: [MemeService],
   controllers: [MemeController],
 })

src/modules/meme/meme.service.ts

@@ -3,17 +3,20 @@ import * as path from 'path';
 import * as fs from 'fs/promises';
 import { PathService } from '../../core/path/path.service';
 import { OpenListService } from '../../core/openlist/openlist.service';
+import { AppConfigService } from '../../config/config.service';
 
 @Injectable()
 export class MemeService {
   private readonly logger = new Logger(MemeService.name);
-  private readonly updateMs = 15 * 60 * 1000; // 15min
+  private readonly updateMs = 150 * 60 * 1000; // 15min
 
   constructor(
     @Inject(PathService)
     private readonly pathService: PathService,
     @Inject(OpenListService)
     private readonly openListService: OpenListService,
+    @Inject(AppConfigService)
+    private readonly configService: AppConfigService,
   ) {
     this.startAutoUpdate();
   }
@@ -21,22 +24,30 @@ export class MemeService {
   private startAutoUpdate() {
     setInterval(async () => {
       const memePath = path.join(this.pathService.get('meme'));
-      this.logger.log('定时检查表情仓库更新..');
-      try {
-        const remoteFiles = await this.openListService.listFiles(memePath);
-        if (remoteFiles.code === 200) {
-          const remoteFileList = remoteFiles.data.content;
-          const localFiles = await this.getLocalFileList(memePath);
-          await this.compareAndDownloadFiles(
-            memePath,
-            localFiles,
-            remoteFileList,
-          );
-        } else {
-          this.logger.error('获取远程表情仓库文件失败..');
+      const remoteMemePath = this.configService.get('OPENLIST_API_MEME_PATH');
+      if (remoteMemePath) {
+        this.logger.log('定时检查表情仓库更新..');
+        try {
+          const remoteFiles =
+            await this.openListService.listFiles(remoteMemePath);
+          if (remoteFiles.code === 200 && remoteFiles.data.content) {
+            let remoteFileList = remoteFiles.data.content;
+            const localFiles = await this.getLocalFileList(memePath);
+            //this.logger.debug(localFiles);
+            await this.compareAndDownloadFiles(
+              memePath,
+              localFiles,
+              remoteFileList,
+              remoteMemePath,
+            );
+          } else {
+            this.logger.error('获取远程表情仓库文件失败..');
+          }
+        } catch (error) {
+          this.logger.error('定时检查表情仓库更新失败..', error);
         }
-      } catch (error) {
-        this.logger.error('定时检查表情仓库更新失败..', error);
+      } else {
+        this.logger.warn('未配置远程表情包地址..');
       }
     }, this.updateMs);
   }
@@ -47,8 +58,8 @@ export class MemeService {
    * @private
    */
   private async getLocalFileList(dir: string): Promise<string[]> {
-    const files: string[] = []; //文件
-    const dirs: string[] = []; //目录
+    const files: string[] = [];
+    const dirs: string[] = [];
     try {
       const entries = await fs.readdir(dir, { withFileTypes: true });
       for (const entry of entries) {
@@ -70,37 +81,57 @@ export class MemeService {
   }
 
   /**
-   * 比较本地文件和远程文件,并下载缺失的文件
+   * 比较本地文件和远程文件 下载缺失的文件
    * @param localPath 本地路径
    * @param localFiles 本地文件列表
    * @param remoteFiles 远程文件列表
+   * @param remoteMemePath 远程基准路径
    * @private
    */
   private async compareAndDownloadFiles(
     localPath: string,
     localFiles: string[],
     remoteFiles: any[],
+    remoteMemePath: string,
   ) {
     for (const remoteFile of remoteFiles) {
-      const remoteFilePath = path.join(localPath, remoteFile.name);
+      let relativePath = path.relative(remoteMemePath, remoteFile.path);
+      relativePath = relativePath.replace(/D:\\alist\\crystelf\\meme/g, '');
+      const localFilePath = path.join(
+        localPath,
+        relativePath.replace(/\\/g, '/'),
+      );
       if (remoteFile.is_dir) {
-        await fs.mkdir(remoteFilePath, { recursive: true });
-        this.logger.log(`文件夹已创建: ${remoteFile.name}`);
-        await this.compareAndDownloadFiles(
-          remoteFilePath,
-          [],
-          remoteFile.content,
-        );
-      } else if (!localFiles.includes(remoteFilePath)) {
-        this.logger.log(`文件缺失: ${remoteFile.name}，开始下载..`);
         try {
-          await this.openListService.downloadFile(
-            remoteFile.raw_url,
-            remoteFilePath,
+          const localDirPath = path.dirname(localFilePath);
+          await fs.mkdir(localDirPath, { recursive: true });
+          this.logger.log(`文件夹已创建: ${localDirPath}`);
+          const subRemoteFiles = await this.openListService.listFiles(
+            remoteFile.path,
           );
-          this.logger.log(`文件下载成功: ${remoteFile.name}`);
+          if (subRemoteFiles.code === 200 && subRemoteFiles.data.content) {
+            await this.compareAndDownloadFiles(
+              localPath,
+              [],
+              subRemoteFiles.data.content,
+              remoteMemePath,
+            );
+          }
         } catch (error) {
-          this.logger.error(`下载文件失败: ${remoteFile.name}`, error);
+          this.logger.error(`创建文件夹失败: ${remoteFile.path}`, error);
+        }
+      } else {
+        if (!localFiles.includes(localFilePath)) {
+          this.logger.log(`文件缺失: ${remoteFile.path}, 开始下载..`);
+          try {
+            await this.openListService.downloadFile(
+              remoteFile.path,
+              localFilePath,
+            );
+            this.logger.log(`文件下载成功: ${remoteFile.path}`);
+          } catch (error) {
+            this.logger.error(`下载文件失败: ${remoteFile.path}`, error);
+          }
         }
       }
     }