changed method of generating event in tests

dao/src/test/java/org/thingsboard/server/dao/service/AbstractServiceTest.java

@@ -98,6 +98,10 @@ public abstract class AbstractServiceTest {
 
 
     protected RuleNodeDebugEvent generateEvent(TenantId tenantId, EntityId entityId) throws IOException {
+        return generateEvent(tenantId, entityId, null);
+    }
+
+    protected RuleNodeDebugEvent generateEvent(TenantId tenantId, EntityId entityId, String eventType) throws IOException {
         if (tenantId == null) {
             tenantId = TenantId.fromUUID(Uuids.timeBased());
         }
@@ -105,6 +109,7 @@ public abstract class AbstractServiceTest {
                 .tenantId(tenantId)
                 .entityId(entityId.getId())
                 .serviceId("server A")
+                .eventType(eventType)
                 .data(JacksonUtil.toString(readFromResource("TestJsonData.json")))
                 .build();
     }

dao/src/test/java/org/thingsboard/server/dao/service/event/BaseEventServiceTest.java

@@ -133,12 +133,12 @@ public abstract class BaseEventServiceTest extends AbstractServiceTest {
     }
 
     @Test
-    public void findLatestDebugRuleNodeInEvent() {
+    public void findLatestDebugRuleNodeInEvent() throws Exception {
         CustomerId customerId = new CustomerId(Uuids.timeBased());
         TenantId tenantId = TenantId.fromUUID(Uuids.timeBased());
 
-        Event event1 = saveDebugEvent(customerId, tenantId);
-        Event event2 = saveDebugEvent(customerId, tenantId);
+        Event event1 = saveEventWithProvidedTimeAndEventType(eventTime, "IN", customerId, tenantId);
+        Event event2 = saveEventWithProvidedTimeAndEventType(eventTime + 1, "IN", customerId, tenantId);
 
         EventInfo event = eventService.findLatestDebugRuleNodeInEvent(tenantId, customerId);
 
@@ -149,21 +149,14 @@ public abstract class BaseEventServiceTest extends AbstractServiceTest {
     }
 
     private Event saveEventWithProvidedTime(long time, EntityId entityId, TenantId tenantId) throws Exception {
-        RuleNodeDebugEvent event = generateEvent(tenantId, entityId);
+        return saveEventWithProvidedTimeAndEventType(time, null, entityId, tenantId);
+    }
+
+    private Event saveEventWithProvidedTimeAndEventType(long time, String eventType, EntityId entityId, TenantId tenantId) throws Exception {
+        RuleNodeDebugEvent event = generateEvent(tenantId, entityId, eventType);
         event.setId(new EventId(Uuids.timeBased()));
         event.setCreatedTime(time);
         eventService.saveAsync(event).get();
         return event;
     }
-
-    private Event saveDebugEvent(EntityId entityId, TenantId tenantId) {
-        Event event = RuleNodeDebugEvent.builder()
-                .tenantId(tenantId)
-                .entityId(entityId.getId())
-                .serviceId("server A")
-                .eventType("IN")
-                .build();
-        eventService.saveAsync(event);
-        return event;
-    }
 }

dao/src/test/java/org/thingsboard/server/dao/sql/event/JpaBaseEventDaoTest.java

@@ -112,14 +112,15 @@ public class JpaBaseEventDaoTest extends AbstractJpaDaoTest {
     }
 
     @Test
-    public void findLatestDebugRuleNodeInEvent() {
+    public void findLatestDebugRuleNodeInEvent() throws Exception {
 
         UUID entityId = Uuids.timeBased();
 
-        RuleNodeDebugEventEntity event = getDebugEventEntity(Uuids.timeBased(), tenantId, entityId);
-        eventDao.saveAsync(event.toData());
-        RuleNodeDebugEventEntity event2 = getDebugEventEntity(Uuids.timeBased(), tenantId, entityId);
-        eventDao.saveAsync(event2.toData());
+        RuleNodeDebugEventEntity event = getDebugInEventEntity(Uuids.timeBased(), tenantId, entityId);
+        eventDao.saveAsync(event.toData()).get(1, TimeUnit.MINUTES);
+        Thread.sleep(2);
+        RuleNodeDebugEventEntity event2 = getDebugInEventEntity(Uuids.timeBased(), tenantId, entityId);
+        eventDao.saveAsync(event2.toData()).get(1, TimeUnit.MINUTES);
 
         RuleNodeDebugEventEntity foundEvent = ruleNodeDebugEventRepository.findLatestDebugRuleNodeInEvent(tenantId, entityId).get();
         assertNotNull("Events expected to be not null", foundEvent);
@@ -139,7 +140,7 @@ public class JpaBaseEventDaoTest extends AbstractJpaDaoTest {
         return event.build();
     }
 
-    private RuleNodeDebugEventEntity getDebugEventEntity(UUID eventId, UUID tenantId, UUID entityId) {
+    private RuleNodeDebugEventEntity getDebugInEventEntity(UUID eventId, UUID tenantId, UUID entityId) {
         RuleNodeDebugEventEntity event = new RuleNodeDebugEventEntity();
         event.setId(eventId);
         event.setEventType("IN");