Browse Source
Merge pull request #1987 from silasdavis/static-marshaler
Generate static marshalling methods for ABCI types to make compatible with downstream GRPC usagepull/2006/head
Anton Kaliaev
6 years ago
committed by
GitHub
GitHub
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
16 changed files with 16902 additions and 562 deletions
Split View
Diff Options
-
+0 -1.gitignore
-
+3 -0CHANGELOG.md
-
+159 -22Gopkg.lock
-
+2 -2Gopkg.toml
-
+14 -13Makefile
-
+10160 -451abci/types/types.pb.go
-
+10 -1abci/types/types.proto
-
+4281 -0abci/types/typespb_test.go
-
+1 -0codecov.yml
-
+621 -24libs/common/types.pb.go
-
+11 -0libs/common/types.proto
-
+280 -0libs/common/typespb_test.go
-
+0 -3rpc/grpc/compile.sh
-
+820 -45rpc/grpc/types.pb.go
-
+9 -0rpc/grpc/types.proto
-
+531 -0rpc/grpc/typespb_test.go
+ 0
- 1
.gitignore
View File
+ 3
- 0
CHANGELOG.md
View File
+ 159
- 22
Gopkg.lock
View File
+ 2
- 2
Gopkg.toml
View File
+ 14
- 13
Makefile
View File
+ 10160
- 451
abci/types/types.pb.go
File diff suppressed because it is too large
View File
+ 10
- 1
abci/types/types.proto
View File
+ 4281
- 0
abci/types/typespb_test.go
File diff suppressed because it is too large
View File
+ 1
- 0
codecov.yml
View File
+ 621
- 24
libs/common/types.pb.go
View File
+ 11
- 0
libs/common/types.proto
View File
+ 280
- 0
libs/common/typespb_test.go
View File
| @ -0,0 +1,280 @@ | |||
| // Code generated by protoc-gen-gogo. DO NOT EDIT. | |||
| // source: libs/common/types.proto | |||
| /* | |||
| Package common is a generated protocol buffer package. | |||
| It is generated from these files: | |||
| libs/common/types.proto | |||
| It has these top-level messages: | |||
| KVPair | |||
| KI64Pair | |||
| */ | |||
| package common | |||
| import testing "testing" | |||
| import rand "math/rand" | |||
| import time "time" | |||
| import proto "github.com/gogo/protobuf/proto" | |||
| import jsonpb "github.com/gogo/protobuf/jsonpb" | |||
| import golang_proto "github.com/golang/protobuf/proto" | |||
| import fmt "fmt" | |||
| import math "math" | |||
| import _ "github.com/gogo/protobuf/gogoproto" | |||
| // Reference imports to suppress errors if they are not otherwise used. | |||
| var _ = proto.Marshal | |||
| var _ = golang_proto.Marshal | |||
| var _ = fmt.Errorf | |||
| var _ = math.Inf | |||
| func TestKVPairProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KVPair{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestKVPairMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KVPair{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKI64PairProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KI64Pair{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestKI64PairMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KI64Pair{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKVPairJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KVPair{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKI64PairJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &KI64Pair{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKVPairProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &KVPair{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKVPairProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &KVPair{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKI64PairProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &KI64Pair{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKI64PairProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &KI64Pair{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestKVPairSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKVPair(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| func TestKI64PairSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedKI64Pair(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| //These tests are generated by github.com/gogo/protobuf/plugin/testgen | |||
+ 0
- 3
rpc/grpc/compile.sh
View File
| @ -1,3 +0,0 @@ | |||
| #! /bin/bash | |||
| protoc --go_out=plugins=grpc:. -I $GOPATH/src/ -I . types.proto | |||
+ 820
- 45
rpc/grpc/types.pb.go
View File
+ 9
- 0
rpc/grpc/types.proto
View File
+ 531
- 0
rpc/grpc/typespb_test.go
View File
| @ -0,0 +1,531 @@ | |||
| // Code generated by protoc-gen-gogo. DO NOT EDIT. | |||
| // source: rpc/grpc/types.proto | |||
| /* | |||
| Package core_grpc is a generated protocol buffer package. | |||
| It is generated from these files: | |||
| rpc/grpc/types.proto | |||
| It has these top-level messages: | |||
| RequestPing | |||
| RequestBroadcastTx | |||
| ResponsePing | |||
| ResponseBroadcastTx | |||
| */ | |||
| package core_grpc | |||
| import testing "testing" | |||
| import rand "math/rand" | |||
| import time "time" | |||
| import proto "github.com/gogo/protobuf/proto" | |||
| import jsonpb "github.com/gogo/protobuf/jsonpb" | |||
| import golang_proto "github.com/golang/protobuf/proto" | |||
| import fmt "fmt" | |||
| import math "math" | |||
| import _ "github.com/gogo/protobuf/gogoproto" | |||
| import _ "github.com/tendermint/tendermint/abci/types" | |||
| // Reference imports to suppress errors if they are not otherwise used. | |||
| var _ = proto.Marshal | |||
| var _ = golang_proto.Marshal | |||
| var _ = fmt.Errorf | |||
| var _ = math.Inf | |||
| func TestRequestPingProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestPing{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestRequestPingMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestPing{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestBroadcastTx{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestBroadcastTx{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponsePingProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponsePing{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestResponsePingMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponsePing{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxProto(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, false) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponseBroadcastTx{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| littlefuzz := make([]byte, len(dAtA)) | |||
| copy(littlefuzz, dAtA) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| if len(littlefuzz) > 0 { | |||
| fuzzamount := 100 | |||
| for i := 0; i < fuzzamount; i++ { | |||
| littlefuzz[popr.Intn(len(littlefuzz))] = byte(popr.Intn(256)) | |||
| littlefuzz = append(littlefuzz, byte(popr.Intn(256))) | |||
| } | |||
| // shouldn't panic | |||
| _ = proto.Unmarshal(littlefuzz, msg) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxMarshalTo(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, false) | |||
| size := p.Size() | |||
| dAtA := make([]byte, size) | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| _, err := p.MarshalTo(dAtA) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponseBroadcastTx{} | |||
| if err := proto.Unmarshal(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| for i := range dAtA { | |||
| dAtA[i] = byte(popr.Intn(256)) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestPingJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestPing{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &RequestBroadcastTx{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponsePingJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponsePing{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxJSON(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, true) | |||
| marshaler := jsonpb.Marshaler{} | |||
| jsondata, err := marshaler.MarshalToString(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| msg := &ResponseBroadcastTx{} | |||
| err = jsonpb.UnmarshalString(jsondata, msg) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Json Equal %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestPingProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &RequestPing{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestPingProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &RequestPing{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &RequestBroadcastTx{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &RequestBroadcastTx{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponsePingProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &ResponsePing{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponsePingProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &ResponsePing{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxProtoText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, true) | |||
| dAtA := proto.MarshalTextString(p) | |||
| msg := &ResponseBroadcastTx{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxProtoCompactText(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, true) | |||
| dAtA := proto.CompactTextString(p) | |||
| msg := &ResponseBroadcastTx{} | |||
| if err := proto.UnmarshalText(dAtA, msg); err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| if !p.Equal(msg) { | |||
| t.Fatalf("seed = %d, %#v !Proto %#v", seed, msg, p) | |||
| } | |||
| } | |||
| func TestRequestPingSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestPing(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| func TestRequestBroadcastTxSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedRequestBroadcastTx(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| func TestResponsePingSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponsePing(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| func TestResponseBroadcastTxSize(t *testing.T) { | |||
| seed := time.Now().UnixNano() | |||
| popr := rand.New(rand.NewSource(seed)) | |||
| p := NewPopulatedResponseBroadcastTx(popr, true) | |||
| size2 := proto.Size(p) | |||
| dAtA, err := proto.Marshal(p) | |||
| if err != nil { | |||
| t.Fatalf("seed = %d, err = %v", seed, err) | |||
| } | |||
| size := p.Size() | |||
| if len(dAtA) != size { | |||
| t.Errorf("seed = %d, size %v != marshalled size %v", seed, size, len(dAtA)) | |||
| } | |||
| if size2 != size { | |||
| t.Errorf("seed = %d, size %v != before marshal proto.Size %v", seed, size, size2) | |||
| } | |||
| size3 := proto.Size(p) | |||
| if size3 != size { | |||
| t.Errorf("seed = %d, size %v != after marshal proto.Size %v", seed, size, size3) | |||
| } | |||
| } | |||
| //These tests are generated by github.com/gogo/protobuf/plugin/testgen | |||