Solve caching issue

Author: benjie

createLink.js

@@ -1,7 +1,7 @@
-const { createPostGraphileSchema } = require('postgraphile')
+const { createPostGraphileSchema } = require("postgraphile");
 
 function requireFrom(modules, moduleName) {
-  const path = [...modules, moduleName].join('/node_modules/')
+  const path = [...modules, moduleName].join("/node_modules/");
   try {
     return require(path); // eslint-disable-line
   } catch (e) {
@@ -10,46 +10,40 @@ function requireFrom(modules, moduleName) {
       const result = requireFrom(
         modules.slice(0, modules.length - 1),
         moduleName
-      )
-      if (result) return result
+      );
+      if (result) return result;
     }
     return (
       requireFrom(modules.slice(1), moduleName) ||
       requireFrom(modules.slice(0, modules.length - 1), moduleName)
-    )
+    );
   }
 }
 const graphileBuild = requireFrom(
-  ['postgraphile', 'postgraphile-core'],
-  'graphile-build'
-)
-/*
-const graphileBuildPg = requireFrom(
-  ['postgraphile', 'postgraphile-core'],
-  'postgraphile/node_modules/graphile-build-pg'
-)
-*/
+  ["postgraphile", "postgraphile-core"],
+  "graphile-build"
+);
 
-const RenamedQueryPlugin = require('./RenamedQueryPlugin')
+const RenamedQueryPlugin = require("./RenamedQueryPlugin");
 
 const skipPlugins = [
   graphileBuild.QueryPlugin,
   graphileBuild.MutationPlugin,
   graphileBuild.SubscriptionPlugin,
-]
-const prependPlugins = [RenamedQueryPlugin]
+];
+const prependPlugins = [RenamedQueryPlugin];
 
 module.exports = async (pool, schema, options) => {
-  const schemas = Array.isArray(schema) ? schema : schema.split(',')
+  const schemas = Array.isArray(schema) ? schema : schema.split(",");
   const graphqlSchema = await createPostGraphileSchema(pool, schemas, {
-    simpleCollections: 'both',
+    simpleCollections: "both",
     dynamicJson: true,
     showErrorStack: true,
-    extendedErrors: ['hint', 'detail', 'errcode'],
-    legacyRelations: 'omit',
+    extendedErrors: ["hint", "detail", "errcode"],
+    legacyRelations: "omit",
     ...options,
     skipPlugins: [...skipPlugins, ...(options.skipPlugins || [])],
     prependPlugins: [...prependPlugins, ...(options.prependPlugins || [])],
-  })
-  return graphqlSchema
-}
+  });
+  return graphqlSchema;
+};

createSchema.js

@@ -1,14 +1,24 @@
 const gatsbySourceGraphQLNode = require("gatsby-source-graphql/gatsby-node");
+const { Pool } = require("pg");
 
-const createLink = require("./createLink");
+const createSchema = require("./createSchema");
+const PostGraphileLink = require("./PostGraphileLink");
 
 exports.sourceNodes = async (
   utils,
   { typeName = "PostGraphile", fieldName = "postgres", ...options }
 ) => {
+  const { connectionString, schema: postgresSchema, ...rest } = options;
+
+  const pool = new Pool({
+    connectionString,
+  });
+  const graphqlSchema = await createSchema(pool, postgresSchema, rest);
+
   await gatsbySourceGraphQLNode.sourceNodes(utils, {
     typeName,
     fieldName,
-    createLink: () => createLink(options),
+    createLink: () => new PostGraphileLink({ pool, schema: graphqlSchema }),
+    createSchema: () => graphqlSchema,
   });
 };

gatsby-node.js

@@ -8,7 +8,7 @@ module.exports = async function performQuery(
   variables,
   operationName
 ) {
-  const queryString = typeof query === 'string' ? query : print(query);
+  const queryString = typeof query === "string" ? query : print(query);
   return withPostGraphileContext({ pgPool }, async context =>
     graphql(
       schema, // The schema from `createPostGraphileSchema`