From 2535d769094356c3ee05332f904446df94efe051 Mon Sep 17 00:00:00 2001
From: Boaz Poolman <boaz_skater@hotmail.com>
Date: Fri, 19 Mar 2021 21:50:23 +0100
Subject: [PATCH] Initial import/export backend

---
 config/config.json    |  4 ++++
 config/routes.json    | 12 ++++++++++--
 controllers/config.js | 35 ++++++++++++++++++++++++++++++----
 services/config.js    | 44 +++++++++++++++++++++++++++++++++++++++++++
 4 files changed, 89 insertions(+), 6 deletions(-)
 create mode 100644 config/config.json

diff --git a/config/config.json b/config/config.json
new file mode 100644
index 0000000..1adb4eb
--- /dev/null
+++ b/config/config.json
@@ -0,0 +1,4 @@
+{
+  "destination": "extensions/config/files/",
+  "exclude": []
+}
diff --git a/config/routes.json b/config/routes.json
index 6a09017..430a8e8 100644
--- a/config/routes.json
+++ b/config/routes.json
@@ -2,8 +2,16 @@
   "routes": [
     {
       "method": "GET",
-      "path": "/",
-      "handler": "config.index",
+      "path": "/export",
+      "handler": "config.export",
+      "config": {
+        "policies": []
+      }
+    },
+    {
+      "method": "GET",
+      "path": "/import",
+      "handler": "config.import",
       "config": {
         "policies": []
       }
diff --git a/controllers/config.js b/controllers/config.js
index b4afee2..d9d5c61 100644
--- a/controllers/config.js
+++ b/controllers/config.js
@@ -1,5 +1,7 @@
 'use strict';
 
+const fs = require('fs');
+
 /**
  * config.js controller
  *
@@ -14,12 +16,37 @@ module.exports = {
    * @return {Object}
    */
 
-  index: async (ctx) => {
-    // Add your own logic here.
+  export: async (ctx) => {
+    const coreStoreAPI = strapi.query('core_store');
+    const coreStore = await coreStoreAPI.find({ _limit: -1 });
+
+    Object.values(coreStore).map(async ({ key, value }) => {
+      await strapi.plugins.config.services.config.writeConfigFile(key, value);
+    });
 
-    // Send 200 `ok`
     ctx.send({
-      message: 'ok'
+      message: `Config was successfully exported to ${strapi.plugins.config.config.destination}.`
+    });
+  },
+
+  import: async (ctx) => {
+    // Check for existance of the config file destination dir.
+    if (!fs.existsSync(strapi.plugins.config.config.destination)) {
+      ctx.send({
+        message: 'No config files were found.'
+      });
+
+      return;
+    }
+    
+    const configFiles = fs.readdirSync(strapi.plugins.config.config.destination);
+
+    configFiles.map((file) => {
+      strapi.plugins.config.services.config.importFromFile(file.slice(0, -5));
+    });
+
+    ctx.send({
+      message: 'Config was successfully imported.'
     });
   }
 };
diff --git a/services/config.js b/services/config.js
index c992ee6..e8ed75a 100644
--- a/services/config.js
+++ b/services/config.js
@@ -1,5 +1,8 @@
 'use strict';
 
+const fs = require('fs');
+const util = require('util');
+
 /**
  * config.js service
  *
@@ -7,5 +10,46 @@
  */
 
 module.exports = {
+  writeConfigFile: async (configName, fileContents) => {
+    await strapi.fs.writePluginFile(
+      'config',
+      `files/${configName}.json`,
+      fileContents
+    );
+  },
 
+  readConfigFile: async (configName) => {
+    const readFile = util.promisify(fs.readFile);
+    return await readFile(`${strapi.plugins.config.config.destination}${configName}.json`)
+      .then((data) => {
+        return JSON.parse(data);
+      })
+      .catch(() => {
+        return null;
+      });
+  },
+
+  importFromFile: async (configName) => {
+    const coreStoreAPI = strapi.query('core_store');
+    const fileContents = await strapi.plugins.config.services.config.readConfigFile(configName);
+
+    // If there is no corresponding config file we should not try to import.
+    if (!fileContents) return;
+
+    try {
+      const configExists = await strapi
+      .query('core_store')
+      .findOne({ key: configName });
+
+      if (!configExists) {
+        await coreStoreAPI.create({ key: configName, value: fileContents });
+      } else {
+        await coreStoreAPI.update({ key: configName }, { value: fileContents });
+      }
+
+      return { success: true };
+    } catch (err) {
+      throw new Error(err);
+    }
+  }
 };