Merge pull request #3 from wtrocki/graphback

fix: refactor graphback to hide unused features

services/iot-graphql-api/docker-compose.yml

@@ -0,0 +1,11 @@
+version: '3'
+
+services:
+  postgres:
+    image: postgres:9.6
+    ports:
+      - "5432:5432"
+    environment:
+      POSTGRES_PASSWORD: rhtr-pass
+      POSTGRES_USER: rhtr-user
+      POSTGRES_DB: city-info

services/iot-graphql-api/package.json

@@ -16,9 +16,9 @@
   },
   "license": "Apache 2.0",
   "dependencies": {
-    "@graphback/runtime-knex": "~0.16.1",
-    "@graphql-codegen/add": "~2.0.1",
-    "@graphql-codegen/typescript": "~1.17.9",
+    "@graphback/runtime-knex": "0.16.2",
+    "@graphql-codegen/add": "2.0.1",
+    "@graphql-codegen/typescript": "1.17.9",
     "apollo-server-express": "~2.17.0",
     "cors": "~2.8.5",
     "dotenv": "~8.2.0",
@@ -27,20 +27,20 @@
     "graphback": "~0.16.2",
     "graphql": "~15.3.0",
     "graphql-config": "~3.0.3",
-    "graphql-migrations": "~0.16.1",
-    "graphql-subscriptions": "~1.1.0",
-    "graphql-tag": "~2.11.0",
-    "knex": "~0.21.5",
-    "pg": "~8.3.3"
+    "graphql-migrations": "0.16.2",
+    "graphql-subscriptions": "1.1.0",
+    "graphql-tag": "2.11.0",
+    "knex": "0.21.5",
+    "pg": "8.3.3"
   },
   "devDependencies": {
-    "@graphql-cli/codegen": "~1.17.8",
+    "@graphql-cli/codegen": "1.17.8",
     "@types/bson": "~4.0.2",
     "@types/glob": "~7.1.3",
-    "@types/graphql": "~14.2.3",
+    "@types/graphql": "14.5.0",
     "@types/node-fetch": "~2.5.7",
-    "graphback-cli": "~0.16.1",
-    "graphql-cli": "~4.0.0",
+    "graphback-cli": "0.16.2",
+    "graphql-cli": "4.1.0-beta.1",
     "prettier": "~2.1.1",
     "ts-node": "~9.0.0",
     "tslint": "~6.1.3",

services/iot-graphql-api/src/db.ts

@@ -1,17 +1,18 @@
 import Knex from 'knex'
+import config from './config'
 
 export function loadDBConfig() {
   let port
   if (process.env.DB_PORT) {
     port = parseInt(process.env.DB_PORT, 10)
   }
   return {
-    client: process.env.DB_CLIENT,
+    client: config.DB_CLIENT,
     connection: {
-      user: process.env.DB_USER,
-      password: process.env.DB_PASSWORD,
-      database: process.env.DB_DATABASE,
-      host: process.env.DB_HOST,
+      user: config.DB_USER,
+      password: config.DB_PASSWORD,
+      database: config.DB_DATABASE,
+      host: config.DB_HOST,
       port: port && !isNaN(port) ? port : 5432
     },
     pool: { min: 5, max: 30 }

services/iot-graphql-api/src/graphback.ts

@@ -0,0 +1,50 @@
+import { createKnexDbProvider } from '@graphback/runtime-knex'
+import { ApolloServer } from 'apollo-server-express'
+import { buildGraphbackAPI } from 'graphback'
+import { loadConfigSync } from 'graphql-config'
+import { removeNonSafeOperationsFilter, migrateDB } from 'graphql-migrations'
+import { connectDB, loadDBConfig } from './db'
+
+/**
+ * create Apollo server using automatically generated resolvers
+ */
+export const createApolloServer = async () => {
+  const graphbackExtension = 'graphback'
+  const config = loadConfigSync({
+    extensions: [
+      () => ({
+        name: graphbackExtension
+      })
+    ]
+  })
+
+  const projectConfig = config.getDefault()
+  const graphbackConfig = projectConfig.extension(graphbackExtension)
+  const modelDefs = projectConfig.loadSchemaSync(graphbackConfig.model)
+
+  const db = connectDB()
+
+  const { typeDefs, resolvers, contextCreator } = buildGraphbackAPI(modelDefs, {
+    crud: {
+      create: false,
+      subCreate: false,
+      subUpdate: false,
+      subDelete: false
+    },
+    dataProviderCreator: createKnexDbProvider(db)
+  })
+
+  const dbConfig = loadDBConfig()
+  await migrateDB(dbConfig, typeDefs, {
+    operationFilter: removeNonSafeOperationsFilter
+  })
+  console.log('Migrated database')
+
+  const apolloServer = new ApolloServer({
+    typeDefs,
+    resolvers: [resolvers],
+    context: contextCreator
+  })
+
+  return apolloServer
+}

services/iot-graphql-api/src/index.ts

@@ -2,18 +2,14 @@ import { ApolloServer } from 'apollo-server-express'
 import cors from 'cors'
 import express from 'express'
 import http from 'http'
-import { buildGraphbackAPI } from 'graphback'
-import { loadDBConfig, connectDB } from './db'
-import { migrateDB, removeNonSafeOperationsFilter } from 'graphql-migrations'
-import { createKnexDbProvider } from '@graphback/runtime-knex'
-import { loadConfigSync } from 'graphql-config'
 import { HTTP_RESPONSE_DELAY, NODE_ENV, HTTP_PORT } from './config'
+import { createApolloServer } from './graphback'
 
 const app = express()
 
 app.use(cors())
 
-app.use((req, res, next) => {
+app.use((req: Express.Request, res: Express.Response, next) => {
   if (HTTP_RESPONSE_DELAY && NODE_ENV === 'dev') {
     // Simulate request processing time in dev mode
     setTimeout(() => next(), HTTP_RESPONSE_DELAY)
@@ -22,43 +18,19 @@ app.use((req, res, next) => {
   }
 })
 
-const graphbackExtension = 'graphback'
-const config = loadConfigSync({
-  extensions: [
-    () => ({
-      name: graphbackExtension
-    })
-  ]
-})
-
-const projectConfig = config.getDefault()
-const graphbackConfig = projectConfig.extension(graphbackExtension)
-const modelDefs = projectConfig.loadSchemaSync(graphbackConfig.model)
-
-const db = connectDB()
-const dbConfig = loadDBConfig()
+createApolloServer()
+  .then((apolloServer: ApolloServer) => {
+    apolloServer.applyMiddleware({ app })
 
-const { typeDefs, resolvers, contextCreator } = buildGraphbackAPI(modelDefs, {
-  dataProviderCreator: createKnexDbProvider(db)
-})
-
-migrateDB(dbConfig, typeDefs, {
-  operationFilter: removeNonSafeOperationsFilter
-}).then(() => {
-  console.log('Migrated database')
-})
+    const httpServer = http.createServer(app)
+    apolloServer.installSubscriptionHandlers(httpServer)
 
-const apolloServer = new ApolloServer({
-  typeDefs,
-  resolvers: [resolvers],
-  context: contextCreator
-})
-
-apolloServer.applyMiddleware({ app })
-
-const httpServer = http.createServer(app)
-apolloServer.installSubscriptionHandlers(httpServer)
-
-httpServer.listen({ port: HTTP_PORT }, () => {
-  console.log(`🚀  Server ready at http://localhost:${HTTP_PORT}/graphql`)
-})
+    httpServer.listen({ port: HTTP_PORT }, () => {
+      console.log(
+        `🚀  Graphback Server ready at http://localhost:${HTTP_PORT}/graphql \nFor more information see: https://graphback.dev`
+      )
+    })
+  })
+  .catch((error) => {
+    console.log(`Error: ${error}`)
+  })