finished flow covering

Author: Krivtsov

.babelrc

@@ -1,4 +1,4 @@
 {
   "presets": ["es2015", "stage-0"],
-  "plugins": ["add-module-exports"]
+  "plugins": ["add-module-exports", "syntax-flow", "transform-flow-strip-types"]
 }

README.md

@@ -5,7 +5,9 @@ It allows you to move your API to GraphQL with nearly zero afford and maintain b
 
 <a href="https://medium.com/@raxwunter/moving-existing-api-from-rest-to-graphql-205bab22c184">Why?</a>
 
-## Usage
+# Usage
+
+## Basic server
 
 ```js
 const express = require('express');
@@ -32,3 +34,22 @@ graphQLSchema('./petstore.json').then(schema => {
   throw e;
 });
 ```
+
+## CLI convertion
+
+```
+npm i -g swagger-to-graphql
+swagger-to-graphql --swagger=/path/to/swagger_schema.json > ./types.graphql
+```
+## Authorization
+
+```
+ ...
+  context: {
+    GQLProxyBaseUrl: API_BASE_URL,
+    BearerToken: req.get('authorization')
+  },
+ ...
+```
+
+<a href="https://github.com/yarax/swagger-to-graphql/blob/master/src/types.js#L3"> All context options </a>

lib/index.js

@@ -1,6 +1,6 @@
 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
   value: true
 });
 
@@ -16,9 +16,8 @@ var _typeMap = require('./typeMap');
 
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step('next', value); }, function (err) { step('throw', err); }); } } return step('next'); }); }; }
+function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; }
 
-// @flow
 require('babel-polyfill');
 
 
@@ -62,30 +61,28 @@ var schemaFromEndpoints = function schemaFromEndpoints(endpoints) {
 };
 
 var resolver = function resolver(endpoint) {
-  return (function () {
+  return function () {
     var _ref = _asyncToGenerator(regeneratorRuntime.mark(function _callee(_, args, opts) {
       var req, res;
       return regeneratorRuntime.wrap(function _callee$(_context) {
         while (1) {
           switch (_context.prev = _context.next) {
-          case 0:
-            req = endpoint.request(args, {
-              baseUrl: opts.GQLProxyBaseUrl
-            });
+            case 0:
+              req = endpoint.request(args, opts.GQLProxyBaseUrl);
 
-            if (opts.BearerToken) {
-              req.headers.Authorization = opts.BearerToken;
-            }
-            _context.next = 4;
-            return (0, _requestPromise2.default)(req);
+              if (opts.BearerToken) {
+                req.headers.Authorization = opts.BearerToken;
+              }
+              _context.next = 4;
+              return (0, _requestPromise2.default)(req);
 
-          case 4:
-            res = _context.sent;
-            return _context.abrupt('return', JSON.parse(res));
+            case 4:
+              res = _context.sent;
+              return _context.abrupt('return', JSON.parse(res));
 
-          case 6:
-          case 'end':
-            return _context.stop();
+            case 6:
+            case 'end':
+              return _context.stop();
           }
         }
       }, _callee, undefined);
@@ -94,44 +91,45 @@ var resolver = function resolver(endpoint) {
     return function (_x, _x2, _x3) {
       return _ref.apply(this, arguments);
     };
-  }());
+  }();
 };
 
 var getQueriesFields = function getQueriesFields(endpoints, isMutation) {
   return Object.keys(endpoints).filter(function (typeName) {
     return !!endpoints[typeName].mutation === !!isMutation;
   }).reduce(function (result, typeName) {
     var endpoint = endpoints[typeName];
-    var type = (0, _typeMap.createGQLObject)(endpoint.response, typeName, endpoint.location);
-    result[typeName] = {
+    var type = (0, _typeMap.createGQLObject)(endpoint.response, typeName, false);
+    var gType = {
       type: type,
       description: endpoint.description,
-      args: (0, _typeMap.mapParametersToFields)(endpoint.parameters, endpoint.location, typeName),
+      args: (0, _typeMap.mapParametersToFields)(endpoint.parameters, typeName),
       resolve: resolver(endpoint)
     };
+    result[typeName] = gType;
     return result;
   }, {});
 };
 
-var build = (function () {
+var build = function () {
   var _ref2 = _asyncToGenerator(regeneratorRuntime.mark(function _callee2(swaggerPath) {
     var swaggerSchema, endpoints, schema;
     return regeneratorRuntime.wrap(function _callee2$(_context2) {
       while (1) {
         switch (_context2.prev = _context2.next) {
-        case 0:
-          _context2.next = 2;
-          return (0, _swagger.loadSchema)(swaggerPath);
-
-        case 2:
-          swaggerSchema = _context2.sent;
-          endpoints = (0, _swagger.getAllEndPoints)(swaggerSchema);
-          schema = schemaFromEndpoints(endpoints);
-          return _context2.abrupt('return', schema);
-
-        case 6:
-        case 'end':
-          return _context2.stop();
+          case 0:
+            _context2.next = 2;
+            return (0, _swagger.loadSchema)(swaggerPath);
+
+          case 2:
+            swaggerSchema = _context2.sent;
+            endpoints = (0, _swagger.getAllEndPoints)(swaggerSchema);
+            schema = schemaFromEndpoints(endpoints);
+            return _context2.abrupt('return', schema);
+
+          case 6:
+          case 'end':
+            return _context2.stop();
         }
       }
     }, _callee2, undefined);
@@ -140,7 +138,7 @@ var build = (function () {
   return function build(_x4) {
     return _ref2.apply(this, arguments);
   };
-}());
+}();
 
 exports.default = build;
-module.exports = exports.default;
+module.exports = exports['default'];

lib/swagger.js

@@ -1,6 +1,6 @@
 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
   value: true
 });
 exports.getAllEndPoints = exports.loadSchema = exports.getSchema = undefined;
@@ -15,10 +15,7 @@ var _nodeRequestBySwagger2 = _interopRequireDefault(_nodeRequestBySwagger);
 
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-// @flow
-
 var __schema = void 0;
-
 var getSchema = exports.getSchema = function getSchema() {
   if (!__schema || !Object.keys(__schema).length) {
     throw new Error('Schema was not loaded');
@@ -56,7 +53,6 @@ var replaceOddChars = function replaceOddChars(str) {
 
 /**
  * Going throw schema and grab routes
- * @returns Promise<T>
  */
 var getAllEndPoints = exports.getAllEndPoints = function getAllEndPoints(schema) {
   var allTypes = {};
@@ -70,12 +66,12 @@ var getAllEndPoints = exports.getAllEndPoints = function getAllEndPoints(schema)
         var type = param.type;
         return { name: replaceOddChars(param.name), type: type, jsonSchema: param };
       }) : [];
-      allTypes[typeName] = {
+      var endpoint = {
         parameters: parameters,
         description: obj.description,
         response: getSuccessResponse(obj.responses),
-        request: function request(args, server) {
-          var url = '' + server.baseUrl + path;
+        request: function request(args, baseUrl) {
+          var url = '' + baseUrl + path;
           return (0, _nodeRequestBySwagger2.default)(obj, {
             request: args,
             url: url,
@@ -84,6 +80,7 @@ var getAllEndPoints = exports.getAllEndPoints = function getAllEndPoints(schema)
         },
         mutation: isMutation
       };
+      allTypes[typeName] = endpoint;
     });
   });
   return allTypes;

lib/typeMap.js

@@ -1,6 +1,6 @@
 'use strict';
 
-Object.defineProperty(exports, '__esModule', {
+Object.defineProperty(exports, "__esModule", {
   value: true
 });
 exports.mapParametersToFields = exports.getTypeFields = exports.createGQLObject = undefined;
@@ -15,13 +15,11 @@ var graphql = _interopRequireWildcard(_graphql);
 
 var _swagger = require('./swagger');
 
-var _swagger2 = _interopRequireDefault(_swagger);
-
-function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; }  var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj;  }
+function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) newObj[key] = obj[key]; } } newObj.default = obj; return newObj; } }
 
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
-var __allTypes = {}; // @flow
+var __allTypes = {};
 
 var primitiveTypes = {
   string: graphql.GraphQLString,
@@ -42,13 +40,13 @@ var getTypeNameFromRef = function getTypeNameFromRef(ref) {
 
 var getExistingType = function getExistingType(ref, isInputType) {
   var typeName = getTypeNameFromRef(ref);
-  var allSchema = _swagger2.default.getSchema();
+  var allSchema = (0, _swagger.getSchema)();
   if (!__allTypes[typeName]) {
     var schema = allSchema.definitions[typeName];
     if (!schema) {
       throw new Error('Definition ' + typeName + ' was not found in schema');
     }
-    __allTypes[typeName] = createGQLObject(schema, typeName, ref, isInputType);
+    __allTypes[typeName] = createGQLObject(schema, typeName, isInputType);
   }
   return __allTypes[typeName];
 };
@@ -59,9 +57,11 @@ var getRefProp = function getRefProp(jsonSchema) {
 
 var createGQLObject = exports.createGQLObject = function createGQLObject(jsonSchema, title, isInputType) {
   if (!jsonSchema) {
-    jsonSchema = {
+    jsonSchema = { // eslint-disable-line no-param-reassign
       type: 'object',
-      properties: {}
+      properties: {},
+      description: '',
+      title: ''
     };
   }
 
@@ -78,14 +78,20 @@ var createGQLObject = exports.createGQLObject = function createGQLObject(jsonSch
     return new graphql.GraphQLList(getPrimitiveTypes(jsonSchema.items));
   }
 
-  title = title || jsonSchema.title;
-
-  var objectType = isInputType ? 'GraphQLInputObjectType' : 'GraphQLObjectType';
-
-  return new graphql[objectType]({
+  title = title || jsonSchema.title; // eslint-disable-line no-param-reassign
+  var description = jsonSchema.description;
+  var fields = getTypeFields(jsonSchema, title, isInputType);
+  if (isInputType) {
+    return new graphql.GraphQLInputObjectType({
+      name: title,
+      description: description,
+      fields: fields
+    });
+  }
+  return new graphql.GraphQLObjectType({
     name: title,
-    description: jsonSchema.description,
-    fields: getTypeFields(jsonSchema, title, isInputType)
+    description: description,
+    fields: fields
   });
 };
 
@@ -128,7 +134,7 @@ var getPrimitiveTypes = function getPrimitiveTypes(jsonSchema) {
   return type;
 };
 
-var mapParametersToFields = exports.mapParametersToFields = function mapParametersToFields(parameters, endpointLocation, typeName) {
+var mapParametersToFields = exports.mapParametersToFields = function mapParametersToFields(parameters, typeName) {
   return parameters.reduce(function (res, param) {
     var type = jsonSchemaTypeToGraphQL('param_' + typeName, param.jsonSchema, param.name, true);
     res[param.name] = {

lib/types.js

@@ -0,0 +1 @@
+'use strict';

package.json

@@ -20,6 +20,8 @@
     "babel-core": "^6.24.1",
     "babel-eslint": "^7.2.3",
     "babel-plugin-add-module-exports": "^0.2.1",
+    "babel-plugin-syntax-flow": "^6.18.0",
+    "babel-plugin-transform-flow-strip-types": "^6.22.0",
     "babel-preset-es2015": "^6.24.1",
     "babel-preset-stage-0": "^6.24.1",
     "eslint": "^3.19.0",

src/index.js

@@ -1,6 +1,6 @@
 // @flow
 require('babel-polyfill');
-import type {GraphQLParameters, Endpoint, GraphQLType} from './types';
+import type {GraphQLParameters, Endpoint, GraphQLType, RootGraphQLSchema, SwaggerToGraphQLOptions} from './types';
 import rp from 'request-promise';
 import { GraphQLSchema, GraphQLObjectType } from 'graphql';
 import { getAllEndPoints, loadSchema } from './swagger';
@@ -28,7 +28,7 @@ const schemaFromEndpoints = (endpoints: Endpoints) => {
     })
   });
 
-  const graphQLSchema = {
+  const graphQLSchema: RootGraphQLSchema = {
     query: rootType
   };
 
@@ -44,7 +44,7 @@ const schemaFromEndpoints = (endpoints: Endpoints) => {
 };
 
 const resolver = (endpoint: Endpoint) =>
-  async (_, args: GraphQLParameters, opts) => {
+  async (_, args: GraphQLParameters, opts: SwaggerToGraphQLOptions) => {
     const req = endpoint.request(args, opts.GQLProxyBaseUrl);
     if (opts.BearerToken) {
       req.headers.Authorization = opts.BearerToken;
@@ -58,7 +58,7 @@ const getQueriesFields = (endpoints: Endpoints, isMutation: boolean): {[string]:
     return !!endpoints[typeName].mutation === !!isMutation;
   }).reduce((result, typeName) => {
     const endpoint = endpoints[typeName];
-    const type = createGQLObject(endpoint.response, typeName, endpoint.location);
+    const type = createGQLObject(endpoint.response, typeName, false);
     const gType: GraphQLType = {
       type,
       description: endpoint.description,