Merge pull request #563 from M4xymm/RDBC-1081-2

RDBC-1081 Add TimeSeriesDeletedRanges, MaxReadOpsPerSecond and SkipCorruptedData to smuggler options

Author: M4xymm

src/Documents/Smuggler/DatabaseItemType.ts

@@ -17,4 +17,5 @@ export type DatabaseItemType =
     | "Subscriptions"
     | "CompareExchangeTombstones"
     | "TimeSeries"
-    | "ReplicationHubCertificates";
+    | "ReplicationHubCertificates"
+    | "TimeSeriesDeletedRanges";

src/Documents/Smuggler/DatabaseSmugglerOptions.ts

@@ -5,7 +5,7 @@ import { DatabaseRecordItemType } from "./DatabaseRecordItemType.js";
 export class DatabaseSmugglerOptions implements IDatabaseSmugglerOptions {
     public static readonly DEFAULT_OPERATE_ON_TYPES: DatabaseItemType[] = [
         "Indexes", "Documents", "RevisionDocuments", "Conflicts", "DatabaseRecord", "ReplicationHubCertificates", "Identities",
-        "CompareExchange", "Attachments", "CounterGroups", "Subscriptions", "TimeSeries"
+        "CompareExchange", "Attachments", "CounterGroups", "Subscriptions", "TimeSeries", "TimeSeriesDeletedRanges"
     ];
 
     public static readonly DEFAULT_OPERATE_ON_DATABASE_RECORD_TYPES: DatabaseRecordItemType[] = [
@@ -31,6 +31,7 @@ export class DatabaseSmugglerOptions implements IDatabaseSmugglerOptions {
 
     public encryptionKey: string;
     public collections: string[];
+    public maxReadOpsPerSecond?: number;
     /**
      * In case the database is corrupted (for example, Compression Dictionaries are lost), it is possible to export all the remaining data.
      */

src/Documents/Smuggler/IDatabaseSmugglerOptions.ts

@@ -12,4 +12,6 @@ export interface IDatabaseSmugglerOptions {
     skipRevisionCreation: boolean;
     collections: string[];
     operateOnDatabaseRecordType: DatabaseRecordItemType[];
+    maxReadOpsPerSecond?: number;
+    skipCorruptedData?: boolean;
 }

test/Ported/SmugglerTest.ts

@@ -79,6 +79,45 @@ describe("SmugglerTest", function () {
         }
     });
 
+    it("can export and import with maxReadOpsPerSecond, skipCorruptedData and timeSeriesDeletedRanges", async () => {
+        const exportFile = path.join(temporaryDirContext.tempDir, "exported-db-3." + CONSTANTS.Documents.PeriodicBackup.FULL_BACKUP_EXTENSION);
+
+        const sourceStore = await testContext.getDocumentStore();
+
+        try {
+            await addUsers(sourceStore);
+
+            const options = new DatabaseSmugglerExportOptions();
+            options.maxReadOpsPerSecond = 1000;
+            options.skipCorruptedData = true;
+
+            assertThat(options.operateOnTypes)
+                .contains("TimeSeriesDeletedRanges");
+
+            const operation = await sourceStore.smuggler.export(options, exportFile);
+            await operation.waitForCompletion();
+        } finally {
+            sourceStore.dispose();
+        }
+
+        const dstStore = await testContext.getDocumentStore();
+
+        try {
+            const options = new DatabaseSmugglerImportOptions();
+            options.maxReadOpsPerSecond = 1000;
+            options.skipCorruptedData = true;
+
+            const operation = await dstStore.smuggler.import(options, exportFile);
+            await operation.waitForCompletion();
+
+            const stats = await dstStore.maintenance.send(new GetStatisticsOperation());
+            assertThat(stats.countOfDocuments)
+                .isEqualTo(3);
+        } finally {
+            dstStore.dispose();
+        }
+    });
+
     it("can sort files", () => {
         const files = [
             "2018-11-08-10-47.ravendb-incremental-backup",