🎉 First version

Author: jysperm

app.js

@@ -0,0 +1,51 @@
+const express = require('express');
+const bodyParser = require('body-parser');
+const {graphql} = require('graphql');
+const expressGraphql = require('express-graphql');
+const AV = require('leanengine');
+const parseLeancloudHeaders = require('leanengine/middleware/parse-leancloud-headers');
+
+const prepareSchema = require('./lib/schema');
+
+const schemaReady = prepareSchema();
+
+const expressGraphqlReady = schemaReady.then( schema => {
+  return expressGraphql({
+    schema: schema,
+    graphiql: true,
+  });
+});
+
+const app = express();
+
+app.use(AV.express());
+
+app.use('/graphql', (req, res, next) => {
+  expressGraphqlReady.done( expressGraphqlMiddleware => {
+    expressGraphqlMiddleware(req, res, next);
+  });
+});
+
+app.use(parseLeancloudHeaders(AV, {restrict: false}));
+
+app.use(bodyParser.text({
+  type: 'application/graphql'
+}));
+
+app.get('/', (req, res) => {
+  res.redirect('/graphql');
+})
+
+app.post('/', (req, res) => {
+  schemaReady.done( schema => {
+    return graphql(schema, req.body, {}, {
+      authOptions: {
+        sessionToken: req.sessionToken,
+      }
+    }).then( result => {
+      res.json(result);
+    });
+  });
+});
+
+module.exports = app;

lib/schema.js

@@ -0,0 +1,71 @@
+const request = require('request-promise');
+const {GraphQLSchema, GraphQLObjectType, GraphQLString, GraphQLList, GraphQLFloat, GraphQLBoolean, GraphQLInt} = require('graphql');
+const _ = require('lodash');
+const AV = require('leanengine');
+
+const appId = process.env.LEANCLOUD_APP_ID;
+const appKey = process.env.LEANCLOUD_APP_KEY;
+const masterKey = process.env.LEANCLOUD_APP_MASTER_KEY;
+
+const LCTypeMapping = {
+  String: GraphQLString,
+  Number: GraphQLFloat,
+  Boolean: GraphQLBoolean,
+
+  // TODO
+  Object: GraphQLString,
+  Array: GraphQLString,
+  Date: GraphQLString,
+  Relation: GraphQLString,
+  Pointer: GraphQLString
+}
+
+module.exports = function prepareSchema() {
+  return request({
+    url: 'https://api.leancloud.cn/1.1/schemas',
+    json: true,
+    headers: {
+      'X-LC-Id': appId,
+      'X-LC-Key': `${masterKey},master`
+    }
+  }).then( cloudSchemas => {
+    return new GraphQLSchema({
+      query: new GraphQLObjectType({
+        name: 'LeanStorage',
+        fields: _.mapValues(cloudSchemas, (schema, className) => {
+          return {
+            name: className,
+            type: new GraphQLList(new GraphQLObjectType({
+              name: className,
+              fields: _.mapValues(schema, (definition, field) => {
+                return {
+                  type: LCTypeMapping[definition.type],
+                  resolve: (source, args, context, info) => {
+                    return source.get(field);
+                  }
+                }
+              })
+            })),
+            args: {
+              ascending: {
+                type: GraphQLString
+              },
+              descending: {
+                type: GraphQLString
+              },
+              limit: {
+                type: GraphQLInt
+              },
+              skip: {
+                type: GraphQLInt
+              }
+            },
+            resolve: (source, args, {authOptions}, info) => {
+              return new AV.Query(className).find(authOptions);
+            }
+          };
+        })
+      })
+    });
+  });
+};

package.json

@@ -0,0 +1,20 @@
+{
+  "name": "leancloud-graphql",
+  "version": "0.1.0",
+  "description": "Third party GraphQL support for LeanCloud, running on LeanEngine",
+  "engines": {
+    "node": "6.x"
+  },
+  "dependencies": {
+    "body-parser": "^1.15.2",
+    "express": "^4.14.0",
+    "express-graphql": "^0.6.1",
+    "graphql": "^0.8.2",
+    "leanengine": "^1.2.3",
+    "lodash": "^4.17.2",
+    "request": "^2.79.0",
+    "request-promise": "^4.1.1"
+  },
+  "license": "MIT",
+  "devDependencies": {}
+}

server.js

@@ -0,0 +1,16 @@
+const AV = require('leanengine');
+
+AV.init({
+  appId: process.env.LEANCLOUD_APP_ID,
+  appKey: process.env.LEANCLOUD_APP_KEY,
+  masterKey: process.env.LEANCLOUD_APP_MASTER_KEY
+});
+
+AV.Cloud.useMasterKey();
+
+const app = require('./app');
+const port = process.env.LEANCLOUD_APP_PORT || 3000;
+
+app.listen(port, () => {
+  console.log('SniperaaS is started on', port);
+});