Refreshing the LocalData list and Search index for the shared FS based 'cluster' setup.

lib/config.js

@@ -40,6 +40,11 @@ function Config(config) {
       '.sinopia-db.json'
     )
   )
+  self.localList.on('data', function(data) {
+    if (data && data.secret) {
+      self.secret = data.secret
+    }
+  })
   if (!self.secret) {
     self.secret = self.localList.data.secret
 
@@ -195,4 +200,3 @@ module.exports.parse_interval = function(interval) {
   })
   return result
 }
-

lib/local-data.js

@@ -1,17 +1,37 @@
 var fs   = require('fs')
 var Path = require('path')
+var util = require("util")
+var events = require("events")
+var Logger    = require('./logger')
 
 module.exports = LocalData
 
 function LocalData(path) {
   var self = Object.create(LocalData.prototype)
+  events.EventEmitter.call(self);
+  self.logger = Logger.logger.child()
   self.path = path
+  self.parseData()
+  // Refreshes package list.
+  // Necessary in case of running Sinopia*
+  // in shared FS based 'cluster'.
+  fs.watchFile(self.path, function (curr, prev) {
+    self.parseData()
+  })
+  return self
+}
+
+util.inherits(LocalData, events.EventEmitter)
+
+LocalData.prototype.parseData = function() {
   try {
-    self.data = JSON.parse(fs.readFileSync(self.path, 'utf8'))
-  } catch(_) {
-    self.data = { list: [] }
+    this.data = JSON.parse(fs.readFileSync(this.path, 'utf8'))
+    this.logger.warn('The LocalData config has been updated.')
+    this.emit("data", this.data)
+  } catch(err) {
+    this.logger.error({ err: err }, 'The LocalData config parse error: @{err.message}')
+    this.data = { list: [] }
   }
-  return self
 }
 
 LocalData.prototype.add = function(name) {
@@ -41,4 +61,3 @@ LocalData.prototype.sync = function() {
   } catch(err) {}
   fs.writeFileSync(this.path, JSON.stringify(this.data))
 }
-

lib/search.js

@@ -42,7 +42,10 @@ Search.prototype.reindex = function() {
 Search.prototype.configureStorage = function(storage) {
   this.storage = storage
   this.reindex()
+  var self = this
+  this.storage.config.localList.on('data', function(data) {
+    self.reindex()
+  })
 }
 
 module.exports = Search()
-