Function test_clean_tasks

src/task_manager.rs:380–447

()

    #[tokio::test]
    async fn test_clean_tasks() {
        // Set up test environment
        let (config, test_repo, ctx) = setup_test_environment().await.unwrap();
        let repo_root = test_repo.path().to_path_buf();

        // Create tasks with different statuses
        let queued_task_id = "queued-task-123".to_string();
        let completed_task_id = "completed-task-456".to_string();

        // Create task directories and files
        let queued_dir_path =
            setup_task_directory(&config, &queued_task_id, "Queued task instructions")
                .await
                .unwrap();
        let completed_dir_path =
            setup_task_directory(&config, &completed_task_id, "Completed task instructions")
                .await
                .unwrap();

        let queued_task = Task {
            id: queued_task_id.clone(),
            repo_root: repo_root.clone(),
            name: "queued-task".to_string(),
            branch_name: format!("tsk/{queued_task_id}"),
            copied_repo_path: Some(queued_dir_path.join("repo")),
            ..Task::test_default()
        };

        let completed_task = Task {
            id: completed_task_id.clone(),
            repo_root: repo_root.clone(),
            name: "completed-task".to_string(),
            task_type: "fix".to_string(),
            branch_name: format!("tsk/{completed_task_id}"),
            status: TaskStatus::Complete,
            copied_repo_path: Some(completed_dir_path.join("repo")),
            ..Task::test_default()
        };

        // Add tasks via storage API
        let storage = ctx.task_storage();
        storage.add_task(queued_task).await.unwrap();
        storage.add_task(completed_task).await.unwrap();

        // Create TaskManager and clean tasks
        let task_manager = TaskManager::new(&ctx).unwrap();

        let result = task_manager.clean_tasks(false, None).await;
        assert!(result.is_ok(), "Failed to clean tasks: {result:?}");
        let result = result.unwrap();
        assert_eq!(result.deleted, 1);
        assert_eq!(result.skipped, 0);

        // Verify directories are cleaned up
        assert!(
            queued_dir_path.exists(),
            "Queued task directory should still exist"
        );