jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-03-03 16:10:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

unit-test: increase coverage, path: pkg/ingress/kube/util (#99)

Browse Source 
Signed-off-by: iutx <root@viper.run>
This commit is contained in:
Asher Liu
2022-12-06 10:11:40 +08:00
committed by GitHub
parent 0bbff5b0a2
commit 4776d62515
1 changed files with 172 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

192
pkg/ingress/kube/util/util_test.go
View File

@@ -20,10 +20,24 @@ import (
corev3 "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
wasm "github.com/envoyproxy/go-control-plane/envoy/extensions/filters/http/wasm/v3"
v3 "github.com/envoyproxy/go-control-plane/envoy/extensions/wasm/v3"
any "google.golang.org/protobuf/types/known/anypb"
"github.com/gogo/protobuf/types"
"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/assert"
"google.golang.org/protobuf/types/known/anypb"
wrappers "google.golang.org/protobuf/types/known/wrapperspb"
"istio.io/istio/pilot/pkg/model"
)
func TestString(t *testing.T) {
assert.Equal(t, "cluster/foo/bar", ClusterNamespacedName{
NamespacedName: model.NamespacedName{
Name: "bar",
Namespace: "foo",
},
ClusterId: "cluster",
}.String())
}
func TestSplitNamespacedName(t *testing.T) {
testCases := []struct {
input string
@@ -77,32 +91,170 @@ func TestCreateDestinationRuleName(t *testing.T) {
}
func TestMessageToGoGoStruct(t *testing.T) {
bytes := []byte("test")
wasm := &wasm.Wasm{
Config: &v3.PluginConfig{
Name: "basic-auth",
FailOpen: true,
Vm: &v3.PluginConfig_VmConfig{
VmConfig: &v3.VmConfig{
Runtime: "envoy.wasm.runtime.null",
Code: &corev3.AsyncDataSource{
Specifier: &corev3.AsyncDataSource_Local{
Local: &corev3.DataSource{
Specifier: &corev3.DataSource_InlineString{
InlineString: "envoy.wasm.basic_auth",
testStr := "hello, world"
testCases := []struct {
name string
getMsg func() (proto.Message, error)
expect *types.Struct
wantErr bool
}{
{
name: "message is nil",
getMsg: func() (proto.Message, error) {
return nil, nil
},
wantErr: true,
},
{
name: "marshal error",
getMsg: func() (proto.Message, error) {
return &wasm.Wasm{
Config: &v3.PluginConfig{
Name: "error-config",
Configuration: &anypb.Any{
TypeUrl: "type.googleapis.com/google.protobuf.StringValue",
Value: []byte(testStr),
},
},
}, nil
},
wantErr: true,
},
{
name: "case 1",
getMsg: func() (proto.Message, error) {
bytesVal, err := proto.Marshal(wrappers.String(testStr))
if err != nil {
return nil, err
}
return &wasm.Wasm{
Config: &v3.PluginConfig{
Name: "basic-auth",
FailOpen: true,
Vm: &v3.PluginConfig_VmConfig{
VmConfig: &v3.VmConfig{
Runtime: "envoy.wasm.runtime.null",
Code: &corev3.AsyncDataSource{
Specifier: &corev3.AsyncDataSource_Local{
Local: &corev3.DataSource{
Specifier: &corev3.DataSource_InlineString{
InlineString: "envoy.wasm.basic_auth",
},
},
},
},
},
},
Configuration: &anypb.Any{
TypeUrl: "type.googleapis.com/google.protobuf.StringValue",
Value: bytesVal,
},
},
}, nil
},
expect: &types.Struct{
Fields: map[string]*types.Value{
"config": {
Kind: &types.Value_StructValue{
StructValue: &types.Struct{
Fields: map[string]*types.Value{
"name": {
Kind: &types.Value_StringValue{
StringValue: "basic-auth",
},
},
"fail_open": {
Kind: &types.Value_BoolValue{
BoolValue: true,
},
},
"vm_config": {
Kind: &types.Value_StructValue{
StructValue: &types.Struct{
Fields: map[string]*types.Value{
"runtime": {
Kind: &types.Value_StringValue{
StringValue: "envoy.wasm.runtime.null",
}},
"code": {
Kind: &types.Value_StructValue{
StructValue: &types.Struct{
Fields: map[string]*types.Value{
"local": {
Kind: &types.Value_StructValue{
StructValue: &types.Struct{
Fields: map[string]*types.Value{
"inline_string": {
Kind: &types.Value_StringValue{
StringValue: "envoy.wasm.basic_auth",
},
},
},
},
},
},
},
},
},
},
},
},
},
},
"configuration": {
Kind: &types.Value_StructValue{
StructValue: &types.Struct{
Fields: map[string]*types.Value{
"@type": {
Kind: &types.Value_StringValue{
StringValue: "type.googleapis.com/google.protobuf.StringValue",
},
},
"value": {
Kind: &types.Value_StringValue{
StringValue: testStr,
},
},
},
},
},
},
},
},
},
},
},
},
Configuration: &any.Any{
TypeUrl: "type.googleapis.com/google.protobuf.StringValue",
Value: bytes,
},
},
}
gogoStruct, _ := MessageToGoGoStruct(wasm)
t.Log(gogoStruct)
for _, tt := range testCases {
t.Run(tt.name, func(t *testing.T) {
// get proto.Message
msg, err := tt.getMsg()
if err != nil {
t.Fatalf("getMsg() error = %v", err)
}
got, err := MessageToGoGoStruct(msg)
if (err != nil) != tt.wantErr {
t.Errorf("MessageToGoGoStruct() error = %v, wantErr %v", err, tt.wantErr)
return
}
if !proto.Equal(got, tt.expect) {
t.Errorf("MessageToGoGoStruct() got = %v, want %v", got, tt.expect)
}
})
}
}
func TestCreateServiceFQDN(t *testing.T) {
namespace := "default"
serviceName := "go-httpbin-v1"
expect := "go-httpbin-v1.default.svc.cluster.local"
got := CreateServiceFQDN(namespace, serviceName)
t.Log(got)
assert.Equal(t, got, expect)
}