Function runFileExampleRoundTrip

integration_tests/idl_tests/go/idl_roundtrip_test.go:583–626

(
	t *testing.T,
	f *fory.Fory,
	message example.ExampleMessage,
	unionValue example.ExampleMessageUnion,
)

}

func runFileExampleRoundTrip(
	t *testing.T,
	f *fory.Fory,
	message example.ExampleMessage,
	unionValue example.ExampleMessageUnion,
) {
	if dataFile := os.Getenv("DATA_FILE_EXAMPLE"); dataFile != "" {
		payload, err := os.ReadFile(dataFile)
		if err != nil {
			t.Fatalf("read example data file: %v", err)
		}
		var decoded example.ExampleMessage
		if err := f.Deserialize(payload, &decoded); err != nil {
			t.Fatalf("deserialize example peer payload: %v", err)
		}
		assertExampleMessageEqual(t, message, decoded)
		out, err := f.Serialize(&decoded)
		if err != nil {
			t.Fatalf("serialize example peer payload: %v", err)
		}
		if err := os.WriteFile(dataFile, out, 0o644); err != nil {
			t.Fatalf("write example data file: %v", err)
		}
	}

	if dataFile := os.Getenv("DATA_FILE_EXAMPLE_UNION"); dataFile != "" {
		payload, err := os.ReadFile(dataFile)
		if err != nil {
			t.Fatalf("read example union data file: %v", err)
		}
		var decoded example.ExampleMessageUnion
		if err := f.Deserialize(payload, &decoded); err != nil {
			t.Fatalf("deserialize example union peer payload: %v", err)
		}
		assertExampleUnionEqual(t, unionValue, decoded)
		out, err := f.Serialize(&decoded)
		if err != nil {
			t.Fatalf("serialize example union peer payload: %v", err)
		}
		if err := os.WriteFile(dataFile, out, 0o644); err != nil {
			t.Fatalf("write example union data file: %v", err)
		}
	}
}

func assertExampleMessageEqual(t *testing.T, expected, actual example.ExampleMessage) {
	t.Helper()