Function TestTaskStorage_DeleteFunc

pkg/task/queue/task_storage_test.go:151–182

TestTaskStorage_DeleteFunc tests the DeleteFunc operation

(t *testing.T)

// TestTaskStorage_DeleteFunc tests the DeleteFunc operation
func TestTaskStorage_DeleteFunc(t *testing.T) {
	ts := newTaskStorage()

	task1 := task.NewTask("test1")
	task2 := task.NewTask("test2")
	task3 := task.NewTask("test3")

	ts.AddLast(task1, task2, task3)

	// Delete tasks where Type is not "test2"
	ts.DeleteFunc(func(t task.Task) bool {
		return t.GetType() != "test2"
	})

	if ts.Length() != 2 {
		t.Errorf("Expected length 2 after DeleteFunc, got %d", ts.Length())
	}

	snapshot := ts.GetSnapshot()
	if snapshot[0] != task1 || snapshot[1] != task3 {
		t.Error("DeleteFunc failed: incorrect remaining tasks")
	}

	// Test DeleteFunc that deletes all
	ts.DeleteFunc(func(t task.Task) bool {
		return false
	})

	if ts.Length() != 0 {
		t.Errorf("Expected length 0 after deleting all, got %d", ts.Length())
	}
}

// TestTaskStorage_ProcessResult tests the ProcessResult operation
func TestTaskStorage_ProcessResult(t *testing.T) {