service runner snapshot

Author: sevenbitbyte

src/service/endpoints/service-identity.js

@@ -0,0 +1,47 @@
+const Joi = require('@hapi/joi')
+const Hoek = require('@hapi/hoek')
+const {Message, Routines} = require('@dataparty/crypto')
+const debug = require('debug')('roshub.middleware.pre.decrypt')
+
+const IMiddleware = require('../../imiddleware')
+
+module.exports = class Decrypt extends IMiddleware {
+
+  static get Name(){
+    return 'decrypt'
+  }
+
+  static get Type(){
+    return 'pre'
+  }
+
+  static get Description(){
+    return 'Decrypt inbound data'
+  }
+
+  static get ConfigSchema(){
+    return Joi.boolean()
+  }
+
+  static async run(ctx, static_ctx){
+
+    if (!Hoek.reach(ctx, 'endpoint.MiddlewareConfig.pre.decrypt', false)){
+      return
+    }
+  
+
+    const msg = new Message(ctx.input)
+    const jsonContent = await msg.decrpyt(this.serviceParty.privateIdentity)
+    const publicKeys = Routines.extractPublicKeys(msg.enc)
+
+    ctx.setInputSession(jsonContent.session)
+
+    return {
+      input: Hoek.reach(content, 'data'),
+      sender: {
+        type: 'ecdsa',
+        public: publicKeys
+      }
+    }
+  }
+}

src/service/middleware/pre/decrypt.js

@@ -11,19 +11,19 @@ module.exports = class Decrypt extends IMiddleware {
     return 'decrypt'
   }
 
-  static get Type(){
-    return 'pre'
-  }
-
   static get Description(){
     return 'Decrypt inbound data'
   }
 
-  static get ConfigSchema(){
-    return Joi.boolean()
+  static get MiddlewareConfig(){
+    throw new Error('not implemented')
+  }
+
+  static async start(party){
+    
   }
 
-  static async run(ctx, static_ctx){
+  static async run(context){
 
     if (!Hoek.reach(ctx, 'endpoint.MiddlewareConfig.pre.decrypt', false)){
       return

test/test-service-compile.js

@@ -2,8 +2,6 @@ const Path = require('path')
 const debug = require('debug')('test.service-compile')
 const Dataparty = require('../src')
 
-//const {VM, NodeVM, VMScript} = require('vm2')
-
 process.on('uncaughtException', (err) => {
   console.error('Asynchronous error caught.', err);
 })
@@ -26,8 +24,6 @@ async function main(){
 
   const build = await service.compile(Path.join(__dirname,'../dataparty'), false)
 
-  //debug(build.middleware.pre.decrypt)
-
   let decryptInfo = new Dataparty.MiddlewareInfoSandbox(build.middleware.pre.decrypt.code)
 
   try{

test/test-service-host.js

@@ -2,14 +2,14 @@ const Path = require('path')
 const debug = require('debug')('test.server-db')
 const Dataparty = require('../src')
 
-/*class ExampleService extends Dataparty.IService {
-    constructor(opts){
-      super(opts)
+class ExampleService extends Dataparty.IService {
+  constructor(opts){
+    super(opts)
 
-      this.addMiddleware(Dataparty.middleware_paths.pre.decrypt)
-    }
+    this.addMiddleware(Dataparty.middleware_paths.pre.decrypt)
+  }
 
-}*/
+}
 
 async function main(){