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

Tweaks to tests 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2023-01-21 00:12:07 +00:00
parent d1fed3807c
commit d8e1afb8ae
2 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
tests/certification/pubsub/azure/eventhubs/eventhubs_test.go
View File

@ -171,7 +171,7 @@ func TestEventhubs(t *testing.T) {
deleteEventhub := func(ctx flow.Context) error {
output, err := exec.Command("/bin/sh", "delete-eventhub.sh", topicToBeCreated).Output()
assert.Nil(t, err, "Error in delete-eventhub.sh.:\n%s", string(output))
assert.NoErrorf(t, err, "Error in delete-eventhub.sh.:\n%s", string(output))
return nil
}
@ -192,10 +192,15 @@ func TestEventhubs(t *testing.T) {
iotHubName := os.Getenv(iotHubNameEnvKey)
// Here so we can comment out tests as needed
_ = publishMessageAsDevice
_ = iotHubName
_ = consumerGroup1
_ = consumerGroup2
_ = consumerGroup4
_ = consumerGroup5
_ = publishMessageAsDevice
_ = iotHubName
_ = metadata
_ = metadata1
_ = publishMessages
flow.New(t, "eventhubs certification").
@ -286,12 +291,12 @@ func TestEventhubs(t *testing.T) {
embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*4),
componentRuntimeOptions(5),
)).
Step("wait", flow.Sleep(10*time.Second)).
Step("add expected IOT messages (simulate add message to iot)", publishMessageAsDevice(consumerGroup5)).
Step("verify if app5 has recevied messages published to iot topic", assertMessages(40*time.Second, consumerGroup5)).
Step("wait", flow.Sleep(5*time.Second)).
Step("wait", flow.Sleep(20*time.Second)).
Step("add expected IoT messages (simulate add message to IoT Hub)", publishMessageAsDevice(consumerGroup5)).
Step("verify if app5 has recevied messages published to IoT topic", assertMessages(10*time.Second, consumerGroup5)).
// cleanup azure assets created as part of tests
Step("wait", flow.Sleep(5*time.Second)).
Step("delete eventhub created as part of the eventhub management test", deleteEventhub).
Run()
}

2
tests/certification/pubsub/azure/eventhubs/send-iot-device-events.sh
View File

@ -30,7 +30,7 @@ fi
az config set extension.use_dynamic_install=yes_without_prompt
# login to azure
az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId > /dev/null
az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId
# Create test device ID if not already present
IOT_HUB_TEST_DEVICE_NAME="certification-test-device"