Dynamically generate GraphQL resolvers

Author: platform-kit

lib/apiSpec.js

@@ -1,17 +1,16 @@
-var fs = require('fs')
-
-var apiSchema = fs.readFileSync('./app/prisma/api-schema/api-schema.json', { encoding: 'utf8', flag: 'r' })
-apiSchema = JSON.parse(apiSchema);
-var schemas = Object.entries(apiSchema.schemas)
+var fs = require('fs');
 
 function getGraphQLSchemas() {
+    var apiSchema = fs.readFileSync('./app/api-schema.json', { encoding: 'utf8', flag: 'r' })
+    apiSchema = JSON.parse(apiSchema);
+    var schemas = Object.entries(apiSchema.schemas)
     var types = [];
     for (const [key, value] of Object.entries(schemas)) {
         var type = value[0];
         var endpoints = Object.entries(value[1]);
         for (const [endpointKey, endpointValue] of endpoints) {
             if (endpointValue != null && endpointValue['input_validation_rules'] != null) {
-                rules = Object.entries(endpointValue['input_validation_rules']);
+                var rules = Object.entries(endpointValue['input_validation_rules']);
                 var startLine = ` type ` + type + ` {`
                 var fieldLines = {};
                 for (const [fieldName, rulesValue] of rules) {
@@ -55,12 +54,12 @@ function getGraphQLSchemas() {
     `;
     schemas = Object.entries(apiSchema.schemas);
     for (const [key, value] of schemas) {
-        queryString = queryString + '   ' + key + ': [' + key + ']\n';        
+        queryString = queryString + '   ' + key + ': [' + key + ']\n';
     }
     queryString = queryString + `
     }`;
     string = string + queryString;
-    
+
     return string;
 
     // GraphQL Schema String example:
@@ -84,6 +83,32 @@ function getGraphQLSchemas() {
     */
 }
 
+function getGraphQLResolvers() {
+    var apiSchema = fs.readFileSync('./app/api-schema.json', { encoding: 'utf8', flag: 'r' })
+    apiSchema = JSON.parse(apiSchema);
+    var schemas = Object.entries(apiSchema.schemas)
+    var types = [];
+    var resolvers = {};
+    for (const [key, value] of Object.entries(schemas)) {                
+        const { Resource } = require('../models/resource');
+        var resource = new Resource(value[0]).browse();        
+        resolvers[value[0]] = () => resource;
+    }
+
+    return resolvers;
+
+    /*
+    // Result should produce an object that looks like this:
+    var resolvers = 
+    {
+        Query: {
+            'analytic_events': () =>  data.browse()         
+        },
+    };
+    */
+}
+
 module.exports = {
-    getGraphQLSchemas
+    getGraphQLSchemas,
+    getGraphQLResolvers
 }

models/resource.ts

@@ -56,7 +56,7 @@ export class Resource {
     }
 
     async add(data: any) {
-        var apiSchema = fs.readFileSync('./prisma/api-schema/api-schema.json', { encoding: 'utf8', flag: 'r' })
+        var apiSchema = fs.readFileSync('./app/api-schema.json', { encoding: 'utf8', flag: 'r' })
         apiSchema = JSON.parse(apiSchema)
         var validationRules = apiSchema.schemas?.[this.pluralizeType()]?.['add']?.['input_validation_rules']
         console.log(validationRules)
@@ -83,7 +83,7 @@ export class Resource {
     }
 
     async edit(id: Number, data: any) {
-        var apiSchema = fs.readFileSync('./prisma/api-schema/api-schema.json', { encoding: 'utf8', flag: 'r' })
+        var apiSchema = fs.readFileSync('./app/api-schema.json', { encoding: 'utf8', flag: 'r' })
         apiSchema = JSON.parse(apiSchema)
         var validationRules = apiSchema.schemas?.[this.pluralizeType()]?.['edit']?.['input_validation_rules']
         console.log(validationRules)
@@ -129,5 +129,4 @@ export class Resource {
     }
 
 
-}
-
+}

src/index.ts

@@ -36,19 +36,18 @@ if (process.env.PUBLIC_DIRECTORY != null) {
 if (Boolean(process.env.ENABLE_GRAPHQL) != false) {
 
   var gqlSchema = ApiSpec.getGraphQLSchemas()
-  console.log(gqlSchema)
+  // console.log(gqlSchema)
 
   const typeDefs = gqlSchema
 
-var users = new Resource('user');
+  //var data = new Resource('analytic_events');
+  console.log(ApiSpec.getGraphQLResolvers())
+  var generatedResolvers = ApiSpec.getGraphQLResolvers();
 
   // Resolvers define the technique for fetching the types defined in the
   // schema. This resolver retrieves books from the "books" array above.
   const resolvers = {
-    Query: {
-      users: () =>  users.browse()
-      ,
-    },
+    Query: generatedResolvers,
   };
   const server = new ApolloServer({
     typeDefs,
@@ -60,8 +59,8 @@ var users = new Resource('user');
 
 // Rest API Schema
 app.get('/api', function (req, res) {
-  var jsonSchema = fs.readFileSync('./app/prisma/json-schema/json-schema.json', { encoding: 'utf8', flag: 'r' })
-  var apiSchema = fs.readFileSync('./app/prisma/api-schema/api-schema.json', { encoding: 'utf8', flag: 'r' })
+  var jsonSchema = fs.readFileSync('./app/json-schema.json', { encoding: 'utf8', flag: 'r' })
+  var apiSchema = fs.readFileSync('./app/api-schema.json', { encoding: 'utf8', flag: 'r' })
   apiSchema = JSON.parse(apiSchema)
   var output = {
     apiSchema: apiSchema

tsconfig.json

@@ -5,5 +5,6 @@
     "strict": true,
     "lib": ["esnext"],
     "esModuleInterop": true,    
+    "allowJs": true
   }
 }