v1.0

Author: Sergey Dolin

.gitignore

@@ -0,0 +1,3 @@
+.hg
+dist
+node_modules

.hgignore

@@ -0,0 +1,8 @@
+node_modules$
+dist$
+mongodb$
+.*\.swp$
+\.tmp$
+\.DS_Store$
+\.session.vim$
+config\.json$

graphQL/.typeDefs.js.swp

@@ -0,0 +1,68 @@
+const schema = `
+
+interface Node {
+	id: ID!
+}
+
+type PageInfo {
+  hasNextPage: Boolean!
+  hasPreviousPage: Boolean!
+  startCursor: String
+  endCursor: String
+}
+
+type Phone implements Node {
+  id: ID!
+  no: String!
+  name: String!
+}
+
+type PhoneEdge {
+	cursor: String!
+	node: Phone!
+}
+
+type PhoneConnection {
+	pageInfo: PageInfo!
+	edges: [PhoneEdge]!
+}
+
+type Query {
+	phone(id:ID!): Phone
+	phones(after:Int,first:Int,before:Int,last:Int): PhoneConnection!
+}
+
+input SubmitPhoneInput{
+	id: ID!
+	name: String
+	no: String
+	clientMutationId: String!
+}
+
+type SubmitPhonePayload{
+	phone: Phone
+	clientMutationId: String!
+}
+
+input DeleteByIdInput{
+	id: ID!
+	clientMutationId: String!
+}
+
+type DeleteByIdPayload{
+	success: Int!
+	clientMutationId: String!
+}
+
+type Mutation {
+	deletePhone(input:DeleteByIdInput!):DeleteByIdPayload!
+	submitPhone(input:SubmitPhoneInput!):SubmitPhonePayload!
+}
+
+schema {
+    query: Query
+    mutation: Mutation
+  }
+`;
+
+export default schema;

graphQL/typeDefs.js

@@ -0,0 +1,46 @@
+{
+  "name": "phones-gql.devbucket.me",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test:server": "mocha-webpack --require 'babel-core/register' --require babel-polyfill --webpack-config webpack.config-test.js \"test/server/**/*.test.js\"",
+    "nodemon:server": "nodemon dist/server/server.js",
+    "watch-dev-build:server": "webpack --watch --progress --config webpack.config-server.js",
+    "watch:server": "npm-run-all --parallel watch-dev-build:server nodemon:server",
+    "build:server": "webpack --progress --config webpack.config-server.js",
+    "start:server:dev": "forever start -a -l forever.log -o forever.log -e forever.log --spinSleepTime=1000 --workingDir /home/dev/public_html/phones-gql.devbucket.me /home/dev/public_html/phones-gql.devbucket.me/dist/server/server.js",
+    "stop:server:dev": "forever stop /home/dev/public_html/phones-gql.devbucket.me/dist/server/server.js"
+  },
+  "author": "S4Y Solution <android@s4y.solutions>",
+  "license": "ISC",
+  "dependencies": {
+    "apollo-server": "0.3.3",
+    "babel-cli": "6.18.0",
+    "babel-core": "6.18.2",
+    "babel-loader": "6.2.7",
+    "babel-polyfill": "6.16.0",
+    "babel-preset-es2015": "6.18.0",
+    "babel-preset-es2017": "6.16.0",
+    "chai": "3.5.0",
+    "chai-as-promised": "6.0.0",
+    "clean-webpack-plugin": "0.1.14",
+    "graphql": "0.7.2",
+    "graphql-server-koa": "0.4.3",
+    "graphql-subscriptions": "0.2.1",
+    "graphql-tools": "0.8.1",
+    "json-loader": "0.5.4",
+    "kcors": "2.2.0",
+    "koa": "2.0.0-alpha.7",
+    "koa-bodyparser": "3.2.0",
+    "koa-logger": "2.0.0",
+    "koa-router": "7.0.1",
+    "mocha": "3.1.2",
+    "mocha-webpack": "0.7.0",
+    "npm-run-all": "3.1.1",
+    "webpack": "1.13.3",
+    "webpack-merge": "0.15.0",
+    "webpack-node-externals": "1.5.4",
+    "webpack-validator": "2.2.9"
+  }
+}

package.json

@@ -0,0 +1,3 @@
+{
+	"serverPort":"3000"
+}

server/.resolvers.js.swp

@@ -0,0 +1,117 @@
+import {locatedError} from 'graphql/error'; 
+
+let fakes=
+			[
+				{id:0,no:'000000000',name:'Aaaa 0 Aaaaaa'},
+				{id:1,no:'111111110',name:'Bbbb 0 Bbbbbb'},
+				{id:2,no:'222222220',name:'Cccc 0 Cccccc'},
+				{id:3,no:'333333330',name:'Dddd 0 Dddddd'},
+				{id:4,no:'444444440',name:'Eeee 0 Eeeeee'},
+				{id:5,no:'555555550',name:'Ffff 0 Ffffff'},
+	 			{id:6,no:'666666660',name:'Gggg 0 Gggggg'},
+				{id:7,no:'777777770',name:'Hhhh 0 Hhhhhh'},
+				{id:8,no:'888888880',name:'Iiii 0 Iiiiii'},
+				{id:9,no:'999999990',name:'Jjjj 0 Jjjjjj'},
+				{id:10,no:'000000001',name:'Aaaa 1 Aaaaaa'},
+				{id:11,no:'111111111',name:'Bbbb 1 Bbbbbb'},
+				{id:12,no:'222222221',name:'Cccc 1 Cccccc'},
+				{id:13,no:'333333331',name:'Dddd 1 Dddddd'},
+				{id:14,no:'444444441',name:'Eeee 1 Eeeeee'},
+				{id:15,no:'555555551',name:'Ffff 1 Ffffff'},
+				{id:16,no:'666666661',name:'Gggg 1 Gggggg'},
+				{id:17,no:'777777771',name:'Hhhh 1 Hhhhhh'},
+				{id:18,no:'888888881',name:'Iiii 1 Iiiiii'},
+				{id:19,no:'999999991',name:'Jjjj 1 Jjjjjj'},
+				{id:20,no:'000000002',name:'Aaaa 2 Aaaaaa'},
+				{id:21,no:'111111112',name:'Bbbb 2 Bbbbbb'},
+				{id:22,no:'222222222',name:'Cccc 2 Cccccc'},
+				{id:23,no:'333333332',name:'Dddd 2 Dddddd'},
+				{id:24,no:'444444442',name:'Eeee 2 Eeeeee'},
+				{id:25,no:'555555552',name:'Ffff 2 Ffffff'},
+				{id:26,no:'666666662',name:'Gggg 2 Gggggg'},
+				{id:27,no:'777777772',name:'Hhhh 2 Hhhhhh'},
+				{id:28,no:'888888882',name:'Iiii 2 Iiiiii'},
+				{id:29,no:'999999992',name:'Jjjj 2 Jjjjjj'},
+				{id:30,no:'000000003',name:'Aaaa 3 Aaaaaa'},
+				{id:31,no:'111111113',name:'Bbbb 3 Bbbbbb'},
+				{id:32,no:'222222223',name:'Cccc 3 Cccccc'},
+				{id:33,no:'333333333',name:'Dddd 3 Dddddd'},
+				{id:34,no:'444444443',name:'Eeee 3 Eeeeee'},
+				{id:35,no:'555555553',name:'Ffff 3 Ffffff'},
+				{id:36,no:'666666663',name:'Gggg 3 Gggggg'},
+				{id:37,no:'777777773',name:'Hhhh 3 Hhhhhh'},
+				{id:38,no:'888888883',name:'Iiii 3 Iiiiii'},
+				{id:39,no:'999999993',name:'Jjjj 3 Jjjjjj'}
+			];
+export default  {
+	Query: {
+		phone:(root,args,ctx,info)=>{
+			return fakes[args.id];
+		},
+		phones:(root,args,ctx,info)=>{
+			let a=(args.after==undefined||args.after<0)?0:args.after+1;
+			let b=(args.before==undefined||args.before>fakes.length)?fakes.length:args.before;
+
+			if (args.first!=undefined){
+				if (args.first<0)
+					throw new Error('FIRST parameter must not be less than zero');
+				if (a+args.first<b)
+					b=a+args.first;
+				if (args.last!=undefined)
+					throw new Error('FIRST parameter must not be used simultaneously with LAST');
+			}else if (args.last!=undefined){
+				if (args.last<0)
+					throw locatedError(new Error('LAST parameter must not be less than zero'));
+				if (b-args.last>a){
+					a=(b-args.last);
+				}
+			}
+		
+			return {
+				pageInfo:{
+					hasNextPage:b<fakes.length,
+					hasPreviousPage:a>0,
+					startCursor:fakes[a].id,
+					endCursor:fakes[b-1].id
+				},
+				edges:fakes.slice(a,b).map((fake)=>({cursor:fake.id,node:fake}))
+			}
+		},
+	},
+	Mutation: {
+		submitPhone:(root,args)=>{
+			let {id,no,name}=args.input;
+			if (id && id!='add' && id<40){
+				throw locatedError({message:"ID must be above 39"})
+			}
+			let max_id=-1;
+			fakes=fakes.map(v=>{
+				if (v.id==id){
+					max_id=-2; //flag of updated
+					return {id,no,name}
+				}else{
+					if (max_id!=-2 && v.id>max_id) max_id=v.id;
+					return v;
+				}
+			});
+			if (max_id!=-2) { //not update, i.e. new
+				id=max_id+1;
+				fakes.push({id,no,name});
+			}
+			return {phone:{id,no,name},clientMutationId:args.input.clientMutationId};
+		},
+		deletePhone:(root,args)=>{
+			const id=(args.input.id);
+			if (id<40){
+				throw locatedError({message:"ID must be above 39"})
+			}else{
+				const prev=fakes;
+				fakes=fakes.filter(fake=>fake.id!=id);
+				return {
+					success:prev.length>fakes.length,
+					clientMutationId:args.input.clientMutationId
+				}
+			}
+		}
+	}
+}

server/config.json

@@ -0,0 +1,69 @@
+import polyfill from 'babel-polyfill'
+import koa from 'koa';
+import koaRouter from 'koa-router';
+import koaBody from 'koa-bodyparser';
+import logger from 'koa-logger';
+import { apolloKoa,graphiqlKoa } from 'apollo-server';
+import { makeExecutableSchema } from 'graphql-tools';
+import typeDefs from '../graphQL/typeDefs'
+import resolvers from './resolvers'
+import {serverPort} from './config.json'
+import cors from 'kcors';
+
+const executableSchema = makeExecutableSchema({typeDefs,resolvers});
+
+const router = new koaRouter();
+const PORT = serverPort;
+const app = new koa();
+
+app.use(cors());
+
+app.use(koaBody());
+
+app.use(async (ctx, next) => {
+  try {
+    await next(); 
+  } catch (err) {
+    ctx.body = { message: err.message };
+    ctx.status = err.status || 500;
+  }
+});
+
+router.get('/graphiql', graphiqlKoa({
+	endpointURL: '/graphql',
+	query: `query {
+		phones (after:10,first:10) {
+			pageInfo{
+        hasNextPage,
+        hasPreviousPage,
+        startCursor,
+        endCursor
+      },
+      edges{
+        cursor,
+        node{
+          id,
+          no,
+          name
+        }
+      }
+		}
+	}`,
+	debug: true
+}));
+router.post('/graphql', apolloKoa({ schema:  executableSchema }));
+
+app.use(logger())
+	.use(router.routes())
+	.use(router.allowedMethods());
+
+export default app;
+
+(async ()=>{
+	try {
+		await app.listen(PORT);
+		console.log("Server is listening on "+PORT);
+	}catch(error){
+		console.log(error);
+	}
+})()