Method uploadStickerPack

getstickers/getstickers.ts:408–513

(client: any, msg: Api.Message, setInfo: any, packDir: string)

  }
  
  private async uploadStickerPack(client: any, msg: Api.Message, setInfo: any, packDir: string): Promise<void> {
    let zipPath: string | undefined;
    try {
      await msg.edit({
        text: "下载完毕，打包上传中。"
      });
      
      zipPath = path.join(path.dirname(packDir), `${setInfo.shortName}.zip`);
      
      // 创建ZIP文件
      await this.createZipFile(packDir, zipPath);
      
      // 检查ZIP文件是否创建成功
      if (!fs.existsSync(zipPath)) {
        throw new Error('ZIP文件创建失败');
      }
      
      const stats = fs.statSync(zipPath);
      if (stats.size === 0) {
        throw new Error('ZIP文件为空');
      }
      
      console.log(`ZIP文件创建成功，大小: ${stats.size} 字节`);
      
      // 检查文件权限和可读性
      try {
        fs.accessSync(zipPath, fs.constants.R_OK);
        console.log('ZIP文件权限检查通过');
      } catch (accessError) {
        throw new Error(`ZIP文件无法读取: ${accessError}`);
      }
      
      // 尝试读取文件的前几个字节来验证文件完整性
       try {
         const buffer = fs.readFileSync(zipPath);
         if (buffer.length === 0) {
           throw new Error('ZIP文件无法读取或为空');
         }
         // 检查ZIP文件头（应该以PK开头）
         if (buffer.length >= 2 && buffer[0] === 0x50 && buffer[1] === 0x4B) {
           console.log('ZIP文件完整性检查通过');
         } else {
           throw new Error('ZIP文件格式无效');
         }
       } catch (readError) {
          throw new Error(`ZIP文件读取测试失败: ${readError}`);
        }
        
        // 等待一小段时间确保文件完全写入磁盘
        await new Promise(resolve => setTimeout(resolve, 1000));
        console.log('文件写入等待完成');
        
        // 上传ZIP文件
        console.log('开始上传ZIP文件...');
      // 使用 CustomFile 以流式上传，避免一次性读入内存导致的 buffer 创建失败
      const fileName = path.basename(zipPath);
      const customFile = new CustomFile(fileName, stats.size, zipPath);
      await client.sendFile(msg.peerId!, {