Function TestSanitizeJSONKeys

plugins/destination/s3/client/write_test.go:40–85

(t *testing.T)

}

func TestSanitizeJSONKeys(t *testing.T) {
	m := map[string]any{
		"foo": "bar",
		"bar": map[string]any{
			"foo-bar": "baz",
		},
		"foo:bar":     "baz",
		"foo-bar-baz": []any{"baz", map[string]any{"foo:bar": "baz"}},
		"string": map[string]string{
			"foo-bar": "baz",
		},
		"int": map[string]int{
			"foo-bar": 123,
		},
		"pointer": map[string]*string{
			"foo-bar": &[]string{"baz"}[0],
		},
	}

	bytes, err := json.Marshal(m)
	require.NoError(t, err)
	var data any
	require.NoError(t, json.Unmarshal(bytes, &data))

	sanitized := sanitizeJSONKeysForObject(data)
	want := map[string]any{
		"foo": "bar",
		"bar": map[string]any{
			"foo_bar": "baz",
		},
		"foo_bar":     "baz",
		"foo_bar_baz": []any{"baz", map[string]any{"foo_bar": "baz"}},
		"string": map[string]any{
			"foo_bar": "baz",
		},
		"int": map[string]any{
			"foo_bar": 123.0,
		},
		"pointer": map[string]any{
			"foo_bar": "baz",
		},
	}
	if diff := cmp.Diff(want, sanitized); diff != "" {
		t.Errorf("sanitizeJSONKeys() mismatch (-want +got):\n%s", diff)
	}
}

func TestReplacePathVariables(t *testing.T) {
	cases := []struct {