Skip to content

Commit

Permalink
Merge pull request #1009 from kaleido-io/multitenancy
Browse files Browse the repository at this point in the history
Ensure new namespaces are up during multi_tenancy test
  • Loading branch information
shorsher authored Aug 26, 2022
2 parents f8f8f79 + be0b9ed commit ddc0e37
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions test/e2e/multiparty/multi_tenancy.go
Original file line number Diff line number Diff line change
Expand Up @@ -108,16 +108,17 @@ func (suite *NamespaceAliasSuite) TestMultiTenancy() {
admin1.SetBaseURL(suite.testState.adminHost1 + "/spi/v1")
admin2.SetBaseURL(suite.testState.adminHost2 + "/spi/v1")

// Reset both nodes to pick up the new namespace
e2e.ResetFireFly(suite.T(), admin1)
e2e.ResetFireFly(suite.T(), admin2)
e2e.PollForUp(suite.T(), suite.testState.client1)
e2e.PollForUp(suite.T(), suite.testState.client2)

clientAlice := client.NewFireFly(suite.T(), suite.testState.client1.Hostname, nsAlice)
clientBob := client.NewFireFly(suite.T(), suite.testState.client1.Hostname, nsBob)
clientCharlie := client.NewFireFly(suite.T(), suite.testState.client2.Hostname, nsCharlie)

// Reset both nodes to pick up the new namespace
e2e.ResetFireFly(suite.T(), admin1)
e2e.ResetFireFly(suite.T(), admin2)
e2e.PollForUp(suite.T(), clientAlice)
e2e.PollForUp(suite.T(), clientBob)
e2e.PollForUp(suite.T(), clientCharlie)

eventNames := "message_confirmed"
queryString := fmt.Sprintf("namespace=%s&ephemeral&autoack&filter.events=%s", nsAlice, eventNames)
receivedAlice := e2e.WsReader(clientAlice.WebSocket(suite.T(), queryString, nil))
Expand Down

0 comments on commit ddc0e37

Please sign in to comment.