Implement loadPluginsDirectory

lib/plugin-loader/plugin-loader.coffee

@@ -4,6 +4,8 @@ path = require('path')
 fs = require('fs')
 resin = require('../resin')
 
+PLUGINS_LOAD_PARALLEL_LIMIT = 5
+
 exports.use = (plugin) ->
 	if not _.isFunction(plugin)
 		throw new Error('Plugin should be a function')
@@ -75,3 +77,26 @@ exports.readPluginsDirectory = (directory, callback) ->
 				return callback(null, results)
 
 	], callback)
+
+exports.loadPluginsDirectory = (directory, callback, limit) ->
+
+	limit ?= PLUGINS_LOAD_PARALLEL_LIMIT
+
+	async.waterfall([
+
+		(callback) ->
+			exports.readPluginsDirectory(directory, callback)
+
+		(plugins, callback) ->
+			async.mapLimit(plugins, limit, exports.loadPlugin, callback)
+
+		(loadedPlugins, callback) ->
+			for plugin in loadedPlugins
+				try
+					exports.use(plugin)
+				catch error
+					return callback(error)
+
+			return callback()
+
+	], callback)

lib/plugin-loader/plugin-loader.spec.coffee

@@ -156,3 +156,29 @@ describe 'Plugin Loader:', ->
 
 				compareArrays(plugins, expectedPlugins)
 				done()
+
+	describe '#loadPluginsDirectory()', ->
+
+		it 'should not return an error for all valid plugins', (done) ->
+			pluginsDirectory = FILESYSTEM.pluginsDirectory
+			pluginLoader.loadPluginsDirectory pluginsDirectory.name, (error) ->
+				expect(error).to.not.exist
+				done()
+
+		it 'should call use for all plugins', (done) ->
+			pluginsDirectory = FILESYSTEM.pluginsDirectory
+			numberOfPlugins = _.keys(pluginsDirectory.contents).length
+
+			mock.fs.restore()
+			useSpy = sinon.spy(pluginLoader, 'use')
+			mock.fs.init(FILESYSTEM)
+
+			pluginLoader.loadPluginsDirectory pluginsDirectory.name, (error) ->
+				expect(error).to.not.exist
+				expect(useSpy.callCount).to.equal(numberOfPlugins)
+
+				for arg in _.flatten(useSpy.args)
+					expect(_.isFunction(arg)).to.be.true
+
+				useSpy.restore()
+				done()