Function TestParallelProcessingDeterministicOutput

pkg/app/app_parallel_test.go:17–85

TestParallelProcessingDeterministicOutput verifies that ListReleases produces consistent sorted output even with parallel processing of multiple helmfile.d files

(t *testing.T)

// TestParallelProcessingDeterministicOutput verifies that ListReleases produces
// consistent sorted output even with parallel processing of multiple helmfile.d files
func TestParallelProcessingDeterministicOutput(t *testing.T) {
	files := map[string]string{
		"/path/to/helmfile.d/z-last.yaml": `
releases:
- name: zulu-release
  chart: stable/chart-z
  namespace: ns-z
`,
		"/path/to/helmfile.d/a-first.yaml": `
releases:
- name: alpha-release
  chart: stable/chart-a
  namespace: ns-a
`,
		"/path/to/helmfile.d/m-middle.yaml": `
releases:
- name: mike-release
  chart: stable/chart-m
  namespace: ns-m
`,
	}

	// Run ListReleases multiple times to verify consistent ordering
	var outputs []string
	for i := 0; i < 5; i++ {
		var buffer bytes.Buffer
		syncWriter := testhelper.NewSyncWriter(&buffer)
		logger := helmexec.NewLogger(syncWriter, "debug")

		valsRuntime, err := vals.New(vals.Options{CacheSize: 32})
		if err != nil {
			t.Fatalf("unexpected error creating vals runtime: %v", err)
		}

		app := appWithFs(&App{
			OverrideHelmBinary:              DefaultHelmBinary,
			fs:                              ffs.DefaultFileSystem(),
			OverrideKubeContext:             "default",
			DisableKubeVersionAutoDetection: true,
			Env:                             "default",
			Logger:                          logger,
			valsRuntime:                     valsRuntime,
			FileOrDir:                       "/path/to/helmfile.d",
		}, files)

		expectNoCallsToHelm(app)

		err = app.ListReleases(configImpl{
			skipCharts: false,
			output:     "table",
		})

		if err != nil {
			t.Fatalf("unexpected error on iteration %d: %v", i, err)
		}

		outputs = append(outputs, buffer.String())
	}