dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update for gofumpt 

Signed-off-by: Lior Nabat <lior.nabat@gmail.clom>
This commit is contained in:
Lior Nabat 2022-11-11 23:41:09 +02:00 committed by Lior Nabat
parent adb840bb84
commit 1024190fcc
2 changed files with 75 additions and 66 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
bindings/kubemq/kubemq_integration_test.go
View File

@ -33,16 +33,17 @@ func getTestKubeMQHost() string {
}
func getDefaultMetadata(channel string) bindings.Metadata {
return bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": getTestKubeMQHost(),
"channel": channel,
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
return bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": getTestKubeMQHost(),
"channel": channel,
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
},
},
},
}
}
@ -54,47 +55,50 @@ func Test_kubeMQ_Init(t *testing.T) {
}{
{
name: "init with valid options",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": getTestKubeMQHost(),
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": getTestKubeMQHost(),
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
},
},
},
},
wantErr: false,
},
{
name: "init with invalid options",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost-bad:50000",
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost-bad:50000",
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
},
},
},
},
wantErr: true,
},
{
name: "init with invalid parsing options",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "bad",
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "bad",
"channel": "test",
"pollMaxItems": "1",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "2",
},
},
},
},
wantErr: true,
},
}
@ -136,6 +140,7 @@ func Test_kubeMQ_Invoke_Read_Single_Message(t *testing.T) {
require.Equal(t, invokeRequest.Data, data)
}
}
func Test_kubeMQ_Invoke_Read_Single_MessageWithHandlerError(t *testing.T) {
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()

64
bindings/kubemq/kubemq_test.go
View File

@ -18,18 +18,19 @@ func Test_createOptions(t *testing.T) {
}{
{
name: "create valid opts",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost:50000",
"channel": "test",
"authToken": "authToken",
"pollMaxItems": "10",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "10",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost:50000",
"channel": "test",
"authToken": "authToken",
"pollMaxItems": "10",
"autoAcknowledged": "true",
"pollTimeoutSeconds": "10",
},
},
},
},
want: &options{
host: "localhost",
port: 50000,
@ -43,40 +44,43 @@ func Test_createOptions(t *testing.T) {
},
{
name: "create invalid opts with bad host",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": ":50000",
"clientId": "clientId",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": ":50000",
"clientId": "clientId",
},
},
},
},
want: nil,
wantErr: true,
},
{
name: "create invalid opts with bad port",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost:badport",
"clientId": "clientId",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "localhost:badport",
"clientId": "clientId",
},
},
},
},
want: nil,
wantErr: true,
},
{
name: "create invalid opts with empty address",
meta: bindings.Metadata{Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "",
"clientId": "clientId",
meta: bindings.Metadata{
Base: metadata.Base{
Name: "kubemq",
Properties: map[string]string{
"address": "",
"clientId": "clientId",
},
},
},
},
want: nil,
wantErr: true,
},
@ -174,7 +178,6 @@ func Test_createOptions(t *testing.T) {
got, err := createOptions(tt.meta)
if tt.wantErr {
assert.Error(t, err)
} else {
assert.NoError(t, err)
assert.Equal(t, tt.want, got)
@ -251,7 +254,8 @@ func Test_parsePolicyExpirationSeconds(t *testing.T) {
args args
want int
}{
{name: "parse policy expiration seconds - nil",
{
name: "parse policy expiration seconds - nil",
args: args{
md: nil,
},