secure echo example

Author: sevenbitbyte

public/app.js

@@ -61,6 +61,28 @@ async function main(){
     //console.log('send')
 
 
+    let callTime2 = new DeltaTime()
+
+    callTime2.start()
+
+    const echoReply2 = await party.comms.call('secure-echo', {t:(new Date()).getTime()}, {
+      expectClearTextReply: true,
+      sendClearTextRequest: false,
+      useSessions: false
+    })
+
+    callTime2.end()
+    complete++
+
+    const text = `call deltaMs=<i>${callTime2.deltaMs}</i>ms complete ${complete}` 
+    document.getElementById("console").innerHTML = text    
+
+  }, 150)
+
+  setInterval(async ()=>{
+    //console.log('send')
+
+
     let callTime2 = new DeltaTime()
 
     callTime2.start()
@@ -78,7 +100,6 @@ async function main(){
     document.getElementById("console").innerHTML = text    
 
   }, 75)
-
 
 }
 

src/party/iparty.js

@@ -200,8 +200,8 @@ class IParty {
 
     if (!cfgIdenStr){
       debug('generated new identity')
-      this._identity = new dataparty_crypto.Identity({id: 'primary'})
-      await this.config.write(path, this._identity.toJSON(true))
+      
+      await this.resetIdentity()
     } else {
       debug('loaded identity')
       this._identity = dataparty_crypto.Identity.fromString(JSON.stringify(cfgIdenStr))
@@ -211,6 +211,10 @@ class IParty {
   async resetIdentity(){
     const path = 'identity'
     await this.config.write(path, null)
+
+    this._identity = new dataparty_crypto.Identity({id: 'primary'})
+    await this.config.write(path, this._identity.toJSON(true))
+
     await this.loadIdentity()
   }
 

src/service/endpoint-context.js

@@ -36,7 +36,6 @@ class EndpointContext {
   setCloud(cloud){ this.cloud = cloud }
 
   setSenderKey(key){
-    this.
     this.senderKey = key
   }
 

src/service/endpoints/secure-echo.js

@@ -0,0 +1,40 @@
+const Joi = require('@hapi/joi')
+const Hoek = require('@hapi/hoek')
+const {Message, Routines} = require('@dataparty/crypto')
+const debug = require('debug')('dataparty.endpoint.secure-echo')
+
+const IEndpoint = require('../iendpoint')
+
+module.exports = class SecureEchoEndpoint extends IEndpoint {
+
+  static get Name(){
+    return 'secure-echo'
+  }
+
+
+  static get Description(){
+    return 'Secure echo input'
+  }
+
+  static get MiddlewareConfig(){
+    return {
+      pre: {
+        decrypt: true,
+        validate: Joi.object().keys(null).description('any input allowed'),
+      },
+      post: {
+        encrypt: false,
+        validate: Joi.object().keys(null).description('any output allowed')
+      }
+    }
+  }
+
+  static async run(ctx){
+
+    ctx.debug('hello')
+    debug('echo')
+    ctx.debug('ctx.input', ctx.input)
+
+    return ctx.input
+  }
+}

src/service/index.js

@@ -33,10 +33,12 @@ module.exports = {
   },
   endpoint: {
     echo: require('./endpoints/echo'),
+    secureecho: require('./endpoints/secure-echo'),
     identity: require('./endpoints/service-identity')
   },
   endpoint_paths: {
     echo: Path.join(__dirname, './endpoints/echo.js'),
+    secureecho: Path.join(__dirname, './endpoints/secure-echo.js'),
     identity: Path.join(__dirname, './endpoints/service-identity.js')
   }
 }

src/service/middleware/pre/decrypt.js

@@ -29,15 +29,23 @@ module.exports = class Decrypt extends IMiddleware {
 
   static async run(context){
 
-    if (!Hoek.reach(context, 'endpoint.MiddlewareConfig.pre.decrypt', false)){
-      return
-    }
+    if (!Config){ return }
+
+    context.debug('input', context.input)
 
 
     const msg = new Message(context.input)
-    const jsonContent = await msg.decrpyt(this.serviceParty.privateIdentity)
+    context.debug('privateIdentity', context.party.privateIdentity)
+
     const publicKeys = Routines.extractPublicKeys(msg.enc)
 
+    context.debug('sender', publicKeys)
+    context.debug(typeof context.party.privateIdentity.key.private.box)
+    context.debug(context.input.enc)
+
+    const jsonContent = await msg.decrypt(context.party.privateIdentity)
+    
+
     context.setSenderKey({
       type: 'ecdsa',
       public: publicKeys

test/test-service-compile.js

@@ -17,6 +17,7 @@ class ExampleService extends Dataparty.IService {
     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)
 
   }

test/test-service-host.js

@@ -16,6 +16,7 @@ class ExampleService extends Dataparty.IService {
     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)
   }