revert test playground

Author: keisar

raft/src/test/scala/zio/raft/RaftIntegrationSpec.scala

@@ -161,15 +161,18 @@ object RaftIntegrationSpec extends ZIOSpecDefault:
           killSwitch3
         ) <- makeRaft()
 
-        _ <- r1.sendCommand(Increase).fork.repeatN(10)
-        _ <- ZIO.sleep(100.millis) // Give raft the time to queue all writes
+        // TODO (eran): This is not a good test, since sendCommmand is blocking we don't have pending writes, need to rethink this...
+        _ <- r1.sendCommand(Increase)
+        _ <- r1.sendCommand(Increase)  
+        _ <- r1.sendCommand(Increase)
+        
         readResult1 <- r1.readState
 
         _ <- r1.sendCommand(Increase)
 
         readResult2 <- r1.readState
-      yield assertTrue(readResult1 == 11 && readResult2 == 12)
-    } @@ TestAspect.nonFlaky,
+      yield assertTrue(readResult1 == 3 && readResult2 == 4)
+    },
     test("read returns the correct state when there are no pending writes.") {
       for
         (
@@ -187,7 +190,7 @@ object RaftIntegrationSpec extends ZIOSpecDefault:
         readResult <- r1.readState
 
       yield assertTrue(readResult == 1)
-    } @@ TestAspect.nonFlaky,    
+    },
     test("read returns the correct state when there are no writes and one follower is down.") {
       for
         (
@@ -223,37 +226,37 @@ object RaftIntegrationSpec extends ZIOSpecDefault:
       yield assertTrue(
         readResult.isLeft && readResult.left.exists(_.isInstanceOf[NotALeaderError])
       )
-    }
-    // test("isolated leader cannot apply commands") {
-    //   for
-    //     (
-    //       r1,
-    //       killSwitch1,
-    //       r2,
-    //       killSwitch2,
-    //       r3,
-    //       killSwitch3
-    //     ) <- makeRaft()
+    },
+    test("isolated leader cannot apply commands") {
+      for
+        (
+          r1,
+          killSwitch1,
+          r2,
+          killSwitch2,
+          r3,
+          killSwitch3
+        ) <- makeRaft()
 
-    //     // Verify r1 is the leader initially
-    //     _ <- r1.sendCommand(Increase)
-    //     initialState <- r1.readState
+        // Verify r1 is the leader initially
+        _ <- r1.sendCommand(Increase)
+        initialState <- r1.readState
 
-    //     // Isolate the leader (r1) from the rest of the cluster
-    //     _ <- killSwitch1.set(false)
+        // Isolate the leader (r1) from the rest of the cluster
+        _ <- killSwitch1.set(false)
 
-    //     // Try to send a command to the isolated leader
-    //     // This can either timeout (if leader hasn't detected isolation yet) 
-    //     // or fail with NotALeaderError (if leader has stepped down)
-    //     commandResult <- r1.sendCommand(Increase).timeout(2.seconds).either
+        // Try to send a command to the isolated leader
+        // This can either timeout (if leader hasn't detected isolation yet) 
+        // or fail with NotALeaderError (if leader has stepped down)
+        commandResult <- r1.sendCommand(Increase).timeout(2.seconds).either
 
-    //   yield assertTrue(
-    //     initialState == 1 && // Verify initial command worked
-    //     (commandResult match {
-    //       case Right(None) => true // Command timed out - leader couldn't commit
-    //       case Left(_: NotALeaderError) => true // Leader stepped down due to isolation
-    //       case _ => false // Any other result is unexpected
-    //     })
-    //   )
-    // } @@ TestAspect.timeout(5.seconds)
+      yield assertTrue(
+        initialState == 1 && // Verify initial command worked
+        (commandResult match {
+          case Right(None) => true // Command timed out - leader couldn't commit
+          case Left(_: NotALeaderError) => true // Leader stepped down due to isolation
+          case _ => false // Any other result is unexpected
+        })
+      )
+    } @@ TestAspect.timeout(5.seconds)
   ) @@ withLiveClock