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

More cert test fixes 

Signed-off-by: ItalyPaleAle <43508+ItalyPaleAle@users.noreply.github.com>
This commit is contained in:
ItalyPaleAle 2023-01-20 23:18:16 +00:00
parent a0251482c2
commit 4aeb055ac0
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -162,7 +162,7 @@ func TestEventhubs(t *testing.T) {
return func(ctx flow.Context) error { return func(ctx flow.Context) error {
// assert for messages // assert for messages
for _, m := range messageWatchers { for _, m := range messageWatchers {
m.Assert(ctx, 10*timeout) m.Assert(ctx, 15*timeout)
} }
return nil return nil
@ -269,6 +269,7 @@ func TestEventhubs(t *testing.T) {
embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*3), embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*3),
componentRuntimeOptions(4), componentRuntimeOptions(4),
)). )).
Step("wait", flow.Sleep(10*time.Second)).
Step(fmt.Sprintf("publish messages to topicToBeCreated: %s", topicToBeCreated), publishMessages(metadata, sidecarName4, topicToBeCreated, consumerGroup4)). Step(fmt.Sprintf("publish messages to topicToBeCreated: %s", topicToBeCreated), publishMessages(metadata, sidecarName4, topicToBeCreated, consumerGroup4)).
Step("verify if app4 has recevied messages published to newly created topic", assertMessages(10*time.Second, consumerGroup4)). Step("verify if app4 has recevied messages published to newly created topic", assertMessages(10*time.Second, consumerGroup4)).
@ -285,6 +286,7 @@ func TestEventhubs(t *testing.T) {
embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*4), embedded.WithProfilePort(runtime.DefaultProfilePort+portOffset*4),
componentRuntimeOptions(5), componentRuntimeOptions(5),
)). )).
Step("wait", flow.Sleep(10*time.Second)).
Step("add expected IOT messages (simulate add message to iot)", publishMessageAsDevice(consumerGroup5)). 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("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(5*time.Second)).

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 az config set extension.use_dynamic_install=yes_without_prompt
# login to azure # login to azure
az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId az login --service-principal -u $AzureCertificationServicePrincipalClientId -p $AzureCertificationServicePrincipalClientSecret --tenant $AzureCertificationTenantId > /dev/null
# Create test device ID if not already present # Create test device ID if not already present
IOT_HUB_TEST_DEVICE_NAME="certification-test-device" IOT_HUB_TEST_DEVICE_NAME="certification-test-device"