Implemented GraphQL-based API gateway

Author: cer

.gitignore

@@ -12,3 +12,5 @@ target
 .project
 .settings
 bin
+node_modules
+dist

build-and-test-all.sh

@@ -1,15 +1,38 @@
 #! /bin/bash -e
 
+KEEP_RUNNING=
+ASSEMBLE_ONLY=
+
+while [ ! -z "$*" ] ; do
+  case $1 in
+    "--keep-running" )
+      KEEP_RUNNING=yes
+      ;;
+    "--assemble-only" )
+      ASSEMBLE_ONLY=yes
+      ;;
+    "--help" )
+      echo ./build-and-test-all.sh --keep-running --assemble-only
+      exit 0
+      ;;
+  esac
+  shift
+done
+
+echo KEEP_RUNNING=$KEEP_RUNNING
+
 . ./set-env.sh
 
 initializeDynamoDB() {
-    echo preparing dynamodblocal table data
-    cd dynamodblocal-init
-    ./create-dynamodb-tables.sh
-    cd ..
-    echo data is prepared
+./initialize-dynamodb.sh
 }
 
+# TODO Temporarily
+
+./build-contracts.sh
+
+./gradlew testClasses
+
 docker-compose down -v
 docker-compose up -d --build dynamodblocal mysql
 
@@ -21,36 +44,49 @@ initializeDynamoDB
 
 docker-compose up -d --build eventuate-local-cdc-service tram-cdc-service
 
-# TODO Temporarily
 
-./build-contracts.sh
+if [ -z "$ASSEMBLE_ONLY" ] ; then
 
-./gradlew -x :ftgo-end-to-end-tests:test $* build
+  ./gradlew -x :ftgo-end-to-end-tests:test $* build
 
-docker-compose build
+  docker-compose build
 
-./gradlew $* integrationTest
+  ./gradlew $* integrationTest
 
 
-# Component tests need to use the per-service database schema
+  # Component tests need to use the per-service database schema
 
-SPRING_DATASOURCE_URL=jdbc:mysql://${DOCKER_HOST_IP?}/ftgoorderservice ./gradlew :ftgo-order-service:cleanComponentTest :ftgo-order-service:componentTest
+  SPRING_DATASOURCE_URL=jdbc:mysql://${DOCKER_HOST_IP?}/ftgoorderservice ./gradlew :ftgo-order-service:cleanComponentTest :ftgo-order-service:componentTest
 
-# Reset the DB/messages
+  # Reset the DB/messages
 
-docker-compose down -v
-docker-compose up -d
+  docker-compose down -v
+  docker-compose up -d
+
+
+else
+
+  ./gradlew $* assemble
+  docker-compose up -d --build
+
+fi
 
 ./wait-for-mysql.sh
 
 echo mysql is started
 
 initializeDynamoDB
 
-date
+./wait-for-mysql.sh
+
+echo mysql is started
 
 ./wait-for-services.sh
 
 ./gradlew :ftgo-end-to-end-tests:cleanTest :ftgo-end-to-end-tests:test
 
-docker-compose down -v
+./run-graphql-api-gateway-tests.sh
+
+if [ -z "$KEEP_RUNNING" ] ; then
+  docker-compose down -v
+fi

docker-compose.yml

@@ -180,6 +180,15 @@ services:
       SPRING_SLEUTH_SAMPLER_PROBABILITY: 1
       SPRING_ZIPKIN_BASE_URL: http://zipkin:9411/
 
+  ftgo-api-gateway-graphql:
+    build: ./ftgo-api-gateway-graphql
+    ports:
+      - "8088:3000"
+    environment:
+      ORDER_HISTORY_SERVICE_URL: http://ftgo-order-history-service:8080
+      CONSUMER_SERVICE_URL: http://ftgo-consumer-service:8080
+      RESTAURANT_SERVICE_URL: http://ftgo-restaurant-service:8080
+
   zipkin:
       image: openzipkin/zipkin:2.5.0
       ports:

ftgo-api-gateway-graphql/.dockerignore

@@ -0,0 +1 @@
+node_modules

ftgo-api-gateway-graphql/Dockerfile

@@ -0,0 +1,7 @@
+FROM node:9.11.2-alpine
+COPY package.json .
+RUN npm install
+COPY tsconfig.json .
+ADD src ./src
+RUN npm run build
+CMD npm run start

ftgo-api-gateway-graphql/jest.config.js

@@ -0,0 +1,18 @@
+module.exports = {
+    globals: {
+        'ts-jest': {
+            tsConfigFile: 'tsconfig.json'
+        }
+    },
+    moduleFileExtensions: [
+        'ts',
+        'js'
+    ],
+    transform: {
+        '^.+\\.(ts|tsx)$': './node_modules/ts-jest/preprocessor.js'
+    },
+    testMatch: [
+        '**/tests/**/*.test.(ts|js)'
+    ],
+    testEnvironment: 'node'
+};

ftgo-api-gateway-graphql/package.json

@@ -0,0 +1,39 @@
+{
+  "private": true,
+  "main": "./src/index.js",
+  "scripts": {
+    "start": "node ./dist/index.js",
+    "build": "tsc",
+    "dev": "tsc --watch & nodemon dist/server.js",
+    "unit-test": "tsc && jest --config jest.config.js tests/unit",
+    "end-to-end-test": "tsc && jest --config jest.config.js tests/end-to-end",
+    "lint": "eslint src --ext ts",
+    "tsc": "tsc",
+    "clean": "rm -fr dist"
+  },
+  "dependencies": {
+    "apollo-cache-inmemory": "^1.2.1",
+    "apollo-client": "^2.3.1",
+    "apollo-engine": "^1.0.1",
+    "apollo-link-http": "^1.5.4",
+    "apollo-server-express": "1.3.2",
+    "body-parser": "^1.17.1",
+    "dataloader": "^1.4.0",
+    "express": "^4.15.2",
+    "graphql-tools": "2.20.2",
+    "node-fetch": "^2.0.0"
+  },
+  "devDependencies": {
+    "@types/mocha": "^5.2.0",
+    "@types/node": "^10.1.4",
+    "apollo-boost": "^0.1.6",
+    "apollo-link-persisted-queries": "^0.2.0",
+    "apollo-link-schema": "^1.1.0",
+    "graphql": "^0.13.2",
+    "graphql-tag": "^2.9.2",
+    "jest": "^23.0.1",
+    "ts-jest": "^22.4.6",
+    "tsc": "^1.20150623.0",
+    "typescript": "^2.8.4"
+  }
+}

ftgo-api-gateway-graphql/queries.txt

@@ -0,0 +1,31 @@
+
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "query { consumer(consumerId:1)  { id, firstName, lastName} } " }'
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "query { consumer(consumerId:1)  { id, firstName, lastName  orders { orderId restaurant {id name }} } } " }'
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "{ orders(consumerId:1)  { orderId, consumer { id, firstName, lastName} } }" }'
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "{ orders(consumerId:1)  { orderId, restaurant { name } } }" }'
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "{ consumer(consumerId:1)  { id, firstName, lastName, orders { orderId } } } " }'
+
+
+# doesn't like spaces in query!
+
+curl -v -g 'http://localhost:3000/graphql?query={orders(consumerId:1){orderId,restaurant{id}}}'
+
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{ "query": "{ orders(consumerId:1)  { orderId, restaurant { name } } }" }'
+
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{
+
+"query": "mutation ($fn : String, $ln : String) { createConsumer(c: {firstName: $fn, lastName: $ln})  { id, orders { orderId } } } ",
+"variables" : { "fn": "Chris", "ln" : "Richardson" }
+
+ }'
+
+curl http://localhost:3000/graphql -X POST   -H "Content-Type: application/json"   --data '{
+
+"query": "{ __schema { types { name } } }"
+ }'

ftgo-api-gateway-graphql/src/ConsumerServiceProxy.js

@@ -0,0 +1,58 @@
+const fetch = require("node-fetch");
+const DataLoader = require('dataloader');
+
+
+class ConsumerServiceProxy {
+
+    constructor(options) {
+        console.log("ConsumerServiceProxy constructor", options, DataLoader);
+        this.dataLoader = new DataLoader(keys => this.batchFindConsumers(keys));
+        this.consumerService = `${options.baseUrl}/consumers`;
+    }
+
+    findConsumer(consumerId) {
+        console.log("findConsumer")
+        return this.dataLoader.load(consumerId);
+    }
+
+    findConsumerInternal(consumerId) {
+        console.log("findConsumerInternal")
+        return fetch(`${this.consumerService}/${consumerId}`)
+            .then(response => {
+                console.log("response=", response.status);
+                if (response.status == 200) {
+                    return response.json().then(body => {
+                        console.log("response=", body);
+                        return Object.assign({
+                            id: consumerId,
+                            firstName: body.name.firstName,
+                            lastName: body.name.lastName
+                        }, body);
+                    })
+                } else
+                    return Promise.reject(new Error("cannot found consumer for id" + consumerId))
+            });
+    }
+
+    createConsumer(firstName, lastName) {
+        console.log("createConsumer")
+        return fetch(this.consumerService, {
+            method: 'POST',
+            body: JSON.stringify({name: {firstName, lastName}}),
+            headers: {"Content-Type": "application/json"}
+        })
+            .then(r => r.json())
+            .then(({consumerId}) => {
+                console.log("consumerId=", consumerId);
+                return {id: consumerId, orders: []};
+            })
+    }
+
+    batchFindConsumers(keys) {
+        console.log("keys=", keys);
+        return Promise.all(keys.map(k => this.findConsumerInternal(k)));
+    }
+
+}
+
+module.exports = {ConsumerServiceProxy};

ftgo-api-gateway-graphql/src/OrderServiceProxy.js

@@ -0,0 +1,23 @@
+const fetch = require("node-fetch");
+
+class OrderServiceProxy {
+
+    constructor(options) {
+        this.orderService = `${options.baseUrl}/orders`;
+    }
+
+    findOrders(consumerId) {
+        return fetch(`${this.orderService}?consumerId=${consumerId}`)
+            .then(res => res.json())
+            .then(data => {
+                // Sometimes, there are no upcoming events
+                console.log("orders=", data);
+                const x = data.orders.map((order) => Object.assign({consumerId}, order));
+                console.log("orders=", x);
+                return x;
+            });
+    }
+
+}
+
+module.exports = {OrderServiceProxy};

ftgo-api-gateway-graphql/src/RestaurantServiceProxy.js

@@ -0,0 +1,36 @@
+const fetch = require("node-fetch");
+const DataLoader = require('dataloader');
+
+class RestaurantServiceProxy {
+    constructor(options) {
+        this.restaurantServiceUrl = `${options.baseUrl}/restaurants`;
+        this.dataLoader = new DataLoader(restaurantIds => this.batchFindRestaurants(restaurantIds));
+        console.log("this.restaurantServiceUrl", this.restaurantServiceUrl);
+    }
+
+    findRestaurant(restaurantId) {
+        return this.dataLoader.load(restaurantId);
+    }
+
+    findRestaurantInternal(restaurantId) {
+        return fetch(`${this.restaurantServiceUrl}/${restaurantId}`)
+            .then(response => {
+                console.log("response=", response.status);
+                if (response.status === 200) {
+                    return response.json().then(body => {
+                        console.log("response=", body);
+                        return Object.assign({id: restaurantId, name: body.name.name}, body);
+                    })
+                } else
+                    return Promise.reject(new Error("cannot found restaurant for id" + restaurantId))
+            });
+    }
+
+    batchFindRestaurants(restaurantIds) {
+        console.log("restaurantIds=", restaurantIds);
+        return Promise.all(restaurantIds.map(k => this.findRestaurantInternal(k)));
+    }
+
+}
+
+module.exports = {RestaurantServiceProxy};

ftgo-api-gateway-graphql/src/index.js

@@ -0,0 +1,8 @@
+
+const {app} = require("./server");
+
+const PORT = 3000;
+
+app.listen(PORT);
+
+console.log("Server listing on port: ", PORT);