upgrade async-graphql and related api changes (#4092)

input-output-hk · Sep 15, 2022 · 79eb8f3 · 79eb8f3
1 parent 790178f
commit 79eb8f3
Show file tree

Hide file tree

Showing 3 changed files with 68 additions and 65 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/explorer/Cargo.toml b/explorer/Cargo.toml
@@ -13,8 +13,8 @@ version = "0.9.1"
 futures = "0.3.5"
 futures-channel = "0.3.5"
 futures-util = "0.3.5"
-async-graphql = "3"
-async-graphql-warp = "3"
+async-graphql = "4.0.13"
+async-graphql-warp = "4.0.13"
 serde = {version = "1.0.114", features = ["derive"]}
 serde_json = "1.0.81"
 serde_yaml = "0.8.13"

diff --git a/explorer/src/api/graphql/mod.rs b/explorer/src/api/graphql/mod.rs
@@ -126,12 +126,14 @@ impl Branch {
                     }
                 };
 
-                connection.append(edges.iter().map(|(h, chain_length)| {
-                    Edge::new(
-                        IndexCursor::from(u32::from(*chain_length)),
-                        Block::from_valid_hash(*h),
-                    )
-                }));
+                connection
+                    .edges
+                    .extend(edges.iter().map(|(h, chain_length)| {
+                        Edge::new(
+                            IndexCursor::from(u32::from(*chain_length)),
+                            Block::from_valid_hash(*h),
+                        )
+                    }));
 
                 Ok::<_, async_graphql::Error>(connection)
             },
@@ -201,7 +203,7 @@ impl Branch {
                         .collect(),
                 };
 
-                connection.append(edges.iter().map(|(h, i)| {
+                connection.edges.extend(edges.iter().map(|(h, i)| {
                     Edge::new(IndexCursor::from(*i), Transaction::from_valid_id(*h))
                 }));
 
@@ -279,7 +281,7 @@ impl Branch {
                     }
                 };
 
-                connection.append(
+                connection.edges.extend(
                     edges
                         .iter()
                         .map(|(vps, cursor)| Edge::new(IndexCursor::from(*cursor), vps.clone())),
@@ -365,7 +367,7 @@ impl Branch {
                     }
                 };
 
-                connection.append(
+                connection.edges.extend(
                     edges
                         .iter()
                         .map(|(pool, cursor)| Edge::new(IndexCursor::from(*cursor), pool.clone())),
@@ -456,7 +458,7 @@ impl Branch {
                             .collect::<Vec<_>>(),
                     };
 
-                    connection.append(edges.iter().map(|(id, cursor)| {
+                    connection.edges.extend(edges.iter().map(|(id, cursor)| {
                         Edge::new(IndexCursor::from(*cursor), Block::from_valid_hash(*id))
                     }));
 
@@ -623,7 +625,7 @@ impl Block {
                     }
                 };
 
-                connection.append(
+                connection.edges.extend(
                     edges
                         .iter()
                         .map(|(tx, cursor)| Edge::new(IndexCursor::from(*cursor), tx.clone())),
@@ -1103,7 +1105,7 @@ impl Pool {
                     },
                 );
 
-                connection.append(
+                connection.edges.extend(
                     edges
                         .iter()
                         .map(|(h, i)| Edge::new(IndexCursor::from(*i), Block::from_valid_hash(*h))),
@@ -1468,7 +1470,7 @@ impl VoteProposalStatus {
                     }
                 };
 
-                connection.append(
+                connection.edges.extend(
                     edges
                         .iter()
                         .map(|(vs, cursor)| Edge::new(IndexCursor::from(*cursor), vs.clone())),