Function TestWaitForTaskFailure

internal/cli/cli_helpers_test.go:232–267

(t *testing.T)

}

func TestWaitForTaskFailure(t *testing.T) {
	const upid = "UPID:pve:00001234:00000000:test:qmcreate:100:user@pam:"

	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		w.Header().Set("Content-Type", "application/json")

		switch {
		case r.URL.Path == "/api2/json/access/ticket":
			_, _ = w.Write([]byte(authResponse))
		case r.URL.Path == "/api2/json/cluster/tasks":
			// Task finished with an error status.
			body := `{"data":[{"upid":"` + upid + `","status":"disk full","endtime":1700000060,"starttime":1700000000,"node":"pve","type":"qmcreate"}]}`
			_, _ = w.Write([]byte(body))
		case strings.Contains(r.URL.Path, "/tasks/") && strings.HasSuffix(r.URL.Path, "/status"):
			_, _ = w.Write([]byte(taskStatusResponse("disk full")))
		default:
			http.NotFound(w, r)
		}
	}))
	defer server.Close()

	client := newTestClient(t, server.URL)

	exitStatus, err := waitForTask(context.Background(), client, "pve", upid, "test-op")
	if err == nil {
		t.Fatal("waitForTask returned nil error, expected non-nil for failed task")
	}

	if !strings.Contains(err.Error(), "disk full") {
		t.Errorf("error message %q does not mention failure reason", err.Error())
	}

	if exitStatus != "ERROR" {
		t.Errorf("exitStatus = %q, want %q", exitStatus, "ERROR")
	}
}

func TestWaitForTaskCancelled(t *testing.T) {
	const upid = "UPID:pve:00001234:00000000:test:qmcreate:100:user@pam:"