add global results in testPhase1FailoverPhase2Phase3_ShouldFireRules

apache · Aug 4, 2023 · 42a8db3 · 42a8db3
1 parent 697143b
commit 42a8db3
Showing 1 changed file with 13 additions and 2 deletions.
diff --git a/...iability-tests/src/test/java/org/drools/reliability/test/ReliabilityFireAndAlarmTest.java b/...iability-tests/src/test/java/org/drools/reliability/test/ReliabilityFireAndAlarmTest.java
@@ -40,26 +40,30 @@ public class ReliabilityFireAndAlarmTest extends ReliabilityTestBasics{
                     "  $sprinkler: Sprinkler( room == $room, on == false ) \n" +
                     "then\n" +
                     "  modify($sprinkler) { setOn(true); } \n" +
-                    "  System.out.println(\"Turn on the sprinkler for room\" + $room.getName()); \n" +
+                    "  System.out.println(\"Turn on the sprinkler for room \" + $room.getName()); \n" +
+                    "  results.add( \"Turn on sprinkler rule\" );\n" +
                     "end\n" +
                     "rule 'Raise the alarm when we have one or more firs' when\n" +
                     "  exists Fire() \n" +
                     "then\n" +
                     "  insert( new Alarm() );\n" +
                     "  System.out.println(\"Raise the alarm\");\n" +
+                    "  results.add( \"Raise alarm rule\" );\n" +
                     "end\n"+
                     "rule 'Cancel the alarm when all the fires have gone' when \n" +
                     "   not Fire() \n" +
                     "   $alarm : Alarm() \n" +
                     "then\n" +
                     "   delete ( $alarm ); \n" +
                     "   System.out.println(\"Cancel the alarm\"); \n" +
+                    "  results.add( \"Cancel alarm rule\" );\n" +
                     "end\n" +
                     "rule 'Status output when things are ok' when\n" +
                     "   not Alarm() \n" +
                     "   not Sprinkler ( on == true ) \n" +
                     "then \n" +
                     "   System.out.println(\"Everything is ok\"); \n" +
+                    "  results.add( \"Everything ok rule\" );\n" +
                     "end";
 
 
@@ -117,18 +121,24 @@ void testPhase1FailoverPhase2Phase3_ShouldFireRules(PersistedSessionOption.Persi
         insert(new Fire(room1));
 
         assertThat(fireAllRules()).isEqualTo(1);
+        assertThat(getResults()).containsExactlyInAnyOrder("Raise alarm rule");
+
         Optional<Object> alarm = getObjectByType(Alarm.class);
         assertThat(alarm.isEmpty()).isFalse();
 
         failover();
         restoreSession(FIRE_AND_ALARM, persistenceStrategy,safepointStrategy,PersistedSessionOption.PersistenceObjectsStrategy.OBJECT_REFERENCES);
+        clearResults();
 
         // phase 2
         Optional<Object> room = getObjectByType(Room.class);
         assertThat(room.isEmpty()).isFalse();
         Sprinkler sprinkler1 = new Sprinkler((Room) room.get());
         insert(sprinkler1);
-        fireAllRules();
+
+        assertThat(fireAllRules()).isEqualTo(1);
+        assertThat(getResults()).containsExactlyInAnyOrder("Turn on sprinkler rule");
+        clearResults();
 
         Optional<Object> sprinkler = getObjectByType(Sprinkler.class);
         assertThat(sprinkler.isEmpty()).isFalse();
@@ -139,5 +149,6 @@ void testPhase1FailoverPhase2Phase3_ShouldFireRules(PersistedSessionOption.Persi
         assertThat(fireFh.isEmpty()).isFalse();
         delete(fireFh.get());
         assertThat(fireAllRules()).isEqualTo(1);
+        assertThat(getResults()).containsExactlyInAnyOrder("Cancel alarm rule");
     }
 }