wip

Author: hmottestad

core/sail/nativerdf/src/test/java/org/eclipse/rdf4j/sail/nativerdf/wal/ValueStoreWalCorruptRecoveryTest.java

@@ -116,10 +116,7 @@ void corruptValueIsRecoveredFromWal() throws Exception {
 				ValueStore.NAMESPACE_CACHE_SIZE, ValueStore.NAMESPACE_ID_CACHE_SIZE,
 				ValueStoreWAL.open(config))) {
 			NativeValue v = store.getValue(id);
-			assertThat(v).isInstanceOf(CorruptValue.class);
-			CorruptValue cv = (CorruptValue) v;
-			assertThat(cv.getRecovered()).isNotNull();
-			assertThat(cv.getRecovered().stringValue()).isEqualTo(label);
+			assertThat(v.stringValue()).isEqualTo(label);
 		}
 	}
 
@@ -291,10 +288,8 @@ void corruptIriIsRecoveredFromWal() throws Exception {
 				ValueStore.VALUE_ID_CACHE_SIZE,
 				ValueStore.NAMESPACE_CACHE_SIZE, ValueStore.NAMESPACE_ID_CACHE_SIZE, ValueStoreWAL.open(config))) {
 			NativeValue v = store.getValue(id);
-			assertThat(v).isInstanceOf(CorruptValue.class);
-			CorruptValue cv = (CorruptValue) v;
-			assertThat(cv.getRecovered()).isNotNull();
-			assertThat(cv.getRecovered().stringValue()).isEqualTo(iri);
+			assertThat(v.toString()).isEqualTo(iri);
+
 		}
 	}
 
@@ -337,10 +332,7 @@ void corruptBNodeIsRecoveredFromWal() throws Exception {
 				ValueStore.VALUE_ID_CACHE_SIZE,
 				ValueStore.NAMESPACE_CACHE_SIZE, ValueStore.NAMESPACE_ID_CACHE_SIZE, ValueStoreWAL.open(config))) {
 			NativeValue v = store.getValue(id);
-			assertThat(v).isInstanceOf(CorruptValue.class);
-			CorruptValue cv = (CorruptValue) v;
-			assertThat(cv.getRecovered()).isNotNull();
-			assertThat(cv.getRecovered().stringValue()).isEqualTo(bnodeId);
+			assertThat(v.stringValue()).isEqualTo(bnodeId);
 		}
 	}
 
@@ -439,10 +431,7 @@ private void runCorruptAndRecoverLiteralTest(Literal lit) throws Exception {
 				ValueStore.NAMESPACE_CACHE_SIZE, ValueStore.NAMESPACE_ID_CACHE_SIZE,
 				ValueStoreWAL.open(config))) {
 			NativeValue v = store.getValue(id);
-			assertThat(v).isInstanceOf(CorruptValue.class);
-			CorruptValue cv = (CorruptValue) v;
-			assertThat(cv.getRecovered()).isNotNull();
-			assertThat(cv.getRecovered().stringValue()).isEqualTo(lit.stringValue());
+			assertThat(v.stringValue()).isEqualTo(lit.stringValue());
 		}
 	}
 }