improve loki querying

Author: sevenbitbyte

src/bouncer/db/loki-db.js

@@ -314,7 +314,7 @@ module.exports = class LokiDb extends IDb {
 
       debug('its good, updating', dbDoc)
 
-      let old = collection.findOne( {'$meta.id': dbDoc._id})
+      let old = collection.findOne( {'$meta.id': {'$eq': dbDoc._id}})
 
       let mergedDoc = {...old, ...dbDoc}
 

src/bouncer/mongo-query.js

@@ -176,7 +176,7 @@ const buildQueryDoc = (node, cursor) => {
     // -> { 'param.path': value }
     case 'equals':
       cursor.push({
-        [node.param.join('.')]: node.value
+        [node.param.join('.')]: {'$eq':  node.value}
       })
       return
 

src/party/local/loki-party.js

@@ -31,6 +31,8 @@ class LokiParty extends IParty {
   constructor ({path, dbAdapter, qbOptions, lokiOptions, ...options}) {
     super(options)
 
+    this.dbStarted = false
+
     this.db = new LokiDb({
       dbAdapter,
       path, factory: this.factory,
@@ -54,7 +56,11 @@ class LokiParty extends IParty {
    */
   async start(){
     await super.start()
-    await this.db.start()
+
+    if(!this.dbStarted){
+      await this.db.start()
+      this.dbStarted = true
+    }
   }
 
   static get Loki(){

src/party/local/tingo-party.js

@@ -24,6 +24,7 @@ class TingoParty extends IParty {
   constructor ({path, qbOptions, tingoOptions, ...options}) {
     super(options)
 
+    this.dbStarted = false
     this.db = new TingoDb({
       path, factory: this.factory,
       tingoOptions
@@ -45,7 +46,10 @@ class TingoParty extends IParty {
    */
   async start(){
     await super.start()
-    await this.db.start()
+    if(!this.dbStarted){
+      await this.db.start()
+      this.dbStarted = true
+    }
   }
 
 

src/party/local/zango-party.js

@@ -27,6 +27,7 @@ class ZangoParty extends IParty {
   constructor ({dbname, qbOptions, ...options}) {
     super(options)
 
+    this.dbStarted = false
     this.db = new ZangoDb({
       dbname, factory: this.factory,
     })
@@ -48,7 +49,10 @@ class ZangoParty extends IParty {
    */
   async start(){
     await super.start()
-    await this.db.start()
+    if(!this.dbStarted){
+      await this.db.start()
+      this.dbStarted = true
+    }
   }
 
 

src/party/loki-cache.js

@@ -41,7 +41,7 @@ module.exports = class LokiCache extends EventEmitter {
 
     var found = collection.findOne({'$meta.id': {'$eq': id}})
 
-    debug(found)
+    debug('removing found', found)
     if(found){ 
 
       try{
@@ -52,7 +52,7 @@ module.exports = class LokiCache extends EventEmitter {
         collection.findAndRemove({'$meta.id': id})
       }
 
-      debug('remove found', found)
+      debug('removed found', found)
 
       this._emitChange(found, 'remove')
     }
@@ -105,6 +105,8 @@ module.exports = class LokiCache extends EventEmitter {
         // check for cached version of message
         const cachedMsg = collection.findOne({'$meta.id': {'$eq': id}})
 
+        debug('cachedMsg', cachedMsg)
+
         // if backend set error or removed flag invalidate cache
         if (error || removed) {
           debug('invalidating msg!')