docs: graphql schema stitching w neo4j-graphql-js

Author: roschaefer

example/schema-stitching/.env.test

@@ -0,0 +1,7 @@
+JWT_SECRET='supersecret'
+NEO4J_USERNAME='neo4j'
+NEO4J_PASSWORD='letmein'
+NEO4J_PROTOCOL=neo4j
+NEO4J_HOST=localhost
+NEO4J_DATABASE=neo4j
+NEO4J_ENCRYPTION=ENCRYPTION_OFF

example/schema-stitching/.eslintrc.js

@@ -0,0 +1,28 @@
+module.exports = {
+  plugins: ['jest'],
+  env: {
+    es6: true,
+    node: true,
+    'jest/globals': true
+  },
+  extends: 'airbnb-base',
+  globals: {
+    Atomics: 'readonly',
+    SharedArrayBuffer: 'readonly'
+  },
+  parserOptions: {
+    ecmaVersion: 2018,
+    sourceType: 'module'
+  },
+  rules: {
+    'jest/no-disabled-tests': 'warn',
+    'jest/no-focused-tests': 'error',
+    'jest/no-identical-title': 'error',
+    'jest/prefer-to-have-length': 'warn',
+    'jest/valid-expect': 'error',
+    'import/no-extraneous-dependencies': [
+      'error',
+      { devDependencies: ['db/**/*.js', '**/*.test.js', '**/*.spec.js'] }
+    ]
+  }
+};

example/schema-stitching/babel.config.js

@@ -0,0 +1,3 @@
+module.exports = {
+  presets: [['@babel/preset-env', { targets: { node: 'current' } }]]
+};

example/schema-stitching/index.js

@@ -0,0 +1,15 @@
+import { ApolloServer } from 'apollo-server';
+import Server from './src/server';
+
+const playground = {
+  settings: {
+    'schema.polling.enable': false
+  }
+};
+
+(async () => {
+  const server = await Server(ApolloServer, { playground });
+  const { url } = await server.listen();
+  // eslint-disable-next-line no-console
+  console.log(`🚀  Server ready at ${url}`);
+})();

example/schema-stitching/package.json

@@ -0,0 +1,46 @@
+{
+  "name": "neo4j-graphql-js-example-schema-stitching",
+  "version": "1.0.0",
+  "main": "index.js",
+  "license": "MIT",
+  "scripts": {
+    "lint": "eslint .",
+    "test": "jest",
+    "test:debug": "node inspect node_modules/jest/bin/jest.js",
+    "dev": "nodemon -r esm index.js",
+    "dev:debug": "nodemon inspect -r esm index.js",
+    "db:seed": "node -r esm src/db/seed.js",
+    "db:clean": "node -r esm src/db/clean.js"
+  },
+  "dependencies": {
+    "@graphql-tools/delegate": "^7.0.7",
+    "@graphql-tools/graphql-file-loader": "^6.2.6",
+    "@graphql-tools/load": "^6.2.5",
+    "@graphql-tools/schema": "^7.1.2",
+    "@graphql-tools/stitch": "^7.1.4",
+    "@graphql-tools/wrap": "^7.0.4",
+    "apollo-datasource": "^0.7.2",
+    "apollo-server": "^2.19.0",
+    "bcrypt": "^5.0.0",
+    "dotenv-flow": "^3.2.0",
+    "graphql-tools": "^7.0.2",
+    "jsonwebtoken": "^8.5.1",
+    "neo4j-driver": "^4.2.1",
+    "neo4j-graphql-js": "^2.17.1",
+    "neode": "^0.4.6"
+  },
+  "devDependencies": {
+    "@babel/core": "^7.12.9",
+    "@babel/preset-env": "^7.12.7",
+    "apollo-server-testing": "^2.19.0",
+    "babel-eslint": "^10.1.0",
+    "babel-jest": "^26.6.3",
+    "eslint": "^7.14.0",
+    "eslint-config-airbnb-base": "^14.2.1",
+    "eslint-plugin-import": "^2.22.1",
+    "eslint-plugin-jest": "^24.1.3",
+    "esm": "^3.2.25",
+    "jest": "^26.6.3",
+    "nodemon": "^2.0.6"
+  }
+}

example/schema-stitching/src/config.js

@@ -0,0 +1,14 @@
+require('dotenv-flow').config();
+
+export const { JWT_SECRET, NEO4J_USERNAME, NEO4J_PASSWORD } = process.env;
+if (!(JWT_SECRET && NEO4J_USERNAME && NEO4J_PASSWORD)) {
+  throw new Error(`
+
+Please create a .env file and configure environment variables there.
+
+You could e.g. copy the .env file used for testing:
+
+$ cp .env.text .env
+`);
+}
+export default { JWT_SECRET, NEO4J_USERNAME, NEO4J_PASSWORD };

example/schema-stitching/src/context.js

@@ -0,0 +1,15 @@
+import jwt from 'jsonwebtoken';
+import driver from './driver';
+import { JWT_SECRET } from './config';
+
+export default function context({ req }) {
+  let token = req.headers.authorization || '';
+  token = token.replace('Bearer ', '');
+  const jwtSign = payload => jwt.sign(payload, JWT_SECRET);
+  try {
+    const decoded = jwt.verify(token, JWT_SECRET);
+    return { ...decoded, jwtSign, driver };
+  } catch (e) {
+    return { jwtSign, driver };
+  }
+}

example/schema-stitching/src/db/clean.js

@@ -0,0 +1,8 @@
+import neode from './neode';
+
+(async () => {
+  await neode.driver
+    .session()
+    .writeTransaction(txc => txc.run('MATCH(n) DETACH DELETE n;'));
+  neode.driver.close();
+})();

example/schema-stitching/src/db/entities/Person.js

@@ -0,0 +1,36 @@
+import bcrypt from 'bcrypt';
+import neode from '../neode';
+
+export default class Person {
+  constructor(data) {
+    Object.assign(this, data);
+  }
+
+  checkPassword(password) {
+    return bcrypt.compareSync(password, this.hashedPassword);
+  }
+
+  async save() {
+    this.hashedPassword = bcrypt.hashSync(this.password, 10);
+    const node = await neode.create('Person', this);
+    Object.assign(this, { ...node.properties(), node });
+    return this;
+  }
+
+  static async first(props) {
+    const node = await neode.first('Person', props);
+    if (!node) return null;
+    return new Person({ ...node.properties(), node });
+  }
+
+  static currentUser(context) {
+    const { person } = context;
+    if (!person) return null;
+    return Person.first({ id: person.id });
+  }
+
+  static async all() {
+    const nodes = await neode.all('Person');
+    return nodes.map(node => new Person({ ...node.properties(), node }));
+  }
+}

example/schema-stitching/src/db/entities/Post.js

@@ -0,0 +1,16 @@
+import neode from '../neode';
+
+export default class Post {
+  constructor(data) {
+    Object.assign(this, data);
+  }
+
+  async save() {
+    if (!(this.author && this.author.node))
+      throw new Error('author node is missing!');
+    const node = await neode.create('Post', this);
+    await node.relateTo(this.author.node, 'wrote');
+    Object.assign(this, { ...node.properties(), node });
+    return this;
+  }
+}