dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed flaky test

Browse Source
This commit is contained in:
dashevchenko 2025-02-14 19:01:58 +02:00
parent e03d4ccc4c
commit 1f3c7acc51
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
application/src/test/java/org/thingsboard/server/controller/WebsocketApiTest.java
View File

@ -340,29 +340,26 @@ public class WebsocketApiTest extends AbstractControllerTest {
Assert.assertEquals(0, update.getCount()); Assert.assertEquals(0, update.getCount());
//create alarm, check count = 1 //create alarm, check count = 1
getWsClient().registerWaitForUpdate();
Alarm alarm = new Alarm(); Alarm alarm = new Alarm();
alarm.setOriginator(tenantId); alarm.setOriginator(tenantId);
alarm.setType("TEST ALARM"); alarm.setType("TEST ALARM");
alarm.setSeverity(AlarmSeverity.WARNING); alarm.setSeverity(AlarmSeverity.WARNING);
alarm = doPost("/api/alarm", alarm, Alarm.class); alarm = doPost("/api/alarm", alarm, Alarm.class);
AlarmCountCmd cmd2 = new AlarmCountCmd(2, alarmCountQuery); update = getWsClient().parseAlarmCountReply(getWsClient().waitForUpdate());
Assert.assertEquals(1, update.getCmdId());
getWsClient().send(cmd2);
update = getWsClient().parseAlarmCountReply(getWsClient().waitForReply());
Assert.assertEquals(2, update.getCmdId());
Assert.assertEquals(1, update.getCount()); Assert.assertEquals(1, update.getCount());
// set wrong entity id in filter, check count = 0 // set wrong entity id in filter, check count = 0
singleEntityFilter.setSingleEntity(tenantAdminUserId); singleEntityFilter.setSingleEntity(tenantAdminUserId);
AlarmCountCmd cmd3 = new AlarmCountCmd(3, alarmCountQuery); AlarmCountCmd cmd3 = new AlarmCountCmd(2, alarmCountQuery);
getWsClient().send(cmd3); getWsClient().send(cmd3);
update = getWsClient().parseAlarmCountReply(getWsClient().waitForReply()); update = getWsClient().parseAlarmCountReply(getWsClient().waitForReply());
Assert.assertEquals(3, update.getCmdId()); Assert.assertEquals(2, update.getCmdId());
Assert.assertEquals(0, update.getCount()); Assert.assertEquals(0, update.getCount());
} }