switch venue to using a LocalParty so we don't have to solve every issue in MongoParty right now

Author: sevenbitbyte

src/party/document-factory.js

@@ -2,6 +2,36 @@ const Ajv = require('ajv')
 const debug = require('debug')('dataparty.document-factory')
 const IDocument = require('./idocument')
 
+class DocumentValidationError extends Error {
+  constructor(ajvErrors){
+    super()
+
+    /*[
+        {
+          "keyword": "required",
+          "dataPath": "",
+          "schemaPath": "#/required",
+          "params": {
+            "missingProperty": "name"
+          },
+          "message": "should have required property 'name'"
+        }
+      ]
+    */
+
+    this.message='Validation failure\n'
+
+    for(let i=0; i<ajvErrors.length; i++){
+      const error = ajvErrors[i]
+      this.message += error.message + 'at data.'+error.dataPath
+    }
+
+    this.stack=''
+    this.name='DocumentValidationError'
+    this.code=this.name
+  }
+}
+
 /**
  * @class
  */
@@ -111,6 +141,7 @@ class DocumentFactory {
    * @param {*} data 
    */
   validate(type, data){
+    debug('validate',type)
     return new Promise((resolve, reject)=>{
 
       if(!this.validators[type]){
@@ -122,7 +153,8 @@ class DocumentFactory {
 
       if(!valid){
         let errors = this.validators[type].errors
-        return reject({error: errors})
+
+        return reject(new DocumentValidationError(errors))
       }
 
       return resolve(data)

src/party/idocument.js

@@ -124,7 +124,9 @@ class IDocument extends EventEmitter {
    * @returns {object}
    */
   async setData(input){
+    debug('setData start')
     let valid = await this.party.factory.validate(this.type, input)
+    debug('setData done')
     this._data = valid
   }
 
@@ -138,6 +140,7 @@ class IDocument extends EventEmitter {
     delete value.$meta.version
     delete value.__v
 
+    debug('asign data')
     await this.setData(value)
     debug('data set')
     await this.party.update(value)

src/party/local/loki-db.js

@@ -39,7 +39,7 @@ module.exports = class LokiDb extends EventEmitter {
             autoload: true,
             autoloadCallback : resolve,
             autosave: true, 
-            autosaveInterval: 10000
+            autosaveInterval: 1000
           }
         )
 

src/sandbox/sandbox.js

@@ -33,9 +33,10 @@ class Sandbox {
         sandbox,
         require: {
           external: {
-            modules: ['debug', '@dataparty/crypto', '@hapi/joi', '@hapi/hoek']
+            modules: ['debug', '@dataparty/crypto', '@hapi/joi', '@hapi/hoek', ]
           },
-          //builtin: ['*']
+          builtin: ['*'], //! This should be empty typically
+          import: ['fs', 'readline', 'stream']
         }
       })
 

src/venue/endpoints/create-service.js

@@ -62,22 +62,30 @@ module.exports = class CreateSrvEndpoint extends IEndpoint {
       debug('service created')
     }
     else{
-      debug('updating service')
-      debug(srvDoc.data)
-      await srvDoc.mergeData({
-        package: compiledSrv.package,
-        //schemas: compiledSrv.schemas,
-        //endpoints: compiledSrv.endpoints,
-        //midddleware: compiledSrv.middleware,
-        middleware_order: compiledSrv.middleware_order
-      })
 
-      debug(srvDoc.data)
 
       try{
+
+        debug('updating service')
+        debug(srvDoc.data)
+        await srvDoc.mergeData({
+          package: compiledSrv.package,
+          schemas: compiledSrv.schemas,
+          endpoints: compiledSrv.endpoints,
+          midddleware: compiledSrv.middleware,
+          middleware_order: compiledSrv.middleware_order
+        })
+  
+        //debug(srvDoc.data)
+  
+        debug('saving doc')
+
+
         await srvDoc.save()
       }
-      catch(err){}
+      catch(err){
+        console.log(err)
+      }
       debug('updated service')
     }
 

src/venue/schema/venue_service.js

@@ -54,9 +54,9 @@ class VenueSrv extends Dataparty.ISchema {
 
   static permissions (context) {
     return {
-      read: false,
-      new: false,
-      change: false
+      read: true,
+      new: true,
+      change: true
     }
   }
 }

src/venue/venue-host.js

@@ -59,13 +59,25 @@ async function main(){
     }
   }
 
-  let party = new Dataparty.MongoParty({
+  /*let party = new Dataparty.MongoParty({
     uri,
     model: build.schemas,
     serverModels,
     config: new Dataparty.Config.MemoryConfig()
+  })*/
+
+  const dbPath = 'dataparty-venue.db'
+
+  debug('party db location', dbPath)
+
+  let party = new Dataparty.LocalParty({
+    path: dbPath,
+    model: build.schemas,
+    config: new Dataparty.Config.MemoryConfig()
   })
 
+
+
   debug('partying')
 
   const runner = new Dataparty.ServiceRunner({