a new plugins controller

This commit is contained in:
lesion
2022-08-09 18:32:47 +02:00
parent 9f748423c9
commit 10ba78de96
5 changed files with 63 additions and 27 deletions

View File

@@ -0,0 +1,53 @@
const path = require('path')
const fs = require('fs')
const log = require('../../log')
const config = require('../../config')
const pluginController = {
plugins: [],
getAll (req, res, next) {
res.json(pluginController.plugins)
},
_load () {
const settingsController = require('./settings')
// load custom plugins
const plugins_path = config.plugins_path || path.resolve(process.env.cwd || '', 'gancio_plugins')
log.info(`Loading plugin ${plugins_path}`)
if (fs.existsSync(plugins_path)) {
const notifier = require('../../notifier')
const plugins = fs.readdirSync(plugins_path)
.map(e => path.resolve(plugins_path, e, 'index.js'))
.filter(index => fs.existsSync(index))
plugins.forEach( pluginFile => {
try {
const plugin = require(pluginFile)
if (typeof plugin.load !== 'function') return
const name = plugin.configuration.name
console.log(`Found plugin '${name}'`)
pluginController.plugins.push(plugin.configuration)
if (settingsController.settings['plugin_' + name]) {
const pluginSetting = settingsController.settings['plugin_' + name]
if (pluginSetting.enable) {
plugin.load({ settings: settingsController.settings }, settingsController.settings.plugins)
if (typeof plugin.onEventCreate === 'function') {
notifier.emitter.on('Create', plugin.onEventCreate)
}
if (typeof plugin.onEventDelete === 'function') {
notifier.emitter.on('Delete', plugin.onEventDelete)
}
if (typeof plugin.onEventUpdate === 'function') {
notifier.emitter.on('Update', plugin.onEventUpdate)
}
}
} else {
settingsController.set('plugin_' + name, { enable: false })
}
} catch (e) {
log.warn(`Unable to load plugin ${pluginFile}: ${String(e)}`)
}
})
}
}
}
module.exports = pluginController