diff --git a/resources/test-0x02d425f2e3bfc7cd72078dc314edf857781eb0c2b8ef8ad60c093059b31f4d5695_6133.tar b/resources/test-0x02155da8ebba094882a6f29cfd47a7c0b7c376bab48e770f117acf9d4ae1f60b96_6134.tar similarity index 58% rename from resources/test-0x02d425f2e3bfc7cd72078dc314edf857781eb0c2b8ef8ad60c093059b31f4d5695_6133.tar rename to resources/test-0x02155da8ebba094882a6f29cfd47a7c0b7c376bab48e770f117acf9d4ae1f60b96_6134.tar index 67c0afce..9e508b84 100644 Binary files a/resources/test-0x02d425f2e3bfc7cd72078dc314edf857781eb0c2b8ef8ad60c093059b31f4d5695_6133.tar and b/resources/test-0x02155da8ebba094882a6f29cfd47a7c0b7c376bab48e770f117acf9d4ae1f60b96_6134.tar differ diff --git a/resources/test-0x032af744fdcabe073e24fddeb5b9127abe6a94e844ce9b9f2763ec21fc2e078f00_6136.tar b/resources/test-0x024517f7e05130c1f975b6139d4bfe181884289c627679cc24ff1ebdc32f7d0223_6138.tar similarity index 58% rename from resources/test-0x032af744fdcabe073e24fddeb5b9127abe6a94e844ce9b9f2763ec21fc2e078f00_6136.tar rename to resources/test-0x024517f7e05130c1f975b6139d4bfe181884289c627679cc24ff1ebdc32f7d0223_6138.tar index ad6e857f..1d5dc00e 100644 Binary files a/resources/test-0x032af744fdcabe073e24fddeb5b9127abe6a94e844ce9b9f2763ec21fc2e078f00_6136.tar and b/resources/test-0x024517f7e05130c1f975b6139d4bfe181884289c627679cc24ff1ebdc32f7d0223_6138.tar differ diff --git a/resources/test-0x038bf0d1e9e0ec492310b84c1ef5e13ac893ca7f11d0b9c0162d087a19235355e0_6135.tar b/resources/test-0x029eac085135cab75bdbec2b73fd77e0ee1adf40de8d3fb26028eba355304c7d70_6132.tar similarity index 58% rename from resources/test-0x038bf0d1e9e0ec492310b84c1ef5e13ac893ca7f11d0b9c0162d087a19235355e0_6135.tar rename to resources/test-0x029eac085135cab75bdbec2b73fd77e0ee1adf40de8d3fb26028eba355304c7d70_6132.tar index 0c9043f2..0259a280 100644 Binary files a/resources/test-0x038bf0d1e9e0ec492310b84c1ef5e13ac893ca7f11d0b9c0162d087a19235355e0_6135.tar and b/resources/test-0x029eac085135cab75bdbec2b73fd77e0ee1adf40de8d3fb26028eba355304c7d70_6132.tar differ diff --git a/resources/test-0x035b7fb2f8928696264bdbef3c863dfb5f86f24e0117ea5393ab32d298b4e619a3_6130.tar b/resources/test-0x02e6960a09022362f02289adcb4a708231a498a9762c8c4555d6407be133fd3dd2_6136.tar similarity index 58% rename from resources/test-0x035b7fb2f8928696264bdbef3c863dfb5f86f24e0117ea5393ab32d298b4e619a3_6130.tar rename to resources/test-0x02e6960a09022362f02289adcb4a708231a498a9762c8c4555d6407be133fd3dd2_6136.tar index c3d14fac..5d637f75 100644 Binary files a/resources/test-0x035b7fb2f8928696264bdbef3c863dfb5f86f24e0117ea5393ab32d298b4e619a3_6130.tar and b/resources/test-0x02e6960a09022362f02289adcb4a708231a498a9762c8c4555d6407be133fd3dd2_6136.tar differ diff --git a/resources/test-0x034940a94a265ba008eda880deeac73bfbb5a128fac9c5ffc35452cc205f856df1_6132.tar b/resources/test-0x036188a343eb244c295cfad6c0165dfd133cee0eff6973d0875c51533d7f7cae0a_6130.tar similarity index 58% rename from resources/test-0x034940a94a265ba008eda880deeac73bfbb5a128fac9c5ffc35452cc205f856df1_6132.tar rename to resources/test-0x036188a343eb244c295cfad6c0165dfd133cee0eff6973d0875c51533d7f7cae0a_6130.tar index 0296688b..c5d2381d 100644 Binary files a/resources/test-0x034940a94a265ba008eda880deeac73bfbb5a128fac9c5ffc35452cc205f856df1_6132.tar and b/resources/test-0x036188a343eb244c295cfad6c0165dfd133cee0eff6973d0875c51533d7f7cae0a_6130.tar differ diff --git a/resources/test-0x0286ac005d0ffaacb5bdfd72df2b6a745c166892ec4cc6b0f9584421c8b1b0756c_6134.tar b/resources/test-0x0382f8920afe1d9d82f98fea6ccc1b4ace2bd40f037ecd19084c51446e9fda2ece_6137.tar similarity index 58% rename from resources/test-0x0286ac005d0ffaacb5bdfd72df2b6a745c166892ec4cc6b0f9584421c8b1b0756c_6134.tar rename to resources/test-0x0382f8920afe1d9d82f98fea6ccc1b4ace2bd40f037ecd19084c51446e9fda2ece_6137.tar index 12782ff0..6ff67ecc 100644 Binary files a/resources/test-0x0286ac005d0ffaacb5bdfd72df2b6a745c166892ec4cc6b0f9584421c8b1b0756c_6134.tar and b/resources/test-0x0382f8920afe1d9d82f98fea6ccc1b4ace2bd40f037ecd19084c51446e9fda2ece_6137.tar differ diff --git a/resources/test-0x02ddaa8aaaddcc0fa106e5f80ec851b669563f4c3be42a3ad362c3ae204e5175bd_6137.tar b/resources/test-0x039c862f564d17d11e022c9a7d0ffb2ca19b95e6c16a2b60b466f8e1c918a89dc7_6135.tar similarity index 58% rename from resources/test-0x02ddaa8aaaddcc0fa106e5f80ec851b669563f4c3be42a3ad362c3ae204e5175bd_6137.tar rename to resources/test-0x039c862f564d17d11e022c9a7d0ffb2ca19b95e6c16a2b60b466f8e1c918a89dc7_6135.tar index 22d3049d..d577ecb2 100644 Binary files a/resources/test-0x02ddaa8aaaddcc0fa106e5f80ec851b669563f4c3be42a3ad362c3ae204e5175bd_6137.tar and b/resources/test-0x039c862f564d17d11e022c9a7d0ffb2ca19b95e6c16a2b60b466f8e1c918a89dc7_6135.tar differ diff --git a/resources/test-0x02d0329ccd08527379a1e4c41721564aafaeb59ca4b6ea38532fac8c628ec4fd6a_6138.tar b/resources/test-0x03a059aeb0e86ac84ebc278bf02e46cfc5fe904523a01f7ed3d514a7419a956fa9_6133.tar similarity index 58% rename from resources/test-0x02d0329ccd08527379a1e4c41721564aafaeb59ca4b6ea38532fac8c628ec4fd6a_6138.tar rename to resources/test-0x03a059aeb0e86ac84ebc278bf02e46cfc5fe904523a01f7ed3d514a7419a956fa9_6133.tar index e790984b..1e1e230c 100644 Binary files a/resources/test-0x02d0329ccd08527379a1e4c41721564aafaeb59ca4b6ea38532fac8c628ec4fd6a_6138.tar and b/resources/test-0x03a059aeb0e86ac84ebc278bf02e46cfc5fe904523a01f7ed3d514a7419a956fa9_6133.tar differ diff --git a/resources/test-0x03aee94ee001c222c94c22b8274d9f9de61f1f697fe9b353c94a7c4bad14bb1755_6131.tar b/resources/test-0x03e65829248b3d74cffd6fad8afee8c158d1633aec2b7722437c1d3edfb2a70d85_6131.tar similarity index 58% rename from resources/test-0x03aee94ee001c222c94c22b8274d9f9de61f1f697fe9b353c94a7c4bad14bb1755_6131.tar rename to resources/test-0x03e65829248b3d74cffd6fad8afee8c158d1633aec2b7722437c1d3edfb2a70d85_6131.tar index d7849688..186cc802 100644 Binary files a/resources/test-0x03aee94ee001c222c94c22b8274d9f9de61f1f697fe9b353c94a7c4bad14bb1755_6131.tar and b/resources/test-0x03e65829248b3d74cffd6fad8afee8c158d1633aec2b7722437c1d3edfb2a70d85_6131.tar differ diff --git a/resources/test-0x0361558ace12880d6a7201725507aa64a8a9a1cc7d30a3c1e9daae69ef11129fc6_6139.tar b/resources/test-0x03efd006de1801305c39e97352c618121a4fa144e30fba069f4c7031be55eaeb71_6139.tar similarity index 58% rename from resources/test-0x0361558ace12880d6a7201725507aa64a8a9a1cc7d30a3c1e9daae69ef11129fc6_6139.tar rename to resources/test-0x03efd006de1801305c39e97352c618121a4fa144e30fba069f4c7031be55eaeb71_6139.tar index 93c03e00..bdb9df73 100644 Binary files a/resources/test-0x0361558ace12880d6a7201725507aa64a8a9a1cc7d30a3c1e9daae69ef11129fc6_6139.tar and b/resources/test-0x03efd006de1801305c39e97352c618121a4fa144e30fba069f4c7031be55eaeb71_6139.tar differ diff --git a/src/node/status_node.py b/src/node/status_node.py index 17a32975..fc1086e4 100644 --- a/src/node/status_node.py +++ b/src/node/status_node.py @@ -163,6 +163,12 @@ class StatusNode: params = [{"membership": 3, "name": name, "color": "#ffffff", "description": name}] return self.api.send_rpc_request("wakuext_createCommunity", params) + def set_community_shard(self, community_id, index=128, private_key=None): + params = [{"communityId": community_id, "shard": {"cluster": 16, "index": index}}] + if private_key is not None: + params[0]["shard"]["privateKey"] = private_key + return self.api.send_rpc_request("wakuext_setCommunityShard", params) + @retry(stop=stop_after_delay(30), wait=wait_fixed(0.1), reraise=True) # wakuext_fetchCommunity times out sometimes so that's why we need this retry mechanism def fetch_community(self, community_key): diff --git a/src/scripts/create_nodes_with_communities.py b/src/scripts/create_nodes_with_communities.py index 7de6a78d..e874964f 100644 --- a/src/scripts/create_nodes_with_communities.py +++ b/src/scripts/create_nodes_with_communities.py @@ -4,22 +4,37 @@ from time import sleep from src.node.status_node import StatusNode num_communities = 10 +sharded_community_pk = "0x4c0883a69102937d62341493bd663cdbe3d7d0cf8d59ae34d49bdf57b582f8c4" root_folder = "." # Set your root folder path here resources_folder = os.path.join(root_folder, "resources") # Ensure the resources folder exists os.makedirs(resources_folder, exist_ok=True) + +def create_community(node: StatusNode, i: int, in_shard: bool = False) -> tuple[str, str]: + if in_shard: + name = f"vac_qa_community_{i}_shard" + else: + name = f"vac_qa_community_{i}" + response = node.create_community(name) + community_id = response["result"]["communities"][0]["id"] + if in_shard: + sleep(5) + node.set_community_shard(community_id, 128, sharded_community_pk) + return community_id, name + + for i in range(num_communities): port = str(6130 + i) node = StatusNode(name=f"node{i}", port=port) node.start(capture_logs=False) sleep(4) - name = f"vac_qa_community_{i}" - response = node.create_community(name) - community_id = response["result"]["communities"][0]["id"] + # create the first community in shard 128 + community_id, name = create_community(node, i, i == 0) sleep(5) + print(f"Created community: {name} with ID: {community_id}") node.stop(remove_local_data=False)