initial service runner

Author: sevenbitbyte

src/sandbox/endpoint-info-sandbox.js

@@ -0,0 +1,53 @@
+//const debug = require('debug')('dataparty.EndpointInfoSandbox')
+const Sandbox = require('./sandbox')
+
+class EndpointInfoSandbox extends Sandbox {
+  constructor(code){
+    super(`  
+
+module.exports = async ()=>{
+
+  class ErrorError extends Error { 
+    constructor(msg){
+      super()
+      this.code = 'ErrorError'
+      this.message = 'You did not throw an error object, always throw an Error object! - [' + msg + ']'
+    }
+  }
+
+  try{
+    let Lib = ${code}
+
+    return {
+      Name: Lib.Name,
+      Type: Lib.Type,
+      Description: Lib.Description,
+      MiddlewareConfig: Lib.MiddlewareConfig
+    }
+  }
+  catch(err){
+
+    if(!err || !err.stack){
+      err = new ErrorError(err)
+    }
+
+    throw err
+  }
+
+}
+    `)
+
+    this.info = null
+  }
+
+  async run(){
+
+
+    this.info = await super.run()
+
+    return this.info
+  }
+
+}
+
+module.exports = EndpointInfoSandbox

src/sandbox/index.js

@@ -1,5 +1,6 @@
 module.exports = {
   Sandbox: require('./sandbox'),
   SandboxError: require('./sandbox-error'),
-  MiddlewareInfoSandbox: require('./middleware-info-sandbox')
+  MiddlewareInfoSandbox: require('./middleware-info-sandbox'),
+  MiddlewareExecSandbox: require('./middleware-exec-sandbox')
 }

src/sandbox/middleware-exec-sandbox.js

@@ -0,0 +1,48 @@
+//const debug = require('debug')('dataparty.MiddlewareExecSandbox')
+const Sandbox = require('./sandbox')
+
+class MiddlewareExecSandbox extends Sandbox {
+  constructor(code, func='run'){
+    super(`  
+
+module.exports = async (ctx, static_ctx)=>{
+
+  class ErrorError extends Error { 
+    constructor(msg){
+      super()
+      this.code = 'ErrorError'
+      this.message = 'You did not throw an error object, always throw an Error object! - [' + msg + ']'
+    }
+  }
+
+  try{
+    let Lib = ${code}
+
+    return await Lib.${func}(ctx, static_ctx)
+  }
+  catch(err){
+
+    if(!err || !err.stack){
+      err = new ErrorError(err)
+    }
+
+    throw err
+  }
+
+}
+    `)
+
+    this.result = null
+  }
+
+  async run({ctx, static_ctx, party}){
+
+
+    this.result = await super.run(ctx, static_ctx)
+
+    return this.result
+  }
+
+}
+
+module.exports = MiddlewareExecSandbox

src/service/endpoint-context.js

@@ -0,0 +1,66 @@
+const Debug = require('debug')
+
+class EndpointContext {
+  constructor({party, endpoint, req, res}){
+    this.party = party
+    this.endpoint = endpoint
+    this.MiddlewareConfig = endpoint.info.MiddlewareConfig
+
+    this.req = req
+    this.res = res
+    this.actor = actor
+    this.stats = {
+      start: Date.now(),
+      bytes_in: !req ? null : JSON.stringify(req.body).length
+    }
+    this.oauth_cloud = oauth_cloud
+    this.session = session
+    this.identity = identity
+    this.input = input
+    this.input_session_id = input_session_id
+    this._debug = Debug('dataparty.context.undefined')
+    this._debugContent = []
+  }
+
+  setReq(req){ this.req = req }
+  setRes(res){ this.res = res }
+  setCloud(cloud){ this.cloud = cloud }
+
+  setSession(session){
+    this.session = session
+    this._debug = Debug('dataparty.context.' + session.id)
+  }
+
+  setOauthCloud(oauth_cloud){
+    this.oauth_cloud = oauth_cloud
+    this._debug = Debug('oauth cloud', oauth_cloud.id)
+  }
+
+  setIdentity(identity){ this.identity = identity }
+  setActor(actor){ this.actor = actor }
+  setInputSession(input_session_id){ this.input_session_id = input_session_id }
+
+  applyMiddleware
+
+  debug(msg, ...args){
+    let line = ((new Error().stack).split('at ')[2]).trim()
+
+    const openParen = line.indexOf('(') + 1
+    const closeParen = line.indexOf(')')
+
+    const filePath = line.substring(openParen, closeParen).replace(__dirname, '')
+    line = filePath
+
+    const newMsg = line + ' ' + msg
+
+    this._debugContent.push({
+      file: filePath,
+      time: Date.now(),
+      msg: msg + ' ' + args.map(v=>{return JSON.stringify(v)}).join(' ')
+    })
+    
+    this._debug(newMsg, ...args)
+  }
+}
+
+module.exports = EndpointContext

src/service/iendpoint.js

@@ -15,6 +15,10 @@ module.exports = class IEndpoint {
     throw new Error('not implemented')
   }
 
+  static async start(party){
+    
+  }
+
   static async run(context){
     throw new Error('not implemented')
   }

src/service/imiddleware.js

@@ -19,6 +19,10 @@ module.exports = class IMiddleware {
     throw new Error('not implemented')
   }
 
+  static async start(party){
+
+  }
+
   static async run(context){
     throw new Error('not implemented')
   }

src/service/middleware/pre/decrypt.js

@@ -23,21 +23,18 @@ module.exports = class Decrypt extends IMiddleware {
     return Joi.boolean()
   }
 
-  async run(config, context){
-    if(!config){
-      return
-    }
+  static async run(ctx, static_ctx){
 
-    if (!Hoek.reach(context, 'endpoint.MiddlewareConfig.pre.decrypt', false)){
-      return Promise.resolve(context)
+    if (!Hoek.reach(ctx, 'endpoint.MiddlewareConfig.pre.decrypt', false)){
+      return
     }
 
 
-    const msg = new Message(context.input)
+    const msg = new Message(ctx.input)
     const jsonContent = await msg.decrpyt(this.serviceParty.privateIdentity)
     const publicKeys = Routines.extractPublicKeys(msg.enc)
 
-    context.setInputSession(jsonContent.session)
+    ctx.setInputSession(jsonContent.session)
 
     return {
       input: Hoek.reach(content, 'data'),

src/service/service-host.js

@@ -16,9 +16,11 @@ class ServiceHost {
   constructor({
     cors = {},
     trust_proxy = false,
-    listenUri = 'http://0.0.0.0:4001'
+    listenUri = 'http://0.0.0.0:4001',
+    runner
   }={}){
     this.apiApp = express()
+    this.runner = runner
     this.router = express.Router()
 
     if(cors){
@@ -40,19 +42,14 @@ class ServiceHost {
     this.apiServerUri = new URL(listenUri)
   }
 
-  async onRequest(req, res){
-    debug('request')
-    res.end('nope')
-  }
-
   async start(){
 
     debug('starting server')
 
     if(this.apiServer==null){
       debug('adding default endpoints')
       //Setup router
-      this.apiApp.use(this.onRequest.bind(this))
+      this.apiApp.use(this.runner.onRequest.bind(this.runner))
 
       if(debug.enabled){ expressListRoutes('API:', this.router ) }
     }