unsandboxed service host

Author: sevenbitbyte

examples/test-service-host.js

@@ -48,7 +48,7 @@ async function main(){
 
   const host = new Dataparty.ServiceHost({
     runner,
-    trust_proxy: false,
+    trust_proxy: true,
     wsEnabled: true
   })
 

examples/test-service-node-host.js

@@ -0,0 +1,68 @@
+const Path = require('path')
+const debug = require('debug')('test.server-db')
+const Dataparty = require('../src')
+
+const BouncerServerModels = require('@dataparty/bouncer-model')
+const BouncerClientModels = require('@dataparty/bouncer-model/dist/bouncer-model.json')
+
+class ExampleService extends Dataparty.IService {
+  constructor(opts){
+    super(opts)
+
+    this.addMiddleware(Dataparty.middleware_paths.pre.decrypt)
+    this.addMiddleware(Dataparty.middleware_paths.pre.validate)
+
+    this.addMiddleware(Dataparty.middleware_paths.post.validate)
+    this.addMiddleware(Dataparty.middleware_paths.post.encrypt)
+
+    this.addEndpoint(Dataparty.endpoint_paths.echo)
+    this.addEndpoint(Dataparty.endpoint_paths.secureecho)
+    this.addEndpoint(Dataparty.endpoint_paths.identity)
+    this.addEndpoint(Dataparty.endpoint_paths.version)
+  }
+
+}
+
+async function main(){
+
+  const uri = 'mongodb://localhost:27017/server-party-test'
+  debug('db location', uri)
+
+  let party = new Dataparty.MongoParty({
+    uri,
+    model: BouncerClientModels,
+    serverModels: BouncerServerModels,
+    config: new Dataparty.Config.MemoryConfig()
+  })
+
+  const service = new ExampleService({ name: '@dataparty/example', version: '0.0.1' })
+
+  const build = await service.compile(Path.join(__dirname,'/dataparty'), true)
+
+  debug('built', Object.keys(build))
+
+  const runner = new Dataparty.ServiceRunnerNode({
+    party, service,
+    sendFullErrors: true
+  })
+  
+  const host = new Dataparty.ServiceHost({
+    runner,
+    trust_proxy: true,
+    wsEnabled: true
+  })
+
+  await party.start()
+  await runner.start()
+  await host.start()
+
+  console.log('started')
+  
+  //process.exit()
+}
+
+
+
+main().catch(err=>{
+  console.error(err)
+})

src/party/peer/peer-party.js

@@ -2,10 +2,8 @@
 
 const debug = require('debug')('dataparty.peer-party')
 
-//const WRTC = require('wrtc')
 const Qb = require('../qb')
 const IParty = require('../iparty')
-//const RTCSocketComms = require('../../comms/rtc-socket-comms')
 
 /**
  * @class 
@@ -34,10 +32,6 @@ class PeerParty extends IParty {
     }
   }
 
-  static get WRTC(){
-    return WRTC
-  }
-
   async start(){
     await super.start()
     if(this.comms.host){ 

src/sandbox/sandbox.js

@@ -40,7 +40,7 @@ class Sandbox {
       })
 
       let fn = vm.run(this.script)
-      const retVal = await fn(context)
+      const retVal = await fn(context, sandbox)
       return retVal
 
     } catch(err) {

src/service/endpoints/echo.js

@@ -29,7 +29,7 @@ module.exports = class EchoEndpoint extends IEndpoint {
     }
   }
 
-  static async run(ctx){
+  static async run(ctx, {Package}){
 
     ctx.debug('hello')
     debug('echo')

src/service/endpoints/secure-echo.js

@@ -29,7 +29,7 @@ module.exports = class SecureEchoEndpoint extends IEndpoint {
     }
   }
 
-  static async run(ctx){
+  static async run(ctx, {Package}){
 
     ctx.debug('hello')
     debug('echo')

src/service/endpoints/service-identity.js

@@ -38,7 +38,7 @@ module.exports = class ServiceIdentity extends IEndpoint {
     }
   }
 
-  static async run(ctx, static_ctx){
+  static async run(ctx, {Package}){
 
 
     const identity = ctx.party.identity

src/service/endpoints/service-version.js

@@ -33,7 +33,7 @@ module.exports = class ServiceVersion extends IEndpoint {
     }
   }
 
-  static async run(ctx, static_ctx){
+  static async run(ctx, {Package}){
 
     return {
       ...Package

src/service/iendpoint.js

@@ -19,7 +19,15 @@ module.exports = class IEndpoint {
 
   }
 
-  static async run(context){
+  static async run(context, {Package}){
     throw new Error('not implemented')
   }
+
+  static get info(){
+    return {
+      Name: this.Name,
+      Description: this.Description,
+      MiddlewareConfig: this.MiddlewareConfig
+    }
+  }
 }

src/service/imiddleware.js

@@ -23,7 +23,16 @@ module.exports = class IMiddleware {
 
   }
 
-  static async run(context){
+  static async run(context, {Config}){
     throw new Error('not implemented')
   }
+
+  static get info(){
+    return {
+      Name: this.Name,
+      Type: this.Type,
+      Description: this.Description,
+      ConfigSchema: this.ConfigSchema
+    }
+  }
 }