Updated federation and fixed linting

Author: tlivings

examples/federation/gateway.js renamed to examples/federation/gateway.ts

@@ -1,8 +1,7 @@
-const { ApolloServer } = require('apollo-server');
-const { ApolloGateway } = require('@apollo/gateway');
+import { ApolloServer } from 'apollo-server';
+import { ApolloGateway } from '@apollo/gateway';
 
-
-const run = async function() {
+const run = async function(): Promise<void> {
   const gateway = new ApolloGateway({
     serviceList: [
       { name: 'property', url: 'http://localhost:4001' },
@@ -11,12 +10,11 @@ const run = async function() {
   });
 
   const server = new ApolloServer({
-    gateway,
-    subscriptions: false
+    gateway
   });
 
   const { url } = await server.listen({port: 4000});
   console.log(`🚀 Gateway ready at ${url}`);
 }
 
-module.exports = { run };
+export { run }; 

examples/federation/gateway/index.js renamed to examples/federation/gateway/index.ts

@@ -1,8 +1,7 @@
+import { ApolloServer } from 'apollo-server';
+import { ApolloGateway } from '@apollo/gateway';
 
-const { ApolloServer } = require('apollo-server');
-const { ApolloGateway } = require('@apollo/gateway');
-
-const startGateway = async () => {
+const startGateway = async (): Promise<void> => {
   const gateway = new ApolloGateway({
     serviceList: [
       { name: 'property', url: 'http://localhost:4001' },
@@ -11,13 +10,11 @@ const startGateway = async () => {
   });
 
   const server = new ApolloServer({
-    gateway,
-    subscriptions: false
+    gateway
   });
 
   const { url } = await server.listen({port: 4000});
   console.log(`🚀 Gateway ready at ${url}`);
 }
 
-module.exports = startGateway;
-
+export default startGateway; 

examples/federation/property-service/datasource.js

@@ -0,0 +1,23 @@
+'use strict';
+
+import { ComponentContext, DataSourceDefinition } from "../../../src";
+
+interface Property {
+  id: number;
+  geo: string[];
+}
+
+const propertiesDB: Record<number, Property> = {
+  1: { id: 1, geo: ['41.40338', '2.17403']},
+  2: { id: 2, geo: ['111.1111', '222.2222']}
+}
+
+class PropertyDataSource implements DataSourceDefinition<PropertyDataSource> {
+  name = 'PropertyDataSource';
+
+  getPropertyById(context: ComponentContext, id: string): Property | undefined {
+    return propertiesDB[id];
+  }
+}
+
+export default PropertyDataSource; 

examples/federation/property-service/datasource.ts

@@ -1,18 +1,22 @@
 'use strict';
 
-const { ApolloServer } = require('apollo-server');
-const GraphQLComponent = require('../../../dist').default;
-const PropertyDataSource = require('./datasource');
-const resolvers = require('./resolvers');
-const types = require('./types');
+import { ApolloServer } from 'apollo-server';
+import GraphQLComponent from '../../../dist';
+import PropertyDataSource from './datasource';
+import resolvers from './resolvers';
+import types from './types';
+
+interface PropertyComponentOptions {
+  [key: string]: any;
+}
 
 class PropertyComponent extends GraphQLComponent {
-  constructor(options) {
+  constructor(options: PropertyComponentOptions) {
     super(options);
   }
 }
 
-const run = async function () {
+const run = async function (): Promise<void> {
   const { schema, context } = new PropertyComponent({
     types,
     resolvers,
@@ -22,12 +26,11 @@ const run = async function () {
 
   const server = new ApolloServer({
     schema,
-    context,
-    subscriptions: false,
+    context
   });
 
   const { url } = await server.listen({port: 4001})
   console.log(`🚀 Property service ready at ${url}`)
 }
 
-module.exports = { run };
+export { run }; 

examples/federation/property-service/index.js renamed to examples/federation/property-service/index.ts

@@ -0,0 +1,18 @@
+'use strict';
+
+import { ComponentContext } from "../../../src";
+
+const resolvers = {
+  Query: {
+    property(_: any, { id }: { id: string }, { dataSources }: ComponentContext) {
+      return dataSources.PropertyDataSource.getPropertyById(id);
+    }
+  },
+  Property: {
+    __resolveReference(ref: { id: string }, { dataSources }: ComponentContext) {
+      return dataSources.PropertyDataSource.getPropertyById(ref.id);
+    }
+  }
+};
+
+export default resolvers; 

examples/federation/property-service/resolvers.js

@@ -1,8 +1,8 @@
 'use strict';
 
-const fs = require('fs');
-const path = require('path');
+import * as fs from 'fs';
+import * as path from 'path';
 
 const types = fs.readFileSync(path.resolve(path.join(__dirname, 'schema.graphql')), 'utf-8');
 
-module.exports = types;
+export default types; 

examples/federation/property-service/resolvers.ts

@@ -1,15 +1,22 @@
 'use strict';
 
+import { ComponentContext, DataSourceDefinition } from "../../../src";
+
+interface Review {
+  id: string;
+  content: string;
+}
+
 // reviews indexed by property id
-const reviewsDB = {
+const reviewsDB: Record<number, Review[]> = {
   1: [ { id: 'rev-id-1-a', content: 'this property was great'}, { id: 'rev-id-1-b', content: 'this property was terrible'}],
   2: [ { id: 'rev-id-2-a', content: 'This property was amazing for our extended family'}, { id: 'rev-id-2-b', content: 'I loved the proximity to the beach'}, { id: 'rev-id-2-c', content: 'The bed was not comfortable at all'}]
 }
 
-class ReviewsDataSource {
-  getReviewsByPropertyId(context, propertyId) {
+class ReviewsDataSource implements DataSourceDefinition<ReviewsDataSource> {
+  getReviewsByPropertyId(context: ComponentContext, propertyId: string): Review[] | undefined {
     return reviewsDB[propertyId];
   }
 }
 
-module.exports = ReviewsDataSource;
+export default ReviewsDataSource; 

examples/federation/property-service/types.js renamed to examples/federation/property-service/types.ts

@@ -1,19 +1,23 @@
 'use strict';
 
-const { ApolloServer } = require('apollo-server');
-const GraphQLComponent = require('../../../dist').default;
-const ReviewsDataSource = require('./datasource');
-const resolvers = require('./resolvers');
-const types = require('./types');
-const toUppercaseDirective = require('./toUppercaseDirective')
+import { ApolloServer } from 'apollo-server';
+import GraphQLComponent from '../../../dist';
+import ReviewsDataSource from './datasource';
+import resolvers from './resolvers';
+import types from './types';
+import toUppercaseDirective from './toUppercaseDirective';
+
+interface ReviewsComponentOptions {
+  [key: string]: any;
+}
 
 class ReviewsComponent extends GraphQLComponent {
-  constructor(options) {
+  constructor(options: ReviewsComponentOptions) {
     super(options);
   }
 }
 
-const run = async function () {
+const run = async function (): Promise<void> {
   const { schema, context } = new ReviewsComponent({
     types,
     resolvers,
@@ -26,13 +30,11 @@ const run = async function () {
 
   const server = new ApolloServer({
     schema,
-    context,
-    subscriptions: false
+    context
   });
 
   const { url } = await server.listen({port: 4002})
   console.log(`🚀 Reviews service ready at ${url}`)
-
 }
 
-module.exports = { run };
+export { run }; 

examples/federation/reviews-service/datasource.js renamed to examples/federation/reviews-service/datasource.ts

@@ -0,0 +1,18 @@
+'use strict';
+
+import { ComponentContext } from "../../../src";
+
+const resolvers = {
+  Query: {
+    reviewsByPropertyId(_: any, { propertyId }: { propertyId: string }, { dataSources }: ComponentContext) {
+      return dataSources.ReviewsDataSource.getReviewsByPropertyId(propertyId);
+    }
+  },
+  Property: {
+    reviews(root: { id: string }, _args: any, { dataSources }: ComponentContext) {
+      return dataSources.ReviewsDataSource.getReviewsByPropertyId(root.id);
+    }
+  }
+};
+
+export default resolvers; 

examples/federation/reviews-service/index.js renamed to examples/federation/reviews-service/index.ts

@@ -1,15 +1,15 @@
-const {getDirective, MapperKind, mapSchema} = require("@graphql-tools/utils");
-const {defaultFieldResolver} = require("graphql");
+import { getDirective, MapperKind, mapSchema } from "@graphql-tools/utils";
+import { defaultFieldResolver, GraphQLSchema } from "graphql";
 
-function toUppercaseDirective(directiveName) {
-    return (schema) => mapSchema(schema, {
+function toUppercaseDirective(directiveName: string) {
+    return (schema: GraphQLSchema) => mapSchema(schema, {
         [MapperKind.OBJECT_FIELD]: (fieldConfig) => {
             const upperDirective = getDirective(schema, fieldConfig, directiveName)?.[0];
             if (upperDirective) {
                 const {resolve = defaultFieldResolver} = fieldConfig;
                 return {
                     ...fieldConfig,
-                    resolve: async function (source, args, context, info) {
+                    resolve: async function (source: any, args: any, context: any, info: any) {
                         const result = await resolve(source, args, context, info);
                         if (typeof result === 'string') {
                             return result.toUpperCase();
@@ -22,4 +22,4 @@ function toUppercaseDirective(directiveName) {
     })
 }
 
-module.exports = toUppercaseDirective
+export default toUppercaseDirective; 

examples/federation/reviews-service/resolvers.js

@@ -1,8 +1,8 @@
 'use strict';
 
-const fs = require('fs');
-const path = require('path');
+import * as fs from 'fs';
+import * as path from 'path';
 
 const types = fs.readFileSync(path.resolve(path.join(__dirname, 'schema.graphql')), 'utf-8');
 
-module.exports = types;
+export default types; 

examples/federation/reviews-service/resolvers.ts

@@ -0,0 +1,11 @@
+import { run as runReviewsService } from './reviews-service';
+import { run as runPropertyService } from './property-service';
+import { run as runGateway } from './gateway';
+
+const start = async (): Promise<void> => {
+  await runReviewsService();
+  await runPropertyService();
+  await runGateway();
+}
+
+start(); 

examples/federation/reviews-service/toUppercaseDirective.js renamed to examples/federation/reviews-service/toUppercaseDirective.ts

@@ -15,7 +15,7 @@
     "prepublish": "npm run build",
     "test": "tape -r ts-node/register \"test/**/*.ts\"",
     "start-composition": "DEBUG=graphql-component ts-node examples/composition/server/index.ts",
-    "start-federation": "DEBUG=graphql-component node examples/federation/run-federation-example.js",
+    "start-federation": "DEBUG=graphql-component ts-node examples/federation/run-federation-example.ts",
     "lint": "npx eslint src/index.ts",
     "cover": "nyc npm test",
     "update-deps": "ncu -u && npm install",