WIP

lib/plugins.js

@@ -94,6 +94,7 @@ function plugins (settings) {
     limit 1`
 
     return db.one(sql, ['config'])
+    .then(row => row.id)
   }
 
   function pollQueries (deviceTime, deviceId, deviceRec) {

lib/poller.js

@@ -1,6 +1,7 @@
 const plugins = require('./plugins')
 const notifier = require('./notifier')
 const T = require('./time')
+const logger = require('./logger')
 
 const INCOMING_TX_INTERVAL = 30 * T.seconds
 const LIVE_INCOMING_TX_INTERVAL = 5 * T.seconds
@@ -16,6 +17,7 @@ let pi
 
 function reload (settings) {
   pi = plugins(settings)
+  logger.debug('settings reloaded in poller')
 }
 
 function start (settings) {

lib/routes.js

@@ -15,6 +15,7 @@ const pairing = require('./pairing')
 const settingsLoader = require('./settings-loader')
 const plugins = require('./plugins')
 const helpers = require('./route-helpers')
+const poller = require('./poller')
 
 module.exports = {init}
 
@@ -396,7 +397,8 @@ function init (opts) {
   })
 
   localApp.post('/dbChange', (req, res, next) => {
-    return settingsLoader.load()
+    return settingsLoader.loadLatest()
+    .then(poller.reload)
     .then(() => logger.info('Config reloaded'))
     .catch(err => {
       logger.error(err)
@@ -428,6 +430,8 @@ function populateSettings (req, res, next) {
   }
 
   const versionId = req.headers['config-version']
+  logger.debug('versionId: %s', versionId)
+
   if (!versionId) {
     logger.debug('No config-version header')
     return res.sendStatus(400)

lib/settings-loader.js

@@ -14,7 +14,7 @@ function load (versionId) {
   }))
 }
 
-function loadLatest (versionId) {
+function loadLatest () {
   return Promise.all([loadLatestConfig(), loadAccounts()])
   .then(([config, accounts]) => ({
     config,