This repository has been archived by the owner on Dec 14, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 98
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add tests for ConnOptions and LinkOptions
Resolves #37
- Loading branch information
Showing
5 changed files
with
198 additions
and
86 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,47 @@ | ||
| package amqp | ||
|
|
||
| import ( | ||
| "encoding/binary" | ||
| "testing" | ||
| ) | ||
|
|
||
| func TestLinkOptions(t *testing.T) { | ||
| tests := []struct { | ||
| label string | ||
| opts []LinkOption | ||
|
|
||
| wantSource *source | ||
| }{ | ||
| { | ||
| label: "no options", | ||
| }, | ||
| { | ||
| label: "selector-filter", | ||
| opts: []LinkOption{ | ||
| LinkSelectorFilter("amqp.annotation.x-opt-offset > '100'"), | ||
| }, | ||
|
|
||
| wantSource: &source{ | ||
| Filter: map[symbol]*describedType{ | ||
| "apache.org:selector-filter:string": &describedType{ | ||
| descriptor: binary.BigEndian.Uint64([]byte{0x00, 0x00, 0x46, 0x8C, 0x00, 0x00, 0x00, 0x04}), | ||
| value: "amqp.annotation.x-opt-offset > '100'", | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| } | ||
|
|
||
| for _, tt := range tests { | ||
| t.Run(tt.label, func(t *testing.T) { | ||
| got, err := newLink(nil, nil, tt.opts) | ||
| if err != nil { | ||
| t.Fatal(err) | ||
| } | ||
|
|
||
| if !testEqual(got.source, tt.wantSource) { | ||
| t.Errorf("Properties don't match expected:\n %s", testDiff(got.source, tt.wantSource)) | ||
| } | ||
| }) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,44 @@ | ||
| package amqp | ||
|
|
||
| import ( | ||
| "testing" | ||
| ) | ||
|
|
||
| func TestConnOptions(t *testing.T) { | ||
| tests := []struct { | ||
| label string | ||
| opts []ConnOption | ||
|
|
||
| wantProperties map[symbol]interface{} | ||
| }{ | ||
| { | ||
| label: "no options", | ||
| }, | ||
| { | ||
| label: "multiple properties", | ||
| opts: []ConnOption{ | ||
| ConnProperty("x-opt-test1", "test1"), | ||
| ConnProperty("x-opt-test2", "test2"), | ||
| ConnProperty("x-opt-test1", "test3"), | ||
| }, | ||
|
|
||
| wantProperties: map[symbol]interface{}{ | ||
| "x-opt-test1": "test3", | ||
| "x-opt-test2": "test2", | ||
| }, | ||
| }, | ||
| } | ||
|
|
||
| for _, tt := range tests { | ||
| t.Run(tt.label, func(t *testing.T) { | ||
| got, err := newConn(nil, tt.opts...) | ||
| if err != nil { | ||
| t.Fatal(err) | ||
| } | ||
|
|
||
| if !testEqual(got.properties, tt.wantProperties) { | ||
| t.Errorf("Properties don't match expected:\n %s", testDiff(got.properties, tt.wantProperties)) | ||
| } | ||
| }) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,65 @@ | ||
| package amqp | ||
|
|
||
| import ( | ||
| "reflect" | ||
|
|
||
| "github.com/google/go-cmp/cmp" | ||
| "github.com/google/go-cmp/cmp/cmpopts" | ||
| ) | ||
|
|
||
| func testEqual(x, y interface{}) bool { | ||
| return cmp.Equal(x, y, compareOpts(x, y)...) | ||
| } | ||
|
|
||
| func testDiff(x, y interface{}) string { | ||
| return cmp.Diff(x, y, compareOpts(x, y)...) | ||
| } | ||
|
|
||
| func compareOpts(x, y interface{}) []cmp.Option { | ||
| return cmp.Options{ | ||
| deepAllowUnexported(x, y), | ||
| cmpopts.EquateNaNs(), | ||
| } | ||
| } | ||
|
|
||
| // from https://github.com/google/go-cmp/issues/40 | ||
| func deepAllowUnexported(vs ...interface{}) cmp.Option { | ||
| m := make(map[reflect.Type]struct{}) | ||
| for _, v := range vs { | ||
| structTypes(reflect.ValueOf(v), m) | ||
| } | ||
| var types []interface{} | ||
| for t := range m { | ||
| types = append(types, reflect.New(t).Elem().Interface()) | ||
| } | ||
| return cmp.AllowUnexported(types...) | ||
| } | ||
|
|
||
| func structTypes(v reflect.Value, m map[reflect.Type]struct{}) { | ||
| if !v.IsValid() { | ||
| return | ||
| } | ||
| switch v.Kind() { | ||
| case reflect.Ptr: | ||
| if !v.IsNil() { | ||
| structTypes(v.Elem(), m) | ||
| } | ||
| case reflect.Interface: | ||
| if !v.IsNil() { | ||
| structTypes(v.Elem(), m) | ||
| } | ||
| case reflect.Slice, reflect.Array: | ||
| for i := 0; i < v.Len(); i++ { | ||
| structTypes(v.Index(i), m) | ||
| } | ||
| case reflect.Map: | ||
| for _, k := range v.MapKeys() { | ||
| structTypes(v.MapIndex(k), m) | ||
| } | ||
| case reflect.Struct: | ||
| m[v.Type()] = struct{}{} | ||
| for i := 0; i < v.NumField(); i++ { | ||
| structTypes(v.Field(i), m) | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters