Merge pull request #70 from datapartyjs/i2p-example

i2p example, secure config examle tweak, downgrade ncc

Author: sevenbitbyte

examples/i2p-host.js

@@ -0,0 +1,90 @@
+const Path = require('path')
+const debug = require('debug')('example.i2p')
+const Dataparty = require('../src')
+const dataparty_crypto = require('@dataparty/crypto')
+
+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)
+
+    this.addSchema(Path.join(__dirname, './party/schema/basic_types.js'))
+  }
+
+}
+
+async function main(){
+
+  
+  //const uri = 'mongodb://localhost:27017/server-party-test'
+  //debug('db location', uri)
+
+  
+  const service = new ExampleService({ name: '@dataparty/example', version: '0.0.1' })
+  const build = await service.compile(Path.join(__dirname,'/dataparty'), true)
+  
+  const serviceName = build.package.name
+  const basePath = '/data/dataparty/'
+  const servicePath = Path.join(basePath, serviceName.replace('/','-'))
+
+  let config = new Dataparty.Config.JsonFileConfig({ basePath: servicePath })
+  config.touchDir('/tingo')
+
+  const dbPath = Path.join(servicePath, '/tingo')
+
+  let party = new Dataparty.TingoParty({
+    config,
+    path: dbPath,
+    model: build
+  })
+
+  party.topics = new Dataparty.LocalTopicHost()
+
+  const live = new Dataparty.IService(build.package, build)
+
+  
+  const runner = new Dataparty.ServiceRunnerNode({
+    party,
+    service: live,
+    sendFullErrors: false,
+    useNative: false
+  })
+
+  
+  
+  
+  const runnerRouter = new Dataparty.RunnerRouter(runner)
+  
+  
+  const host = new Dataparty.ServiceHost({
+    runner: runnerRouter,
+    trust_proxy: true,
+    wsEnabled: true,
+    i2pEnabled: true,
+    i2pSamHost: 'localhost',
+    i2pSamPort: 7656
+  })
+  
+  debug(runner.party.identity)
+  await party.start()
+  await runnerRouter.start()
+  await host.start()
+
+  console.log('started')
+}
+
+
+
+main().catch(err=>{
+  console.error(err)
+})

examples/secure-config.js

@@ -15,7 +15,8 @@ async function main(){
 
 
     secureConfig = new Dataparty.Config.SecureConfig({
-        config: jsonConfig
+        config: jsonConfig,
+        timeoutMs: 15*1000
     })
 
 
@@ -121,10 +122,9 @@ async function main(){
 
     let timer = setTimeout(async ()=>{
 
-
         console.log('timer config', await secureConfig.readAll())
 
-    }, 30000)
+    }, 1000*30)
 
 }
 

examples/test-service-node-host.js

@@ -34,7 +34,7 @@ async function main(){
   const build = await service.compile(Path.join(__dirname,'/dataparty'), true)
 
   const serviceName = build.package.name
-  const basePath = '/data/datparty/'
+  const basePath = '/data/dataparty/'
   const servicePath = Path.join(basePath, serviceName.replace('/','-'))
 
   let config = new Dataparty.Config.JsonFileConfig({ basePath: servicePath })
@@ -80,7 +80,7 @@ async function main(){
 
   console.log('started')
 
-  process.exit()
+  //process.exit()
 }
 
 

package.json

@@ -64,6 +64,7 @@
     "@diva.exchange/i2p-sam": "^4.1.8",
     "@markwylde/liferaft": "^1.3.4",
     "@vercel/ncc": "^0.36.1",
+    "@zeit/ncc": "^0.22.3",
     "ajv": "6.9.1",
     "axios": "^0.27.2",
     "bleno": "npm:@abandonware/bleno@^0.5.1-4",

src/config/json-file.js

@@ -68,6 +68,7 @@ class JsonFileConfig extends IConfig {
 
   async write(key, value){
 
+    logger('writing path:', key)
     deepSet(this.content, key, value)
     await this.save()
   }