Rewrote plugins loading (#1)

server/index.ts

@@ -1,6 +1,7 @@
 import * as Hapi from 'hapi';
 
 import {loadRoutes} from './utils/routesLoader';
+import {loadPlugins} from './utils/pluginsLoader';
 
 const pkg = require('../../package.json');
 const log = require('printit')({
@@ -33,17 +34,15 @@ server.connection({ port: port, host: host });
 
 server.register([
 	require('inert'),
+	require('vision'),
 	{
 		register: require('hapi-swagger'),
-		options: { 
-			info: {
-				'title': pkg.name,
-				'description': pkg.description,
-				'version': pkg.version,
-			},
-		}
-	},
-	require('vision')
+		options: { info: {
+			'title': pkg.name,
+			'description': pkg.description,
+			'version': pkg.version,
+		}}
+	}
 ], (err) => {
 	if(err) {
 		log.error(err);
@@ -54,16 +53,16 @@ server.register([
 	server.route({
 		method: 'GET',
 		path: '/{file*}',
-		handler: {
-			directory: {
-				path: __dirname + '/../client/',
-				listing: true
-			}
-		}
+		handler: { directory: {
+			path: __dirname + '/../client/',
+			listing: true
+		}}
 	});
 
 	// Load the routes from the main router
 	loadRoutes(server);
+	// Load the install plugins
+	loadPlugins(server);
 });
 
 // Start the server

server/router.ts

@@ -1 +1,6 @@
+import * as admin from './controllers/admin';
+import * as data from './controllers/pluginData';
+import * as plugin from './controllers/plugin';
+import * as user from './controllers/user';
+
 module.exports = {}

server/utils/handleErrors.ts

@@ -13,6 +13,9 @@ export function handleErr(err: Error, res: e.Response): void {
 		case 'NUMBER_MISSING':
 			code = 400;
 			break;
+		case 'UNAUTHORISED':
+			code = 401;
+			break;
 		case 'NOT_ADMIN':
 		case 'PLUGIN_DISABLED':
 			code = 403;

server/utils/pluginsLoader.ts

@@ -0,0 +1,57 @@
+import * as path from 'path';
+import * as fs from 'fs';
+
+import * as Hapi from 'hapi';
+
+import * as Plugins from '../lib/plugins';
+
+const log = require('printit')({
+	date: true,
+	prefix: 'Plugins'
+});
+
+const root = path.resolve('./plugins');
+
+export function loadPlugins(server: Hapi.Server) {
+	// Check and update plugins currently stored in the database
+	Plugins.PluginConnector.update().catch(processError);
+
+	// Retrieve a list of the plugins currently present in the /plugins directory
+	let plugins = fs.readdirSync(root).filter(file => fs.statSync(path.join(root, file)).isDirectory());
+
+	// Add plugin's public directories as static routes
+	for(let plugin of plugins) {
+	    // Get instance of the connector so the plugin gets registered if
+	    // it wasn't before
+	    Plugins.PluginConnector.getInstance(plugin)
+		.then((connector) => {
+			if(!connector) throw new Error('Couldn\'t get database connector');
+
+			return connector.getState()
+		}).then((state) => {
+			// Only create the root if the plugin is enabled
+			if(state === Plugins.State.enabled) {
+				// Get the plugin's public path
+				let pluginPublicPath = path.join(root, plugin, 'public');
+
+				// Check if the plugin has a public directory
+				if(fs.existsSync(pluginPublicPath)) {
+					// Create a static route for the plugin
+					server.route({
+						method: 'GET',
+						path: '/' + plugin + '/{file*}',
+						handler: { directory: {
+							path: __dirname + pluginPublicPath,
+							listing: true
+						}}
+					});
+				}
+			}
+		}).catch(processError);
+	}
+}
+
+function processError(e) {
+	log.error(e);
+	process.exit(1);
+}