fix: HA event publish

requarks · Apr 20, 2020 · 405187b · 405187b
1 parent bd4263e
commit 405187b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/server/core/db.js b/server/core/db.js
@@ -207,8 +207,8 @@ module.exports = {
     // -> Outbound events handling
 
     this.listener.addChannel('wiki', payload => {
-      if (_.has(payload.event) && payload.source !== WIKI.INSTANCE_ID) {
-        WIKI.logger.debug(`Received event ${payload.event} from instance ${payload.source}: [ OK ]`)
+      if (_.has(payload, 'event') && payload.source !== WIKI.INSTANCE_ID) {
+        WIKI.logger.info(`Received event ${payload.event} from instance ${payload.source}: [ OK ]`)
         WIKI.events.inbound.emit(payload.event, payload.value)
       }
     })
@@ -239,7 +239,7 @@ module.exports = {
    * @param {object} value Payload of the event
    */
   notifyViaDB (event, value) {
-    this.listener.publish('wiki', {
+    WIKI.models.listener.publish('wiki', {
       source: WIKI.INSTANCE_ID,
       event,
       value

diff --git a/server/models/pages.js b/server/models/pages.js
@@ -350,6 +350,7 @@ module.exports = class Page extends Model {
 
     // -> Render page to HTML
     await WIKI.models.pages.renderPage(page)
+    WIKI.events.outbound.emit('deletePageFromCache', page.hash)
 
     // -> Update Search Index
     const pageContents = await WIKI.models.pages.query().findById(page.id).select('render')
@@ -804,12 +805,11 @@ module.exports = class Page extends Model {
   /**
    * Delete an Existing Page from Cache
    *
-   * @param {Object} page Page Model Instance
-   * @param {string} page.hash Hash of the Page
+   * @param {String} page Page Unique Hash
    * @returns {Promise} Promise with no value
    */
-  static async deletePageFromCache(page) {
-    return fs.remove(path.resolve(WIKI.ROOTPATH, WIKI.config.dataPath, `cache/${page.hash}.bin`))
+  static async deletePageFromCache(hash) {
+    return fs.remove(path.resolve(WIKI.ROOTPATH, WIKI.config.dataPath, `cache/${hash}.bin`))
   }
 
   /**