Merge pull request #91 from kuzzleio/4.0.0-proposal

# [4.0.0](https://github.com/kuzzleio/kuzzle-plugin-cluster/releases/tag/4.0.0) (2019-09-19)


#### Enhancements

- [ [#85](#85) ] Adapt cluster for the new indexCache   ([Aschen](https://github.com/Aschen))
- [ [#84](#84) ] Remove the deprecated notifications state   ([scottinet](https://github.com/scottinet))
---

Author: Aschen

.eslintrc

@@ -54,5 +54,9 @@
     "node": true,
     "es6": true
   },
+  "parserOptions": {
+    "sourceType": "module",
+    "ecmaVersion": 2018
+  },
   "extends": "eslint:recommended"
 }

Dockerfile

@@ -1,4 +1,4 @@
-FROM kuzzleio/kuzzle
+FROM kuzzleio/kuzzle:1.10.2
 
 LABEL "io.kuzzle.vendor"="Kuzzle"
 

lib/index.js

@@ -43,7 +43,6 @@ class KuzzleCluster {
    */
   constructor () {
     this.config = null;
-    /** @type {PluginContext} */
     this.context = null;
     this.kuzzle = null;
     this.uuid = null;
@@ -55,7 +54,6 @@ class KuzzleCluster {
       'core:kuzzleStart': 'kuzzleStarted',
       'core:indexCache:add': 'indexCacheAdded',
       'core:indexCache:remove': 'indexCacheRemoved',
-      'core:indexCache:reset': 'indexCacheReset',
       'core:notify:document': 'notifyDocument',
       'core:notify:user': 'notifyUser',
       'core:hotelClerk:addSubscription': 'subscriptionAdded',
@@ -65,7 +63,6 @@ class KuzzleCluster {
       'core:profileRepository:delete': 'profileUpdated',
       'core:roleRepository:save': 'roleUpdated',
       'core:roleRepository:delete': 'roleUpdated',
-      'index:afterSetAutoRefresh': 'autoRefreshUpdated',
       'collection:afterUpdateSpecifications': 'refreshSpecifications',
       'collection:afterDeleteSpecifications': 'refreshSpecifications',
       'realtime:errorSubscribe': 'unlockCreateRoom',
@@ -168,21 +165,6 @@ class KuzzleCluster {
   // hooks
   // --------------------------------------------------------------------------
 
-  /**
-   * @param {Request} request
-   */
-  autoRefreshUpdated (request) {
-    if (!this.node.ready) {
-      debug('[%s][warning] could not broadcast "autoRefresh updated" action: node not connected to cluster', this.uuid);
-      return;
-    }
-
-    return this.redis.hset('cluster:autorefresh', request.input.resource.index, request.input.body.autoRefresh)
-      .then(() => this.node.broadcast('cluster:sync', {
-        event: 'autorefresh'
-      }));
-  }
-
   /**
    * @param {Request} request
    * @param {function} cb callback
@@ -222,45 +204,36 @@ class KuzzleCluster {
   }
 
   /**
-   * @param {object} diff
+   * Hook for core:indexCache:add
+   *
+   * @param {Object} payload - { index, collection, scope }
    */
-  indexCacheAdded (diff) {
+  indexCacheAdded (payload) {
     if (!this.node.ready) {
       debug('[%s][warning] could not broadcast "index cache added" action: node not connected to cluster', this.uuid);
       return;
     }
 
     this.node.broadcast('cluster:sync', {
       event: 'indexCache:add',
-      index: diff.index,
-      collection: diff.collection
+      ...payload
     });
   }
 
   /**
-   * @param {object} diff
+   * Hook for core:indexCache:remove
+   *
+   * @param {Object} payload - { index, collection, scope }
    */
-  indexCacheRemoved (diff) {
+  indexCacheRemoved (payload) {
     if (!this.node.ready) {
       debug('[%s][warning] could not broadcast "index cache removed" action: node not connected to cluster', this.uuid);
       return;
     }
 
     this.node.broadcast('cluster:sync', {
       event: 'indexCache:remove',
-      index: diff.index,
-      collection: diff.collection
-    });
-  }
-
-  indexCacheReset () {
-    if (!this.node.ready) {
-      debug('[%s][warning] could not broadcast "index cache reseted" action: node not connected to cluster', this.uuid);
-      return;
-    }
-
-    this.node.broadcast('cluster:sync', {
-      event: 'indexCache:reset'
+      ...payload
     });
   }
 

lib/node.js

@@ -181,28 +181,21 @@ class Node {
     }
 
     switch (data.event) {
-      case 'autorefresh':
-        return this.redis
-          .hgetall('cluster:autorefresh')
-          .then(autoRefreshes => {
-            for (const index of Object.keys(autoRefreshes)) {
-              const autoRefresh = autoRefreshes[index];
-              this.kuzzle.services.list.storageEngine.setAutoRefresh(new Request({
-                index,
-                controller: 'index',
-                action: 'setAutoRefresh',
-                body: {autoRefresh}
-              }));
-            }
-          });
       case 'indexCache:add':
-        this.kuzzle.indexCache.add(data.index, data.collection, false);
+        this.kuzzle.storageEngine.indexCache.add({
+          index: data.index,
+          collection: data.collection,
+          scope: data.scope,
+          notify: false
+        });
         break;
       case 'indexCache:remove':
-        this.kuzzle.indexCache.remove(data.index, data.collection, false);
-        break;
-      case 'indexCache:reset':
-        this.kuzzle.indexCache.reset();
+        this.kuzzle.storageEngine.indexCache.remove({
+          index: data.index,
+          collection: data.collection,
+          scope: data.scope,
+          notify: false
+        });
         break;
       case 'profile':
         delete this.kuzzle.repositories.profile.profiles[data.id];
@@ -400,7 +393,6 @@ class Node {
         data.rooms,
         new Request(data.request.data, data.request.options),
         data.scope,
-        data.state,
         data.action,
         data.content
       );