Merge pull request #115 from vantreeseba/add_create_many

Add create many

Author: fzaninotto

README.md

@@ -108,6 +108,7 @@ type Query {
 }
 type Mutation {
   createPost(data: String): Post
+  createManyPost(data: [{data:String}]): [Post]
   updatePost(data: String): Post
   removePost(id: ID!): Post
 }

src/introspection/getSchemaFromData.js

@@ -4,6 +4,7 @@ import {
     GraphQLList,
     GraphQLNonNull,
     GraphQLObjectType,
+    GraphQLInputObjectType,
     GraphQLSchema,
     GraphQLString,
     parse,
@@ -140,10 +141,34 @@ export default (data) => {
                 {}
             );
             const { id, ...createFields } = typeFields;
+
+            // Build input type.
+            const inputFields = Object.keys(typeFields).reduce(
+                (f, fieldName) => {
+                    f[fieldName] = Object.assign({}, typeFields[fieldName]);
+                    delete f[fieldName].resolve;
+                    return f;
+                },
+                {}
+            );
+
+            const createManyInputType = new GraphQLInputObjectType({
+                name: type.name + 'Input',
+                fields: inputFields,
+            });
+
             fields[`create${type.name}`] = {
                 type: typesByName[type.name],
                 args: createFields,
             };
+            fields[`createMany${type.name}`] = {
+                type: new GraphQLList(typesByName[type.name]),
+                args: {
+                    data: {
+                        type: new GraphQLList(createManyInputType),
+                    },
+                },
+            };
             fields[`update${type.name}`] = {
                 type: typesByName[type.name],
                 args: nullableTypeFields,

src/resolver/Mutation/createMany.js

@@ -0,0 +1,5 @@
+import create from './create';
+
+export default (entityData = []) => (_, entities) => {
+    return entities.data.map((e) => create(entityData)(null, e));
+};

src/resolver/Mutation/createMany.spec.js

@@ -0,0 +1,40 @@
+import createMany from './createMany';
+
+test('returns a new object with id 0 on empty datastore', () => {
+    expect(createMany()(null, { data: [{}] })).toEqual([{ id: 0 }]);
+});
+
+test('returns a new object with incremental id', () => {
+    const data = [{ id: 1 }, { id: 3 }];
+    expect(createMany(data)(null, { data: [{}] })).toEqual([{ id: 4 }]);
+});
+
+test('returns a new object using create data', () => {
+    const data = [{ id: 0, value: 'foo' }];
+    expect(createMany(data)(null, { data: [{ value: 'toto' }] })).toEqual([
+        {
+            id: 1,
+            value: 'toto',
+        },
+    ]);
+});
+
+test('creates a new record', () => {
+    const data = [{ id: 1 }, { id: 3 }];
+    createMany(data)(null, { data: [{ value: 'foo' }] });
+    expect(data).toEqual([{ id: 1 }, { id: 3 }, { id: 4, value: 'foo' }]);
+});
+
+test('creates multiple new records', () => {
+    const data = [{ id: 1 }, { id: 3 }];
+    createMany(data)(null, {
+        data: [{ value: 'foo' }, { value: 'bar' }, { value: 'baz' }],
+    });
+    expect(data).toEqual([
+        { id: 1 },
+        { id: 3 },
+        { id: 4, value: 'foo' },
+        { id: 5, value: 'bar' },
+        { id: 6, value: 'baz' },
+    ]);
+});

src/resolver/index.js

@@ -5,6 +5,7 @@ import all from './Query/all';
 import meta from './Query/meta';
 import single from './Query/single';
 import create from './Mutation/create';
+import createMany from './Mutation/createMany';
 import update from './Mutation/update';
 import remove from './Mutation/remove';
 import entityResolver from './Entity';
@@ -20,6 +21,7 @@ const getQueryResolvers = (entityName, data) => ({
 
 const getMutationResolvers = (entityName, data) => ({
     [`create${entityName}`]: create(data),
+    [`createMany${entityName}`]: createMany(data),
     [`update${entityName}`]: update(data),
     [`remove${entityName}`]: remove(data),
 });