feat: allow mutations on niorthwind (+ reset data every 30 minutes)

Author: nodkz

examples/northwind/schema.js

@@ -7,7 +7,7 @@
 // import { SchemaComposer } from 'graphql-compose';
 // const schemaComposer = new SchemaComposer();
 
-import { schemaComposer, composeWithRelay, Resolver } from './schemaComposer';
+import { schemaComposer, composeWithRelay } from './schemaComposer';
 import { CategoryTC } from './models/category';
 import { CustomerTC } from './models/customer';
 import { EmployeeTC } from './models/employee';
@@ -16,7 +16,10 @@ import { ProductTC } from './models/product';
 import { RegionTC } from './models/region';
 import { ShipperTC } from './models/shipper';
 import { SupplierTC } from './models/supplier';
-import allowOnlyForLocalhost from './auth/allowOnlyForLocalhost';
+// import { allowOnlyForLocalhost } from './wrappers/allowOnlyForLocalhost';
+import { addQueryToPayload } from './wrappers/addQueryToPayload';
+import { autoResetDataIn30min } from './wrappers/autoResetDataIn30min';
+import seed from './data/seed';
 
 composeWithRelay(schemaComposer.Query);
 
@@ -63,7 +66,8 @@ const fields = {
 ViewerTC.addFields(fields);
 
 schemaComposer.Mutation.addFields({
-  ...allowOnlyForLocalhost({
+  // ...allowOnlyForLocalhost({
+  ...autoResetDataIn30min({
     ...addQueryToPayload({
       createProduct: ProductTC.getResolver('createOne'),
       updateProduct: ProductTC.getResolver('updateById'),
@@ -76,16 +80,15 @@ schemaComposer.Mutation.addFields({
       updateEmployee: EmployeeTC.getResolver('updateById'),
     }),
   }),
+  resetData: {
+    type: 'String',
+    description:
+      'Remove all data and seed DB from scratch. Anyway data automatically reloaded every 30 minutes.',
+    resolve: async () => {
+      await seed();
+      return 'Success';
+    },
+  },
 });
 
-function addQueryToPayload(resolvers: { [name: string]: Resolver<any, any, any> }) {
-  Object.keys(resolvers).forEach((k) => {
-    resolvers[k].getOTC().setField('query', {
-      type: 'Query',
-      resolve: () => ({}),
-    });
-  });
-  return resolvers;
-}
-
 export default schemaComposer.buildSchema();

examples/northwind/wrappers/addQueryToPayload.js

@@ -0,0 +1,13 @@
+/* @flow */
+
+import { Resolver } from '../schemaComposer';
+
+export function addQueryToPayload(resolvers: { [name: string]: Resolver<any, any, any> }) {
+  Object.keys(resolvers).forEach((k) => {
+    resolvers[k].getOTC().setField('query', {
+      type: 'Query',
+      resolve: () => ({}),
+    });
+  });
+  return resolvers;
+}

examples/northwind/auth/allowOnlyForLocalhost.js renamed to examples/northwind/wrappers/allowOnlyForLocalhost.js

@@ -2,9 +2,7 @@
 
 import type { Resolver } from 'graphql-compose';
 
-export default function allowOnlyForLocalhost(resolvers: {
-  [name: string]: Resolver<any, any, any>,
-}) {
+export function allowOnlyForLocalhost(resolvers: { [name: string]: Resolver<any, any, any> }) {
   const secureResolvers = {};
   Object.keys(resolvers).forEach((k) => {
     secureResolvers[k] = resolvers[k].wrapResolve((next) => (rp) => {

examples/northwind/wrappers/autoResetDataIn30min.js

@@ -0,0 +1,19 @@
+/* @flow */
+
+import type { Resolver } from 'graphql-compose';
+import seed from '../data/seed';
+
+let clearDataTimeoutId;
+
+export function autoResetDataIn30min(resolvers: { [name: string]: Resolver<any, any, any> }) {
+  const secureResolvers = {};
+  Object.keys(resolvers).forEach((k) => {
+    secureResolvers[k] = resolvers[k].wrapResolve((next) => (rp) => {
+      if (!clearDataTimeoutId) {
+        clearDataTimeoutId = setTimeout(seed, 1000 * 30 * 60);
+      }
+      return next(rp);
+    });
+  });
+  return secureResolvers;
+}