RS-319: add downsampling options to Create/Update Replication form

CHANGELOG.md

@@ -7,7 +7,11 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
-### Changed:a
+### Added:
+
+- RS-319: add downsampling options to Create/Update Replication form, [PR-69](https://github.com/reductstore/web-console/pull/69)
+
+### Changed:
 
 - Update `antd` up to 5.18.3, [PR-68](https://github.com/reductstore/web-console/pull/68)
 

package.json

@@ -31,7 +31,7 @@
     "react-dom": "^17.0.2",
     "react-router-dom": "^5.3.4",
     "react-scripts": "5.0.1",
-    "reduct-js": "^1.9.2",
+    "reduct-js": "^1.10.1",
     "stream-browserify": "^3.0.0",
     "ts-jest": "^27.1.5",
     "typescript": "^4.9.5",

src/Components/Replication/CreatOrUpdate.test.tsx

@@ -30,6 +30,8 @@ describe("Replication::CreateOrUpdate", () => {
       entries: ["entry1", "entry2"],
       include: { label1: "value1" },
       exclude: { label2: "value2" },
+      each_n: 10n,
+      each_s: 0.5,
     });
 
     const mockDiagnostics = Diagnostics.parse({
@@ -92,6 +94,8 @@ describe("Replication::CreateOrUpdate", () => {
     expect(wrapper.find({ name: "dstToken" }).exists()).toBeTruthy();
     expect(wrapper.find({ name: "entries" }).exists()).toBeTruthy();
     expect(wrapper.find({ name: "recordSettings" }).exists()).toBeTruthy();
+    expect(wrapper.find({ name: "eachN" }).exists()).toBeTruthy();
+    expect(wrapper.find({ name: "eachS" }).exists()).toBeTruthy();
   });
 
   it("shows the replication name if it is provided", () => {
@@ -132,6 +136,20 @@ describe("Replication::CreateOrUpdate", () => {
     expect(selectedOptionText.at(1).text()).toEqual("entry2");
   });
 
+  it("shows the number of records to replicate every Nth record if it is provided", async () => {
+    await waitUntilFind(wrapper, { name: "eachN" });
+    expect(wrapper.find({ name: "eachN" }).find("input").prop("value")).toEqual(
+      "10",
+    );
+  });
+
+  it("shows timeinterval to replicate a record if it is provided", async () => {
+    await waitUntilFind(wrapper, { name: "eachS" });
+    expect(wrapper.find({ name: "eachS" }).find("input").prop("value")).toEqual(
+      "0.5",
+    );
+  });
+
   it("disables record settings inputs and radios in read-only mode", () => {
     wrapper = mount(
       <MemoryRouter>

src/Components/Replication/CreateOrUpdate.css

@@ -0,0 +1,3 @@
+.ReplicationField {
+  margin-bottom: 5px;
+}