add basic query and mutation

Author: jonirrings

Diff for: .babelrc

@@ -0,0 +1,12 @@
+{
+  "presets": [
+    [
+      "env",
+      {
+        "targets": {
+          "node": "current"
+        }
+      }
+    ]
+  ]
+}

Diff for: .gitignore

@@ -0,0 +1,115 @@
+# Created by .ignore support plugin (hsz.mobi)
+### JetBrains template
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and Webstorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff:
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/dictionaries
+
+# Sensitive or high-churn files:
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.xml
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+
+# Gradle:
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# CMake
+cmake-build-debug/
+cmake-build-release/
+
+# Mongo Explorer plugin:
+.idea/**/mongoSettings.xml
+
+## File-based project format:
+*.iws
+
+## Plugin-specific files:
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+### Node template
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+# next.js build output
+.next
+

Diff for: app.js

@@ -0,0 +1,22 @@
+import express from 'express';
+import expressGraphQL from 'express-graphql';
+import morgan from 'morgan';
+
+import client from './data/redis';
+import schema from './data/schema';
+
+const logger = morgan('dev');
+
+const app = express();
+app.use(logger);
+
+app.use('/graphql', expressGraphQL({
+    schema: schema,
+    graphiql: true,
+    context: {
+        client
+    },
+    pretty: true
+}));
+
+export default app;

Diff for: bin/www

@@ -0,0 +1,78 @@
+import debug from 'debug';
+import http from 'http';
+import app from '../app';
+import redis from '../data/redis';
+
+const logger = debug('redis-pubsub:server');
+const port = normalizePort(process.env.PORT || '3000');
+app.set('port', port);
+const server = http.createServer(app);
+
+redis
+    .connect(() => logger("Redis connected"))
+    .then(() => {
+        server.listen(port);
+        server.on('error', onError);
+        server.on('listening', onListening);
+    })
+    .catch(err => console.error(err.stack));
+
+/**
+ * Normalize a port into a number, string, or false.
+ */
+
+function normalizePort(val) {
+    const port = parseInt(val, 10);
+
+    if (isNaN(port)) {
+        // named pipe
+        return val;
+    }
+
+    if (port >= 0) {
+        // port number
+        return port;
+    }
+
+    return false;
+}
+
+/**
+ * Event listener for HTTP server "error" event.
+ */
+
+function onError(error) {
+    if (error.syscall !== 'listen') {
+        throw error;
+    }
+
+    const bind = typeof port === 'string'
+        ? 'Pipe ' + port
+        : 'Port ' + port;
+
+    // handle specific listen errors with friendly messages
+    switch (error.code) {
+        case 'EACCES':
+            console.error(bind + ' requires elevated privileges');
+            process.exit(1);
+            break;
+        case 'EADDRINUSE':
+            console.error(bind + ' is already in use');
+            process.exit(1);
+            break;
+        default:
+            throw error;
+    }
+}
+
+/**
+ * Event listener for HTTP server "listening" event.
+ */
+
+function onListening() {
+    const addr = server.address();
+    const bind = typeof addr === 'string'
+        ? 'pipe ' + addr
+        : 'port ' + addr.port;
+    logger('Listening on ' + bind);
+}

Diff for: data/models/dish.js

@@ -0,0 +1,26 @@
+import {GraphQLError} from 'graphql';
+
+export default function (ctx) {
+    const {client} = ctx;
+
+    function set(v) {
+        return client.set('dish', JSON.stringify(v)).then((result) => {
+            if (result === 'OK') {
+                return v;
+            } else {
+                return new GraphQLError('failed to store data into redis: ' + result);
+            }
+        });
+    }
+
+    function get() {
+        return client.get('dish')
+            .then(v => JSON.parse(v))
+            .catch(err => new GraphQLError('failed to get data from redis: ' + err));
+    }
+
+    return {
+        get,
+        set
+    }
+}

Diff for: data/models/index.js

@@ -0,0 +1,5 @@
+import dish from './dish';
+
+export {
+    dish
+};

Diff for: data/mutations/dish.js

@@ -0,0 +1,22 @@
+import {GraphQLNonNull, GraphQLString} from 'graphql';
+import {dish as DishModel} from '../models'
+import {dish as DishType} from '../type';
+
+const dishField = {
+    type: DishType,
+    args: {
+        name: {
+            type: new GraphQLNonNull(GraphQLString),
+            description: 'the name of a dish',
+        }
+    },
+    resolve(source, {name}, context, info) {
+        const dish = {
+            id: Math.random().toString(34).slice(2),
+            name
+        };
+        return DishModel(context).set(dish);
+    }
+};
+
+export default dishField;

Diff for: data/mutations/index.js

@@ -0,0 +1,10 @@
+import {GraphQLObjectType,} from 'graphql';
+import dish from './dish';
+
+export default new GraphQLObjectType({
+    name: 'Mutation',
+    description: 'root mutation',
+    fields: {
+        updateDish: dish
+    }
+});

Diff for: data/queries/dish.js

@@ -0,0 +1,11 @@
+import {dish as DishModel} from '../models'
+import {dish as DishType} from '../type';
+
+const dishField = {
+    type: DishType,
+    resolve(source, args, context, info) {
+        return DishModel(context).get();
+    }
+};
+
+export default dishField;

Diff for: data/queries/index.js

@@ -0,0 +1,10 @@
+import {GraphQLObjectType} from 'graphql';
+import dish from './dish';
+
+export default new GraphQLObjectType({
+    name: 'Query',
+    description: 'root query',
+    fields: {
+        dish
+    }
+})

Diff for: data/redis.js

@@ -0,0 +1,5 @@
+import Redis from 'ioredis';
+
+export default new Redis({
+    lazyConnect: true
+});

Diff for: data/schema.js

@@ -0,0 +1,8 @@
+import {GraphQLSchema} from 'graphql';
+import query from './queries';
+import mutation from './mutations';
+
+export default new GraphQLSchema({
+    query,
+    mutation,
+})

Diff for: data/type/dish.js

@@ -0,0 +1,14 @@
+import {GraphQLID, GraphQLNonNull, GraphQLObjectType, GraphQLString} from 'graphql';
+
+export default new GraphQLObjectType({
+    name: 'Dish',
+    description: 'a dish is **delicious** dish',
+    fields: {
+        id: {
+            type: new GraphQLNonNull(GraphQLID),
+        },
+        name: {
+            type: new GraphQLNonNull(GraphQLString),
+        }
+    }
+})

Diff for: data/type/index.js

@@ -0,0 +1,5 @@
+import dish from './dish';
+
+export {
+    dish
+};

Diff for: package.json

@@ -0,0 +1,30 @@
+{
+  "name": "graphql-redis-pubsub-demo",
+  "version": "0.0.1",
+  "main": "index.js",
+  "author": "Jonir Rings <[email protected]>",
+  "license": "MIT",
+  "dependencies": {
+    "express": "^4.16.2",
+    "express-graphql": "^0.6.11",
+    "graphiql": "^0.11.11",
+    "graphql": "^0.11.0",
+    "graphql-redis-subscriptions": "^1.4.0",
+    "graphql-relay": "^0.5.4",
+    "graphql-subscriptions": "^0.5.6",
+    "ioredis": "^3.2.2",
+    "prop-types": "^15.6.0",
+    "react": "^16.2.0",
+    "react-dom": "^16.2.0",
+    "subscriptions-transport-ws": "^0.9.5"
+  },
+  "devDependencies": {
+    "babel-cli": "^6.26.0",
+    "babel-preset-env": "^1.6.1",
+    "debug": "^3.1.0",
+    "morgan": "^1.9.0"
+  },
+  "scripts": {
+    "start": "babel-node ./bin/www"
+  }
+}