lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

WIP; plugins

Browse source
This commit is contained in:
Josh Harvey 2016-10-09 19:04:42 +01:00
parent bd3441adfb
commit a9ded1ddf2
2 changed files with 17 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lamassu-schema.json
View file

@ -212,6 +212,12 @@
"display": "SMS", "display": "SMS",
"fieldType": "account", "fieldType": "account",
"fieldClass": "sms" "fieldClass": "sms"
},
{
"code": "lowBalanceThreshold",
"display": "Low Balance Threshold",
"fieldType": "integer",
"fieldClass": null
} }
] ]
} }

18
lib/plugins.js
View file

@ -690,12 +690,16 @@ exports.getcryptoCodes = function getcryptoCodes () {
} }
function sendMessage (rec) { function sendMessage (rec) {
const pluginTypes = cachedConfig.exchanges.plugins.current.notify const pluginPromises = []
const pluginPromises = pluginTypes.map(pluginType => { if (!cachedConfig.notifications.notificationsEnabled) return Promise.all([])
if (pluginType === 'email') return emailPlugin.sendMessage(rec)
if (pluginType === 'sms') return smsPlugin.sendMessage(rec) if (cachedConfig.notifications.notificationsEmailEnabled) {
throw new Error('No such plugin type: ' + pluginType) pluginPromises.push(emailPlugin.sendMessage(rec))
}) }
if (cachedConfig.notifications.notificationsSMSEnabled) {
pluginPromises.push(smsPlugin.sendMessage(rec))
}
return Promise.all(pluginPromises) return Promise.all(pluginPromises)
} }
@ -770,7 +774,7 @@ function checkBalances () {
} }
exports.startCheckingNotification = function startCheckingNotification () { exports.startCheckingNotification = function startCheckingNotification () {
const config = cachedConfig.exchanges.plugins.settings.notifier const config = cachedConfig.notifications
notifier.init(db, checkBalances, config) notifier.init(db, checkBalances, config)
checkNotification() checkNotification()
setInterval(checkNotification, CHECK_NOTIFICATION_INTERVAL) setInterval(checkNotification, CHECK_NOTIFICATION_INTERVAL)