Higher and Lower should re-read level if fetching value fails.

Author: simerplaha

core/src/main/scala/swaydb/core/level/seek/Higher.scala

@@ -330,7 +330,7 @@ private[core] object Higher {
                       }
 
                     case failure @ IO.Left(_) =>
-                      failure recoverTo Higher.seeker(key, currentSeek, nextSeek)
+                      failure recoverTo Higher.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                   }
 
                 //10  -  20
@@ -362,7 +362,7 @@ private[core] object Higher {
                       }
 
                     case failure @ IO.Left(_) =>
-                      failure recoverTo Higher.seeker(key, currentSeek, nextSeek)
+                      failure recoverTo Higher.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                   }
 
                 //10 - 20
@@ -392,7 +392,7 @@ private[core] object Higher {
                       }
 
                     case failure @ IO.Left(_) =>
-                      failure recoverTo Higher.seeker(key, currentSeek, nextSeek)
+                      failure recoverTo Higher.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                   }
             }
         }

core/src/main/scala/swaydb/core/level/seek/Lower.scala

@@ -153,11 +153,11 @@ private[core] object Lower {
                           }
 
                         case failure @ IO.Left(_) =>
-                          failure recoverTo Lower.seeker(key, currentSeek, nextSeek)
+                          failure recoverTo Lower.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                       }
 
                   case failure @ IO.Left(_) =>
-                    failure recoverTo Lower.seeker(key, currentSeek, nextSeek)
+                    failure recoverTo Lower.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                 }
 
               //     20 (input key - inclusive)
@@ -313,7 +313,7 @@ private[core] object Lower {
                       }
 
                     case failure @ IO.Left(_) =>
-                      failure recoverTo Lower.seeker(key, currentSeek, nextSeek)
+                      failure recoverTo Lower.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                   }
 
                 //       11 ->   20 (input keys)
@@ -332,7 +332,7 @@ private[core] object Lower {
                       }
 
                     case failure @ IO.Left(_) =>
-                      failure recoverTo Lower.seeker(key, currentSeek, nextSeek)
+                      failure recoverTo Lower.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                   }
             }
 
@@ -368,7 +368,7 @@ private[core] object Lower {
                     }
 
                   case failure @ IO.Left(_) =>
-                    failure recoverTo Lower.seeker(key, currentSeek, nextSeek)
+                    failure recoverTo Lower.seeker(key, Seek.Current.Read(segmentId), nextSeek)
                 }
             }
         }

data/src/main/scala/swaydb/IO.scala

@@ -393,9 +393,9 @@ object IO {
     override def recoverWith[F >: L : IO.ExceptionHandler, B >: R](f: PartialFunction[L, IO[F, B]]): IO[F, B] =
       IO.Catch(if (f isDefinedAt value) f(value) else this)
 
-    def recoverTo[F: IO.ExceptionHandler, B](onRecover: => IO.Defer[F, B]): IO.Defer[F, B] =
+    def recoverTo[F >: L : IO.ExceptionHandler, B](io: => IO.Defer[F, B]): IO.Defer[F, B] =
       if (this.isRecoverable)
-        onRecover
+        IO.Defer[F, B](io.toIO.get, this.value)
       else
         IO.Defer[F, B](throw IO.ExceptionHandler.toException(this.value))
 

data/src/test/scala/swaydb/data/IOIOLeftSpec.scala

@@ -114,7 +114,7 @@ class IOIOLeftSpec extends WordSpec with Matchers {
   }
 
   "toEither" in {
-    IO.Left(error).toEither shouldBe IO.Left(error)
+    IO.Left(error).toEither shouldBe scala.util.Left(error)
   }
 
   "filter" in {

data/src/test/scala/swaydb/data/IOIORightSpec.scala

@@ -151,7 +151,7 @@ class IOIORightSpec extends WordSpec with Matchers {
   }
 
   "toEither" in {
-    IO.Right(2).toEither shouldBe IO.Right(2)
+    IO.Right(2).toEither shouldBe scala.util.Right(2)
   }
 
   "filter" in {