feat: generating clients/servers from remote template providers

Author: MikeRalphson

cg.js

@@ -12,6 +12,8 @@ const fetch = require('node-fetch');
 const co = require('co');
 const swagger2openapi = require('swagger2openapi');
 const stools = require('swagger-tools');
+const mkdirp = require('mkdirp');
+const rimraf = require('rimraf');
 const admzip = require('adm-zip');
 
 const processor = require('./local.js');
@@ -66,7 +68,7 @@ let remoteConfig = configName.indexOf(':')>-1;
 let configPath = path.dirname(configStr);
 if (!configPath || (configPath === '.')) configPath = './configs';
 let configFile = path.resolve(configPath,configName)+'.json';
-let config = require(configFile);
+let config = remoteConfig ? { defaults: {} } : require(configFile);
 let defName = argv._[1] || './defs/petstore3.json';
 
 let finish = remoteConfig ? finishRemote : finishLocal;
@@ -102,12 +104,26 @@ function finishLocal(err,result) {
 }
 
 function finishRemote(err,result) {
-    if (argv.zip) {
-        // just save the zip file
-    }
-    else {
-        // unpack the zip file
-    }
+   configName = configName.split(':').pop();
+   if (argv.verbose) console.log('Making/cleaning output directories');
+   mkdirp(path.join(config.outputDir,configName),function(){
+       rimraf(path.join(config.outputDir,configName)+'/*',function(){
+           if (argv.zip) {
+              fs.writeFileSync(path.join(config.outputDir,configName,configName+'.zip'),result);
+           }
+           else {
+               const zip = new admzip(result);
+               if (argv.verbose) {
+                   console.log('Unzipping...');
+                   const zipEntries = zip.getEntries(); // an array of ZipEntry records
+                   zipEntries.forEach(function(zipEntry) {
+                       console.log(zipEntry.entryName);
+                   });
+                }
+                zip.extractAllTo(config.outputDir,true);
+            }
+        });
+    });
 }
 
 function despatch(obj, config, configName, callback) {

remote.js

@@ -4,7 +4,40 @@
 const fetch = require('node-fetch');
 const util = require('util');
 
-function main(obj, config, configName, callback) {
+function getServer(prefix) {
+    if (prefix === 'og') {
+        return 'https://api.openapi-generator.tech/api/gen/';
+    }
+    else if (prefix === 'sc') {
+        return 'https://generator.swagger.io/api/gen/';
+    }
+    console.warn('Unknown API provider prefix',prefix);
+    return false;
+}
+
+async function main(obj, config, configName, callback) {
+    const components = configName.split(':');
+    const prefix = components[0];
+    const type = components[1];
+    const template = components[2];
+    const server = getServer(prefix);
+    const body = { options: {}, spec: obj };
+    const response = await fetch(server+type+'s/'+template, {
+        method: 'post',
+        body:    JSON.stringify(body),
+        headers: { 'Content-Type': 'application/json' }
+    })
+    .then(res => res.json())
+    .then(json => json);
+    if (response.link) {
+        const zipfile = await fetch(response.link)
+        .then(res => res.buffer())
+        .then(buffer => buffer);
+        callback(null, zipfile);
+    }
+    else {
+        console.warn(util.inspect(response));
+    }
 }
 
 function format(templates, prefix, type, filter) {
@@ -29,20 +62,13 @@ async function slurp(server, prefix, type, plural, filter) {
 }
 
 async function list(prefix, filter) {
-    let server = '';
-    if (prefix === 'og') {
-       server = 'https://api.openapi-generator.tech/api/gen/';
-    }
-    else if (prefix === 'sc') {
-        server = 'https://generator.swagger.io/api/gen/';
-    }
-    else {
-        console.warn('Unknown API provider prefix',prefix);
-        return 1;
+    const server = getServer(prefix);
+    if (server) {
+        await slurp(server, prefix, 'client', 'clients', filter);
+        await slurp(server, prefix, 'server', 'servers', filter);
+        return 0;
     }
-    await slurp(server, prefix, 'client', 'clients', filter);
-    await slurp(server, prefix, 'server', 'servers', filter);
-    return 0;
+    return 1;
 }
 
 module.exports = {