Block tracking tests

Author: ardatan

examples/composition/graphclient.config.ts

@@ -1,32 +1,37 @@
-import { createRenameFieldTransform, createRenameTypeTransform, defineConfig as defineComposeConfig, loadGraphQLHTTPSubgraph } from '@graphprotocol/client-compose-cli';
-import { GraphQLID } from 'graphql';
+import {
+  createRenameFieldTransform,
+  createRenameTypeTransform,
+  defineConfig as defineComposeConfig,
+  loadGraphQLHTTPSubgraph,
+} from '@graphprotocol/client-compose-cli'
+import { GraphQLID } from 'graphql'
 
 export const composeConfig = defineComposeConfig({
-    subgraphs: [
-        {
-            sourceHandler: loadGraphQLHTTPSubgraph('nft', {
-                endpoint: 'https://api.thegraph.com/subgraphs/name/amxx/eip721-subgraph',
-            }),
-            transforms: [
-                // Resolve conflicts between subgraphs
-                createRenameFieldTransform((field, fieldName, typeName) => {
-                    if (typeName === 'Account' && fieldName === 'id') {
-                        field.type = GraphQLID;
-                    }
-                    return fieldName;
-                }),
-                createRenameTypeTransform(type => {
-                    if (type.name === 'Account') {
-                        return 'User';
-                    }
-                    return type.name;
-                })
-            ]
-        },
-        {
-            sourceHandler: loadGraphQLHTTPSubgraph('uniswap', {
-                endpoint: 'https://api.thegraph.com/subgraphs/name/uniswap/uniswap-v2',
-            })
-        }
-    ]
-})
+  subgraphs: [
+    {
+      sourceHandler: loadGraphQLHTTPSubgraph('nft', {
+        endpoint: 'https://api.thegraph.com/subgraphs/name/amxx/eip721-subgraph',
+      }),
+      transforms: [
+        // Resolve conflicts between subgraphs
+        createRenameFieldTransform((field, fieldName, typeName) => {
+          if (typeName === 'Account' && fieldName === 'id') {
+            field.type = GraphQLID
+          }
+          return fieldName
+        }),
+        createRenameTypeTransform((type) => {
+          if (type.name === 'Account') {
+            return 'User'
+          }
+          return type.name
+        }),
+      ],
+    },
+    {
+      sourceHandler: loadGraphQLHTTPSubgraph('uniswap', {
+        endpoint: 'https://api.thegraph.com/subgraphs/name/uniswap/uniswap-v2',
+      }),
+    },
+  ],
+})

examples/composition/package.json

@@ -11,7 +11,7 @@
   "dependencies": {
     "@graphprotocol/client-compose-cli": "^0.0.0",
     "@graphprotocol/client-runtime": "^0.0.0",
-    "@graphql-mesh/transport-http": "^0.0.3",
+    "@graphql-mesh/transport-http": "^0.1.4",
     "concurrently": "^8.0.1",
     "graphql": "^16.6.0",
     "nodemon": "^3.0.0",

examples/composition/src/index.ts

@@ -1,8 +1,8 @@
-import { getExecutorForFusiongraph } from '@graphprotocol/client-runtime'
+import { getExecutor } from '@graphprotocol/client-runtime'
 import fusiongraph from '../fusiongraph'
 import { parse } from 'graphql'
 
-const executor = getExecutorForFusiongraph({
+const executor = getExecutor({
   fusiongraph,
 })
 
@@ -13,7 +13,8 @@ async function main() {
         # Shared unique identifier field
         id
         # Field from uniswap source
-        ERC721tokens(first: 1) {
+        ERC721tokens(first: 1001) {
+          # Testing auto pagination by exceeding the limit of 1000
           id
           uri
         }
@@ -29,14 +30,28 @@ async function main() {
           ...UserFields
         }
         # Get base entity from uniswap source
-        user(id: "0x72ba1965320ab5352fd6d68235cc3c5306a6ffa2") {
-          ...UserFields
-        }
+        # user(id: "0x72ba1965320ab5352fd6d68235cc3c5306a6ffa2") {
+        #  ...UserFields
+        #}
       }
     `),
   })
 
-  console.log(response)
+  if (Symbol.asyncIterator in response) {
+    throw new Error('Unexpected async iterator response')
+  }
+
+  if ('errors' in response && response.errors?.length) {
+    for (const error of response.errors) {
+      console.error(error.message)
+    }
+  } else {
+    console.log(`
+      Account: ${response.data?.account.id} has
+        ${response.data?.account.ERC721tokens.length} ERC721 tokens and
+        ${response.data?.account.liquidityPositions.length} liquidity positions
+    `)
+  }
 }
 
 main().catch((e) => console.error(`Failed to run example:`, e))

examples/transforms/package.json

@@ -8,7 +8,7 @@
   },
   "dependencies": {
     "@graphprotocol/client-cli": "^3.0.0",
-    "@graphql-mesh/transform-prefix": "^0.94.0",
+    "@graphql-mesh/transform-prefix": "^0.97.4",
     "graphql": "^16.6.0"
   }
 }

packages/auto-type-merging/package.json

@@ -47,6 +47,7 @@
   },
   "dependencies": {
     "@graphql-mesh/transform-type-merging": "^0.94.0",
+    "@graphql-mesh/fusion-runtime": "^0.2.5",
     "tslib": "^2.4.0"
   },
   "peerDependencies": {