'use strict'
|
|
const Farm = require('./farm')
|
|
let farms = [] // keep record of farms so we can end() them if required
|
|
|
function farm (options, path, methods) {
|
if (typeof options == 'string') {
|
methods = path
|
path = options
|
options = {}
|
}
|
|
let f = new Farm(options, path)
|
, api = f.setup(methods)
|
|
farms.push({ farm: f, api: api })
|
|
// return the public API
|
return api
|
}
|
|
|
function end (api, callback) {
|
for (let i = 0; i < farms.length; i++)
|
if (farms[i] && farms[i].api === api)
|
return farms[i].farm.end(callback)
|
process.nextTick(callback.bind(null, new Error('Worker farm not found!')))
|
}
|
|
|
module.exports = farm
|
module.exports.end = end
|
