1 files changed, 1 insertions, 70 deletions

diff --git a/index.js b/index.js
index 5a3ad9e..2d8f5ba 100644
--- a/index.js
+++ b/index.js
@@ -1,8 +1,6 @@
 require('dotenv').config();
 const path = require('path');
 const chalk = require('chalk');
-const npm = require('npm');
-const intercept = require('intercept-stdout');
 
 if (!process.env.MONGO_URL) {
   throw new Error('No MONGO_URL set in .env!');
@@ -14,6 +12,7 @@ const express = require('express');
 const app = express();
 const requireFromString = require('require-from-string');
 const models = require('./models')(db);
+const {installPackagesFromDatabase} = require('./npm')(models);
 
 app.get('/', (req, res) => {
   res.sendFile(path.join(__dirname, '/frontpage.html'));
@@ -56,74 +55,6 @@ app.all('/:path*', async (req, res) => {
   }
 });
 
-const npmLoad = () => new Promise((resolve, reject) => {
-  npm.load(function(err) {
-    if (err) {
-      reject(err);
-    }
-
-    npm.on('log', function(message) {
-      // log installation progress
-      //console.log(message);
-    });
-    resolve();
-  });
-});
-
-const npmList = () => new Promise((resolve, reject) => {
-  const unhook_intercept = intercept(txt => "");
-  npm.config.set('depth', 0);
-  npm.commands.list([], function(err, data) {
-    unhook_intercept();
-    if (err) {
-      reject(err);
-    }
-    resolve(Object.keys(data._dependencies));
-  });
-});
-
-const npmInstall = (packages) => new Promise((resolve, reject) => {
-  const unhook_intercept = intercept(txt => '');
-  npm.config.set('progress', 'false');
-  npm.config.set('silent', 'true');
-  npm.commands.install(packages, function(err, data) {
-    unhook_intercept();
-    if (err) {
-      reject(err);
-    }
-    resolve(data);
-  });
-});
-
-async function installPackagesFromDatabase(showInfo = false) {
-  try {
-    await npmLoad();
-    // handle errors
-    const packagesToInstall = await models.packages.find({});
-    const packages = packagesToInstall.map(obj => obj.name.trim());
-
-    const installedPackages = await npmList();
-
-    packages.forEach(async pkg => {
-      if (installedPackages.some(installedPkg => installedPkg.includes(pkg))) {
-        if (showInfo) {
-          console.info(`"${pkg}" Already installed, skipping...`);
-        }
-        return;
-      }
-      console.info(`Installing package "${pkg}"...`);
-      // install module
-      await npmInstall([pkg]);
-    });
-    if (showInfo) {
-      console.info(`Successfully installed ${packages.length} NPM packages programmatically.`);
-    }
-  } catch (err) {
-    console.error(`Failed to install NPM packages programmatically.`);
-    console.error(err);
-  }
-}
-
 const packagePollInterval = process.env.PACKAGE_POLL_INTERVAL || 60000; // 1 minute
 installPackagesFromDatabase(true);
 setInterval(installPackagesFromDatabase, packagePollInterval);