Function testFileWriterIntegrationDeterministic

output/filewriter_test.go:286–313

testFileWriterIntegration builds and run a topology reading from testdata/filewriter/input.csv.log.zst and using the FileWriter output, configured with the given pathString (in pathString, "TMPDIR" gets replaced at runtime by the test case temporary directory). Once the topology exits, the content

(t *testing.T, pathString string)

//
// To update the golden file, run: go test -race -run TestName -update
func testFileWriterIntegrationDeterministic(t *testing.T, pathString string) {
	const procs = 1
	const rotate = -1

	tmpDir := t.TempDir()
	testFileWriterIntegration(t, tmpDir, pathString, procs, rotate)

	buf := &bytes.Buffer{}
	if err := dirtree.Write(buf, tmpDir, dirtree.ModeAll, dirtree.ExcludeRoot); err != nil {
		t.Fatal(err)
	}

	golden := filepath.Join("testdata", "filewriter", t.Name()+".golden")
	if testutil.UpdateGolden != nil && *testutil.UpdateGolden {
		if err := os.WriteFile(golden, buf.Bytes(), os.ModePerm); err != nil {
			t.Fatalf("can't update golden file: %v", err)
		}
	}

	testutil.DiffWithGolden(t, buf.Bytes(), golden)
	if t.Failed() {
		dirCpy := filepath.Join(os.TempDir(), t.Name()+".golden")
		fmt.Printf("ERROR: copying output directory to %q for investigation\n\n", dirCpy)
		if err := testutil.CopyDirectory(tmpDir, dirCpy); err != nil {
			t.Fatal(err)
		}
	}
}

// testFileWriterIntegrationCheckRecords builds and run a topology reading from
// /testdata/filewriter/input.csv.log.zst and using the FileWriter output,