Merge pull request #492 from FlowzPlatform/custom-service-flowzdata

setup seprate socket for custom service

Author: nikitam747

client/src/pages/flow/New.vue

@@ -142,7 +142,7 @@
                       }
                       for (let m of jsonXML[type]) {
                         // let obj = m
-  
+
                         m.type = type.toLowerCase()
                         allProcess.push(m)
                       }
@@ -222,7 +222,7 @@
 
                   let actionsObj = {}
                   for (let i = 0; i < actions.length; i++) {
-                    actionsObj[actions[i]] = this.permissions
+                    actionsObj[actions[i].toLowerCase()] = this.permissions
                   }
                   subscriptionNew.moduleResource.moduleName = 'workflow_' + this.$route.params.id
                   let registerAppModuleNew = actionsObj

service/src/services/dflowzdata/dflowzdata.class.js

@@ -6,11 +6,24 @@ class Service {
   constructor (options) {
     this.options = options || {};
     this.service = new createServiceMain(options);
-    this.rDB = this.service.options.r(this.service.options.db);
+    this.rDB = this.service.options.r.db(this.service.options.db);
   }
 
   setup(app) {
     this.app = app;
+    // this.service.watchChangefeeds(app);
+    this.on('created',(data) => {
+      this.app.io.emit(this.service.options.name+'_created', data);
+    });
+    this.on('updated',(data) => {
+      this.app.io.emit(this.service.options.name+'_updated', data);
+    });
+    this.on('patched',(data) => {
+      this.app.io.emit(this.service.options.name+'_updated', data);
+    });
+    this.on('removed',(data) => {
+      this.app.io.emit(this.service.options.name+'_removed', data);
+    });
   }
   setTableName (params) {
     this.service.options.name = params.headers.ftablename;

service/src/services/dflowzdata/dflowzdata.service.js

@@ -18,7 +18,7 @@ module.exports = function () {
 
   // Get our initialized service so that we can register hooks and filters
   const service = app.service('dflowzdata');
-
+  service.watch = false;
   service.hooks(hooks);
   // console.log('=======',Object.keys(app.services),'=========');
 };