From 796a3899ebaf3633e9a2b58ff6275e29da352936 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Migone?= Date: Fri, 12 Jun 2026 14:49:38 -0300 Subject: [PATCH 1/2] fix: use ipfsHash for unpublishedDeployments pagination MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Tomás Migone --- src/network/subgraph_client.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/network/subgraph_client.rs b/src/network/subgraph_client.rs index bb879c69..6f7e2de5 100644 --- a/src/network/subgraph_client.rs +++ b/src/network/subgraph_client.rs @@ -199,10 +199,10 @@ impl Client { } unpublishedDeployments: subgraphDeployments( block: $block - orderBy: id, orderDirection: asc + orderBy: ipfsHash, orderDirection: asc first: $first where: { - id_gt: $lastUnpublished + ipfsHash_gt: $lastUnpublished activeSubgraphCount: 0 } ) { From e6165362a2b78090a3828f64ad5f9b15ff17b2e8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tom=C3=A1s=20Migone?= Date: Fri, 12 Jun 2026 15:01:59 -0300 Subject: [PATCH 2/2] chore: rename variable MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Tomás Migone --- src/network/subgraph_client.rs | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/network/subgraph_client.rs b/src/network/subgraph_client.rs index 6f7e2de5..594ec177 100644 --- a/src/network/subgraph_client.rs +++ b/src/network/subgraph_client.rs @@ -253,8 +253,8 @@ impl Client { debug_assert!(self.page_size > 0); let mut query_block: Option = None; - let mut last_id: Option = None; - let mut last_unpublished_id: Option = None; + let mut last_subgraph_id: Option = None; + let mut last_unpublished_ipfs_hash: Option = None; let mut subgraphs_done = false; let mut unpublished_done = false; let mut results: Vec = Default::default(); @@ -277,8 +277,8 @@ impl Client { "variables": { "block": block_height, "first": self.page_size, - "last": last_id.clone().unwrap_or_default(), - "lastUnpublished": last_unpublished_id.clone().unwrap_or_default(), + "last": last_subgraph_id.clone().unwrap_or_default(), + "lastUnpublished": last_unpublished_ipfs_hash.clone().unwrap_or_default(), }, }); let response = self @@ -327,7 +327,7 @@ impl Client { } if !subgraphs_done { - last_id = data.results.last().map(|entry| entry.id.to_string()); + last_subgraph_id = data.results.last().map(|entry| entry.id.to_string()); if data.results.len() < self.page_size { subgraphs_done = true; } @@ -335,7 +335,7 @@ impl Client { } if !unpublished_done { - last_unpublished_id = data + last_unpublished_ipfs_hash = data .unpublished_deployments .last() .map(|entry| entry.id.to_string());