Merge pull request #18 from datapartyjs/service-runner

initial service runner

Author: sevenbitbyte

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@dataparty/api",
   "private": false,
-  "version": "1.0.7",
+  "version": "1.1.0",
   "main": "src/index.js",
   "browser": "src/index-browser.js",
   "files": [
@@ -40,6 +40,7 @@
     "nconf": "^0.10.0",
     "node-persist": "^3.0.1",
     "nodemon-webpack-plugin": "^3.0.1",
+    "origin-router": "^1.6.4",
     "parse-url": "^5.0.1",
     "prompt": "^1.0.0",
     "roslib": "^0.20.0",

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,
+      Description: Lib.Description,
+      MiddlewareConfig: Lib.MiddlewareConfig
+    }
+  }
+  catch(err){
+
+    if(!err || !err.stack){
+      err = new ErrorError(err)
+    }
+
+    throw err
+  }
+
+}
+    `)
+
+    this.info = null
+  }
+
+  async run(){
+
+    debug('running')
+
+    this.info = await super.run()
+
+    return this.info
+  }
+
+}
+
+module.exports = EndpointInfoSandbox

src/sandbox/index.js

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

src/sandbox/middleware-exec-sandbox.js

@@ -0,0 +1,49 @@
+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){
+
+    debug('running')
+
+    this.result = await super.run(ctx, static_ctx)
+
+    return this.result
+  }
+
+}
+
+module.exports = MiddlewareExecSandbox

src/sandbox/middleware-info-sandbox.js

@@ -1,4 +1,4 @@
-//const debug = require('debug')('dataparty.MiddlewareInfoSandbox')
+const debug = require('debug')('dataparty.MiddlewareInfoSandbox')
 const Sandbox = require('./sandbox')
 
 class MiddlewareInfoSandbox extends Sandbox {
@@ -42,7 +42,7 @@ module.exports = async ()=>{
 
   async run(){
 
-
+    debug('running', this.code)
     this.info = await super.run()
 
     return this.info

src/sandbox/sandbox.js

@@ -5,7 +5,7 @@ const SandboxError = require('./sandbox-error')
 
 class Sandbox {
   constructor(code){
-    debug('compiling code')
+    debug('compiling code', typeof code)
     this.code = code
     this.script = new VMScript(code)
     debug('compiled')  

src/service/endpoint-context.js

@@ -0,0 +1,68 @@
+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 = null
+    this.stats = {
+      start: Date.now(),
+      bytes_in: !req ? null : JSON.stringify(req.body).length
+    }
+    this.oauth_cloud = null
+    this.session = null
+    this.identity = null
+    this.input = null
+    this.input_session_id = null
+    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 }
+
+  /*async 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/endpoint-runner.js

@@ -0,0 +1,16 @@
+const IRunner = require('./irunner')
+
+const EndpointInfoSandbox = require('../sandbox/endpoint-info-sandbox')
+const MiddlewareExecSandbox = require('../sandbox/middleware-exec-sandbox')
+
+class EndpointRunner extends IRunner {
+  constructor(code){
+    super({
+      info: new EndpointInfoSandbox(code),
+      exec: new MiddlewareExecSandbox(code),
+      start: new MiddlewareExecSandbox(code,'start')
+    })
+  }
+}
+
+module.exports = EndpointRunner

src/service/endpoints/service-identity.js

@@ -0,0 +1,36 @@
+const Joi = require('@hapi/joi')
+const Hoek = require('@hapi/hoek')
+const {Message, Routines} = require('@dataparty/crypto')
+const debug = require('debug')('roshub.endpoint.identity')
+
+const IEndpoint = require('../iendpoint')
+
+module.exports = class ServiceIdentity extends IEndpoint {
+
+  static get Name(){
+    return 'identity'
+  }
+
+
+  static get Description(){
+    return 'Get host identity'
+  }
+
+  static get MiddlewareConfig(){
+    return {
+      pre: {
+        decrpyt: false
+      }
+    }
+  }
+
+  static async run(ctx, static_ctx){
+
+  
+    const identity = ctx.party.identity
+
+    return {
+      ...identity
+    }
+  }
+}

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')
   }