From 247b1aaf8f2a61de110a24d0ab3bdee0284d8cfc Mon Sep 17 00:00:00 2001
From: boqiu <82121246@qq.com>
Date: Fri, 25 Oct 2024 11:09:30 +0800
Subject: [PATCH] Add py test for auto sync v2

---
 tests/sync_auto_random_v2_test.py | 36 +++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 tests/sync_auto_random_v2_test.py

diff --git a/tests/sync_auto_random_v2_test.py b/tests/sync_auto_random_v2_test.py
new file mode 100644
index 0000000..6411177
--- /dev/null
+++ b/tests/sync_auto_random_v2_test.py
@@ -0,0 +1,36 @@
+#!/usr/bin/env python3
+
+from test_framework.test_framework import TestFramework
+from utility.utils import wait_until
+
+class AutoRandomSyncV2Test(TestFramework):
+    def setup_params(self):
+        self.num_nodes = 4
+
+        # Enable random auto sync v2
+        for i in range(self.num_nodes):
+            self.zgs_node_configs[i] = {
+                "sync": {
+                    "auto_sync_enabled": True,
+                    "max_sequential_workers": 0,
+                    "max_random_workers": 3,
+                    "neighbors_only": True,
+                }
+            }
+
+    def run_test(self):
+        # Submit and upload files on node 0
+        data_root_1 = self.__upload_file__(0, 256 * 1024)
+        data_root_2 = self.__upload_file__(0, 256 * 1024)
+
+        # Files should be available on other nodes via auto sync
+        for i in range(1, self.num_nodes):
+            wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_1) is not None)
+            wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_1)["finalized"])
+            wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_2) is not None)
+            wait_until(lambda: self.nodes[i].zgs_get_file_info(data_root_2)["finalized"])
+
+        assert 1 > 2
+
+if __name__ == "__main__":
+    AutoRandomSyncV2Test().main()