WIP: Fusion & GraphClient

examples/composition/graphclient.config.ts

@@ -0,0 +1,37 @@
+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',
+      }),
+    },
+  ],
+})

examples/composition/package.json

@@ -4,13 +4,14 @@
   "version": "0.0.0",
   "scripts": {
     "start": "ts-node --transpileOnly src/index.ts",
-    "build-client": "graphclient build",
     "check": "tsc --pretty --noEmit",
-    "graphiql": "graphclient serve-dev"
+    "graphiql": "node ../../packages/serve-cli/dist/cjs/bin.js",
+    "build": "node ../../packages/compose-cli/dist/cjs/bin.js"
   },
   "dependencies": {
-    "@graphprotocol/client-cli": "^3.0.0",
-    "@graphql-mesh/transform-rename": "^0.94.0",
+    "@graphprotocol/client-compose-cli": "^0.0.0",
+    "@graphprotocol/client-runtime": "^0.0.0",
+    "@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,18 +1,22 @@
-import { execute } from '../.graphclient'
+import { getExecutor } from '@graphprotocol/client-runtime'
+import fusiongraph from '../fusiongraph'
+import { parse } from 'graphql'
+
+const executor = getExecutor({
+  fusiongraph,
+})
 
 async function main() {
-  const response = await execute(
-    /* GraphQL */ `
+  const response = await executor({
+    document: parse(/* GraphQL */ `
       fragment UserFields on User {
         # Shared unique identifier field
         id
         # Field from uniswap source
-        tokens(first: 1) {
+        ERC721tokens(first: 1001) {
+          # Testing auto pagination by exceeding the limit of 1000
           id
           uri
-          registry {
-            id
-          }
         }
         # Field from nft source
         liquidityPositions(first: 1) {
@@ -26,15 +30,28 @@ async function main() {
           ...UserFields
         }
         # Get base entity from uniswap source
-        user(id: "0x72ba1965320ab5352fd6d68235cc3c5306a6ffa2") {
-          ...UserFields
-        }
+        # user(id: "0x72ba1965320ab5352fd6d68235cc3c5306a6ffa2") {
+        #  ...UserFields
+        #}
       }
-    `,
-    {},
-  )
+    `),
+  })
+
+  if (Symbol.asyncIterator in response) {
+    throw new Error('Unexpected async iterator response')
+  }
 
-  console.log(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/composition/tsconfig.json

@@ -8,5 +8,5 @@
     "lib": ["esnext", "DOM", "DOM.Iterable"],
     "allowSyntheticDefaultImports": true
   },
-  "files": ["src/index.ts"]
+  "files": ["src/index.ts", "graphclient.config.ts"]
 }

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"
   }
 }