test: add failing test for type redefinition

test/gateway/type-redefined.js

@@ -0,0 +1,172 @@
+'use strict'
+
+const { test } = require('tap')
+const Fastify = require('fastify')
+const GQL = require('../..')
+
+const users = {
+  1: {
+    id: 1,
+    name: 'John',
+    username: '@john'
+  },
+  2: {
+    id: 2,
+    name: 'Jane',
+    username: '@jane'
+  }
+}
+
+async function buildService () {
+  const app = Fastify()
+  const schema = `
+    extend type Query {
+      me: User
+    }
+
+    type PageInfo {
+      edges: [User]
+    }
+
+    type User @key(fields: "id") {
+      id: ID!
+      name: String
+      username: String
+    }
+  `
+
+  const resolvers = {
+    Query: {
+      me: () => {
+        return users['1']
+      }
+    }
+  }
+
+  const loaders = {
+    User: {
+      async __resolveReference (queries, { reply }) {
+        return queries.map(({ obj }) => users[obj.id])
+      }
+    }
+  }
+
+  app.register(GQL, {
+    schema,
+    resolvers,
+    loaders,
+    federationMetadata: true,
+    allowBatchedQueries: true
+  })
+
+  return app
+}
+
+async function buildServiceExternal () {
+  const app = Fastify()
+  const schema = `
+    extend type Query {
+      meWrap: PageInfo
+      meWrapDifferentName: PageInfoRenamed
+    }
+
+    type PageInfoRenamed {
+      edges: [User]
+    }
+
+    type PageInfo {
+      edges: [User]
+    }
+
+    type User @key(fields: "id") @extends {
+      id: ID! @external
+    }
+  `
+
+  const resolvers = {
+    Query: {
+      meWrap: () => {
+        return { edges: [{ id: '1', __typename: 'User' }] }
+      },
+      meWrapDifferentName: () => {
+        return { edges: [{ id: '1', __typename: 'User' }] }
+      }
+    }
+  }
+
+  app.register(GQL, {
+    schema,
+    resolvers,
+    federationMetadata: true,
+    allowBatchedQueries: true
+  })
+
+  return app
+}
+
+async function buildProxy (port1, port2) {
+  const proxy = Fastify()
+
+  proxy.register(GQL, {
+    graphiql: true,
+    gateway: {
+      services: [
+        {
+          name: 'ext1',
+          url: `http://localhost:${port1}/graphql`
+        },
+        {
+          name: 'ext2',
+          url: `http://localhost:${port2}/graphql`
+        }
+      ]
+    },
+    pollingInterval: 2000
+  })
+
+  return proxy
+}
+
+test('federated node should be able to redefine type', async (t) => {
+  const port1 = 3027
+  const serviceOne = await buildService()
+  await serviceOne.listen(port1)
+  t.teardown(() => { serviceOne.close() })
+
+  const port2 = 3028
+  const serviceTwo = await buildServiceExternal()
+  await serviceTwo.listen(port2)
+  t.teardown(() => { serviceTwo.close() })
+
+  const serviceProxy = await buildProxy(port1, port2)
+  await serviceProxy.ready()
+  t.teardown(() => { serviceProxy.close() })
+
+  {
+    const res = await serviceProxy.inject({
+      method: 'POST',
+      url: '/graphql',
+      body: {
+        query: `{
+        meWrap { edges { name }  }
+      }`
+      }
+    })
+
+    t.same(res.json(), { data: { meWrap: { edges: [{ name: 'John' }] } } })
+  }
+
+  {
+    const res = await serviceProxy.inject({
+      method: 'POST',
+      url: '/graphql',
+      body: {
+        query: `{
+        meWrapDifferentName { edges { name }  }
+      }`
+      }
+    })
+
+    t.same(res.json(), { data: { meWrapDifferentName: { edges: [{ name: 'John' }] } } })
+  }
+})