跨平台临时文件清理架构

# 查看应用数据目录结构
adb shell "run-as com.e2eepan.e2eepan_client ls -la"
 
# 查看各目录大小
adb shell "run-as com.e2eepan.e2eepan_client find . -type d -exec du -sh {} \; 2>/dev/null"

import 'package:file_picker/file_picker.dart';

/// 清理单个临时文件（仅清理 cache 目录下的文件，避免误删文件）
void _cleanupTempFile(String filePath) {
  try {
    // 只清理 cache 目录下的临时文件，避免误删文件
    if (filePath.contains('/cache/') || filePath.contains('\\cache\\')) {
      final file = io.File(filePath);
      if (file.existsSync()) {
        file.deleteSync();
        debugPrint('[TempCleanup] Deleted: $filePath');
      }
    }
  } catch (e) {
    debugPrint('[TempCleanup] Failed to delete file: $e');
  }
}

/// 统一清理 file_picker 产生的所有临时文件（跨平台兼容）
Future<void> _cleanupFilePickerCache() async {
  try {
    final cleared = await FilePicker.platform.clearTemporaryFiles();
    debugPrint('[TempCleanup] FilePicker cache cleared: $cleared');
  } catch (e) {
    debugPrint('[TempCleanup] FilePicker cleanup failed: $e');
  }
}

// 在 _startUploadJob 完成时
_runningUploads--;
 
// 单文件清理：上传完成后立即删除临时文件
_cleanupTempFile(job.filePath);
 
// 检查是否所有上传已完成，是则调用 file_picker 的统一清理作为兜底
if (_runningUploads == 0 && _uploadQueue.isEmpty) {
  _cleanupFilePickerCache();
}

Future<void> _initCoreAndNetwork() async {
  await _loadPreferences();
  await _ensureCoreModeLoaded();
  await _maybeStartEmbeddedCore();
  await _checkInitialNetworkStatus();
  
  // 启动时清理上次运行可能残留的临时文件（跨平台）
  _cleanupFilePickerCache();
}

func (s *Server) uploadFile(c *gin.Context) {
    file, header, err := c.Request.FormFile("file")
    if err != nil {
        c.JSON(http.StatusBadRequest, gin.H{"error": "no file provided"})
        return
    }
    defer file.Close()
    
    // 清理 multipart 临时文件（大文件上传时 Go 会在 TMPDIR 创建临时文件）
    defer func() {
        if c.Request.MultipartForm != nil {
            c.Request.MultipartForm.RemoveAll()
        }
    }()
    
    // ... 处理上传
}

// cleanupTempDir 清理临时目录中的所有文件
// Gin 上传大文件时会在 TMPDIR 创建 multipart-xxx 临时文件
// 上传完成后 Gin 不会自动删除，需要我们在启动时清理
func cleanupTempDir(tmpDir string) {
    if tmpDir == "" {
        return
    }
    // 如果目录存在，删除并重建
    if _, err := os.Stat(tmpDir); err == nil {
        if err := os.RemoveAll(tmpDir); err != nil {
            log.Printf("Warning: cannot cleanup temp directory: %v", err)
        } else {
            log.Printf("Cleaned up temp directory: %s", tmpDir)
        }
    }
}

func Start(cfg *CoreConfig) error {
    // ...
    
    // 设置临时目录（优先使用 CacheDir，否则回退到 LogDir/tmp）
    if cfg != nil {
        var tmpDir string
        if cfg.CacheDir != "" {
            // 使用缓存目录下的 go_tmp 子目录
            tmpDir = filepath.Join(cfg.CacheDir, "go_tmp")
        } else if cfg.LogDir != "" {
            // 回退到日志目录下的 tmp 子目录
            tmpDir = filepath.Join(cfg.LogDir, "tmp")
        }
        if tmpDir != "" {
            // 启动时清理上次运行留下的临时文件
            cleanupTempDir(tmpDir)
            if err := os.MkdirAll(tmpDir, 0755); err == nil {
                os.Setenv("TMPDIR", tmpDir)
                log.Printf("Set TMPDIR to: %s", tmpDir)
            }
        }
    }
    
    // ...
}

// 旧代码
for obj := range listCh {
    s.client.RemoveObject(ctx, s.bucket, obj.Key, minio.RemoveObjectOptions{})
}

func (s *S3Client) DeletePrefix(ctx context.Context, prefix string) error {
    // 列出所有要删除的对象
    listCh := s.client.ListObjects(ctx, s.bucket, minio.ListObjectsOptions{
        Prefix:    prefix,
        Recursive: true,
    })
 
    // 转换为删除对象通道
    objectsCh := make(chan minio.ObjectInfo)
    go func() {
        defer close(objectsCh)
        for obj := range listCh {
            if obj.Err != nil {
                continue
            }
            objectsCh <- obj
        }
    }()
 
    // 批量删除
    errorCh := s.client.RemoveObjects(ctx, s.bucket, objectsCh, minio.RemoveObjectsOptions{})
 
    // 检查删除错误
    for err := range errorCh {
        if err.Err != nil {
            return fmt.Errorf("failed to delete %s: %w", err.ObjectName, err.Err)
        }
    }
 
    return nil
}

// 删除前
var (
    mu          sync.Mutex
    httpSrv     *http.Server
    logFile     *os.File
    logFilePath string
    server      *api.Server
    cacheDir    string // 保存缓存目录路径  ← 未使用
)
 
// 删除后
var (
    mu          sync.Mutex
    httpSrv     *http.Server
    logFile     *os.File
    logFilePath string
    server      *api.Server
)