| // // Copyright 2021-2023 Buf Technologies, Inc. |
| // // |
| // // Licensed under the Apache License, Version 2.0 (the "License"); |
| // // you may not use this file except in compliance with the License. |
| // // You may obtain a copy of the License at |
| // // |
| // // http://www.apache.org/licenses/LICENSE-2.0 |
| // // |
| // // Unless required by applicable law or agreed to in writing, software |
| // // distributed under the License is distributed on an "AS IS" BASIS, |
| // // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // // See the License for the specific language governing permissions and |
| // // limitations under the License. |
| package triple_protocol |
| |
| // |
| //import ( |
| // "bytes" |
| // "strings" |
| // "testing" |
| // "testing/quick" |
| // |
| // "dubbo.apache.org/dubbo-go/v3/protocol/triple/triple_protocol/assert" |
| // pingv1 "dubbo.apache.org/dubbo-go/v3/protocol/triple/triple_protocol/proto/connect/ping/v1" |
| // "google.golang.org/protobuf/proto" |
| // "google.golang.org/protobuf/types/known/emptypb" |
| // "google.golang.org/protobuf/types/known/structpb" |
| //) |
| // |
| //func convertMapToInterface(stringMap map[string]string) map[string]interface{} { |
| // interfaceMap := make(map[string]interface{}) |
| // for key, value := range stringMap { |
| // interfaceMap[key] = value |
| // } |
| // return interfaceMap |
| //} |
| // |
| //func TestCodecRoundTrips(t *testing.T) { |
| // t.Parallel() |
| // makeRoundtrip := func(codec Codec) func(string, int64) bool { |
| // return func(text string, number int64) bool { |
| // got := pingv1.PingRequest{} |
| // want := pingv1.PingRequest{Text: text, Number: number} |
| // data, err := codec.Marshal(&want) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // err = codec.Unmarshal(data, &got) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // return proto.Equal(&got, &want) |
| // } |
| // } |
| // if err := quick.Check(makeRoundtrip(&protoBinaryCodec{}), nil /* config */); err != nil { |
| // t.Error(err) |
| // } |
| // if err := quick.Check(makeRoundtrip(&protoJSONCodec{}), nil /* config */); err != nil { |
| // t.Error(err) |
| // } |
| //} |
| // |
| //func TestStableCodec(t *testing.T) { |
| // t.Parallel() |
| // makeRoundtrip := func(codec stableCodec) func(map[string]string) bool { |
| // return func(input map[string]string) bool { |
| // initialProto, err := structpb.NewStruct(convertMapToInterface(input)) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // want, err := codec.MarshalStable(initialProto) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // for i := 0; i < 10; i++ { |
| // roundtripProto := &structpb.Struct{} |
| // err = codec.Unmarshal(want, roundtripProto) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // got, err := codec.MarshalStable(roundtripProto) |
| // if err != nil { |
| // t.Fatal(err) |
| // } |
| // if !bytes.Equal(got, want) { |
| // return false |
| // } |
| // } |
| // return true |
| // } |
| // } |
| // if err := quick.Check(makeRoundtrip(&protoBinaryCodec{}), nil /* config */); err != nil { |
| // t.Error(err) |
| // } |
| // if err := quick.Check(makeRoundtrip(&protoJSONCodec{}), nil /* config */); err != nil { |
| // t.Error(err) |
| // } |
| //} |
| // |
| //func TestJSONCodec(t *testing.T) { |
| // t.Parallel() |
| // |
| // var empty emptypb.Empty |
| // codec := &protoJSONCodec{name: "json"} |
| // err := codec.Unmarshal([]byte{}, &empty) |
| // assert.NotNil(t, err) |
| // assert.True( |
| // t, |
| // strings.Contains(err.Error(), "valid JSON"), |
| // assert.Sprintf(`error message should explain that "" is not a valid JSON object`), |
| // ) |
| //} |
