diff options
Diffstat (limited to 'src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer')
2 files changed, 118 insertions, 0 deletions
diff --git a/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBackupInfoSerializerTest.java b/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBackupInfoSerializerTest.java new file mode 100644 index 0000000..e7f56b0 --- /dev/null +++ b/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBackupInfoSerializerTest.java @@ -0,0 +1,73 @@ +package com.keuin.kbackupfabric.backup.incremental.serializer; + +import com.keuin.kbackupfabric.backup.incremental.ObjectCollection2; +import com.keuin.kbackupfabric.backup.incremental.ObjectCollectionFactory; +import com.keuin.kbackupfabric.backup.incremental.identifier.Sha256Identifier; +import org.junit.Test; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Files; +import java.time.ZonedDateTime; + +import static org.junit.Assert.assertEquals; + +public class IncBackupInfoSerializerTest { + + @Test + public void testSerializationConsistency1() throws IOException { + testSerializationConsistency(1, 0); + } + + @Test + public void testSerializationConsistency2() throws IOException { + testSerializationConsistency(2, 0); + } + + @Test + public void testSerializationConsistency4() throws IOException { + testSerializationConsistency(4, 0); + } + + @Test + public void testSerializationConsistency8() throws IOException { + testSerializationConsistency(8, 0); + } + + @Test + public void testSerializationConsistency1A() throws IOException { + testSerializationConsistency(1, 1000); + } + + @Test + public void testSerializationConsistency2A() throws IOException { + testSerializationConsistency(2, 1000); + } + + @Test + public void testSerializationConsistency4A() throws IOException { + testSerializationConsistency(4, 1000); + } + + @Test + public void testSerializationConsistency8A() throws IOException { + testSerializationConsistency(8, 1000); + } + + public void testSerializationConsistency(int threads, int multiThreadThreshold) throws IOException { + ObjectCollectionFactory<Sha256Identifier> factory = + new ObjectCollectionFactory<>(Sha256Identifier.getFactory(), threads, multiThreadThreshold); + ObjectCollection2 collection = + factory.fromDirectory(new File("./testfile/ObjectCollectionFactoryTest")); + File file = new File("./testfile/serialized"); + if (file.exists()) { + Files.delete(file.toPath()); + } + SavedIncrementalBackup backup = SavedIncrementalBackup.newLatest(collection, ":name:", ZonedDateTime.now(), 10000, 2000, 10, 20); + IncBackupInfoSerializer.toFile(file, backup); + SavedIncrementalBackup info = IncBackupInfoSerializer.fromFile(file); + Files.delete(file.toPath()); + assertEquals(backup, info); + } + +}
\ No newline at end of file diff --git a/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBakupBackwardCompatibilityTest.java b/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBakupBackwardCompatibilityTest.java new file mode 100644 index 0000000..d50b264 --- /dev/null +++ b/src/test/java/com/keuin/kbackupfabric/backup/incremental/serializer/IncBakupBackwardCompatibilityTest.java @@ -0,0 +1,45 @@ +package com.keuin.kbackupfabric.backup.incremental.serializer; + +import com.keuin.kbackupfabric.backup.incremental.ObjectCollection2; +import com.keuin.kbackupfabric.backup.incremental.ObjectCollectionFactory; +import com.keuin.kbackupfabric.backup.incremental.ObjectCollectionSerializer; +import com.keuin.kbackupfabric.backup.incremental.identifier.Sha256Identifier; +import com.keuin.kbackupfabric.backup.name.IncrementalBackupFileNameEncoder; +import org.junit.Test; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Path; +import java.nio.file.Paths; +import java.time.LocalDateTime; +import java.time.ZoneOffset; + +import static org.junit.Assert.*; + +public class IncBakupBackwardCompatibilityTest { + + private final String customName = "test_backup"; + private final LocalDateTime backupTime = LocalDateTime.of(2000, 1, 1, 1, 1, 1, 1); + + private final Path testRoot = Paths.get(".\\testfile\\IncBackupBackwardCompatibilityTest"); + private final File indexFile = new File(testRoot.toString(), new IncrementalBackupFileNameEncoder().encode(customName, backupTime)); + + @Test + public void testBackwardCompatibility() throws IOException { + + if (!testRoot.toFile().isDirectory()) { + if (!testRoot.toFile().mkdirs()) + fail("Cannot initialize test environment: cannot create path."); + } + + // now we make an old-style backup index file + ObjectCollectionFactory<Sha256Identifier> factory = + new ObjectCollectionFactory<>(Sha256Identifier.getFactory(), 1, 0); + ObjectCollection2 collection = factory.fromDirectory(testRoot.toFile()); + ObjectCollectionSerializer.toFile(collection, indexFile); + SavedIncrementalBackup info = IncBackupInfoSerializer.fromFile(indexFile); + assertEquals(collection, info.getObjectCollection()); + assertEquals(customName, info.getBackupName()); + assertTrue(backupTime.toEpochSecond(ZoneOffset.UTC) - info.getBackupTime().toLocalDateTime().toEpochSecond(ZoneOffset.UTC) <= 2); + } +} |