FP Refactor

Thx to @clemos

Author: JbIPS

lib/index.js

@@ -102,7 +102,12 @@ function isAuthentifiedFunction(methodName) {
 		'stat', 'batch'].includes(methodName);
 }
 
-const HOOKS = ['onRead', 'onWrite'];
+const HOOKS = {
+	ON_READ: 'onRead',
+	ON_WRITE: 'onWrite'
+};
+
+const applyPlugins = (plugins, content) => plugins.reduce((data, action) => action(data), content);
 
 const connectors = Symbol('connectors');
 
@@ -121,8 +126,8 @@ class Unifile {
    */
 	constructor() {
 		this[connectors] = new Map();
-		this.plugins = HOOKS.reduce((memo, hook) => {
-			memo[hook] = [];
+		this.plugins = Object.keys(HOOKS).reduce((memo, key) => {
+			memo[HOOKS[key]] = [];
 			return memo;
 		}, {});
 	}
@@ -144,7 +149,7 @@ class Unifile {
    * @param {Plugin} plugin - A plugin with at least one hook implemented
    */
 	ext(plugin) {
-		HOOKS.forEach((hook) => {
+		Object.keys(HOOKS).map((key) => HOOKS[key]).forEach((hook) => {
 			if(plugin.hasOwnProperty(hook)) this.plugins[hook].push(plugin[hook]);
 		});
 	}
@@ -267,10 +272,7 @@ class Unifile {
    * @return {external:Promise<null>} an empty promise.
    */
 	writeFile(session, connectorName, path, content) {
-		let input = content;
-		this.plugins.onWrite.forEach((action) => {
-			input = action(input);
-		});
+		const input = applyPlugins(this.plugins[HOOKS.ON_WRITE], content);
 		return this.callMethod(connectorName, session, 'writeFile', path, input);
 	}
 
@@ -294,13 +296,7 @@ class Unifile {
    */
 	readFile(session, connectorName, path) {
 		return this.callMethod(connectorName, session, 'readFile', path)
-		.then((content) => {
-			let output = content;
-			this.plugins.onRead.forEach((action) => {
-				output = action(output);
-			});
-			return output;
-		});
+		.then((content) => applyPlugins(this.plugins[HOOKS.ON_READ], content));
 	}
 
 	/**