feat: create cli tool for adding/removing plugins #351

GluuFederation · Jan 12, 2022 · 9c2e03f · 9c2e03f
1 parent 23ebd1d
commit 9c2e03f
Showing 1 changed file with 15 additions and 17 deletions.
diff --git a/build/plugin-cli.js b/build/plugin-cli.js
@@ -79,63 +79,61 @@ const commands = {
     },
     enablePlugins: function(value) {
       this.createPluginRepo();
-      console.info('Following plugins are enabled.')
-      this.showEnabledPlugins();
       var pluginsArr = value.split('_,');
       try {
         pluginsObj.forEach((ele, index) => {
           if (pluginsArr.indexOf(ele.key) >= 0) {
             ele.enabled = true;
           }
           if (index == (pluginsObj.length-1)) {
-            fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2)) 
+            fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2))
             this.addEnabledPlugins();
           }
         });
       } catch (e) {
         console.error('Error in enabling plugin. Check the plugin keys entered in args.')
       }
-      console.info('Following plugins are enabled now.')
-      this.showEnabledPlugins();
     },
     disablePlugins: function(value) {
       this.createPluginRepo();
-      console.info('Following plugins are enabled.')
-      this.showEnabledPlugins();
       var pluginsArr = value.split('_,');
       try {
         pluginsObj.forEach((ele, index) => {
           if (pluginsArr.indexOf(ele.key) >= 0) {
             ele.enabled = false;
           }
           if (index == (pluginsObj.length-1)) {
-              fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2)) 
+              fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2))
               this.addEnabledPlugins();
           }
         });
       } catch (e) {
         console.error('Error in enabling plugin. Check the plugin keys entered in args.')
       }
-      console.info('Following plugins are enabled now.')
-      this.showEnabledPlugins();
     },
     installPlugin: function(sourcePath) {
       const pluginsRepoPath = dirParamToPath('plugins_repo');
 
       this.createPluginRepo();
-      console.info('Following plugins are enabled.')
-      this.showEnabledPlugins();
       if (!fse.existsSync(sourcePath)) {
+        console.error('Plugin zip not found at %s', sourcePath);
         return;
       }
-      var lastFolder = sourcePath.split('/').filter(function(el) {
+      var lastFolderName = sourcePath.split('/').filter(function(el) {
         return el.trim().length > 0;
       }).pop().split('.').slice(0, -1).join('.');
-      mkdirp.sync(path.join(pluginsRepoPath, lastFolder));
-      fse.createReadStream(sourcePath).pipe(unzipper.Extract({ path: path.join(pluginsRepoPath, lastFolder) }));
 
-      pluginsObj.push(this.createPluginEntry(lastFolder));
-      fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2)) 
+      const pluginPathInRepo = path.join(pluginsRepoPath, lastFolderName);
+      if (fse.existsSync(pluginPathInRepo)) {
+        console.error('Plugin with %s name already present in plugin repo.', lastFolderName);
+        return;
+      }
+
+      mkdirp.sync(pluginPathInRepo);
+      fse.createReadStream(sourcePath).pipe(unzipper.Extract({ path: pluginPathInRepo }));
+
+      pluginsObj.push(this.createPluginEntry(lastFolderName));
+      fse.writeFileSync(path.join(dirParamToPath('rootDir'), 'plugins.config.json'),JSON.stringify(pluginsObj, null, 2))
 
     },
     createPluginEntry: function(pluginKey) {