json based config file

Author: sevenbitbyte

examples/test-loopback-party.js

@@ -1,17 +1,21 @@
+const fs = require('fs/promises')
 const debug = require('debug')('test.local-db')
 const WRTC = require('wrtc')
 const BouncerModel = require('@dataparty/bouncer-model/dist/bouncer-model.json')
 const Dataparty = require('../src')
 
 async function main(){
-  const dbPath = '/tmp/local-peer-party-loki.db'
+  const dbPath = await fs.mkdtemp('/tmp/tingo-party')
+  const configPath = await fs.mkdtemp('/tmp/tingo-party-config')
 
   debug('db location', dbPath)
 
-  let hostLocal = new Dataparty.LokiParty({
+  let config = new Dataparty.Config.JsonFileConfig({basePath: configPath})
+
+  let hostLocal = new Dataparty.TingoParty({
     path: dbPath,
     model: BouncerModel,
-    config: new Dataparty.Config.MemoryConfig()
+    config
   })
 
   let loopback = new Dataparty.Comms.LoopbackChannel()
@@ -25,7 +29,7 @@ async function main(){
     comms: comms1,
     hostParty: hostLocal,
     model: BouncerModel,
-    config: new Dataparty.Config.MemoryConfig()
+    config
   })
 
 
@@ -38,6 +42,8 @@ async function main(){
   })
 
 
+  await config.start()
+
 
   await peer1.loadIdentity()
   await peer2.loadIdentity()
@@ -78,6 +84,14 @@ async function main(){
 }
 
 
-main().catch(err=>{
-  console.error(err)
-})
+try{
+
+  main().catch(err=>{
+    console.error(err)
+  })
+
+}
+catch(err){
+  console.log('crash')
+  console.log(err)
+}

package.json

@@ -1,7 +1,7 @@
 {
   "name": "@dataparty/api",
   "private": false,
-  "version": "1.2.7",
+  "version": "1.2.8",
   "main": "dist/dataparty.js",
   "browser": "src/index-browser.js",
   "source": "src/index.js",

src/config/index.js

@@ -1,9 +1,11 @@
 const NconfConfig = require('./nconf')
 const MemoryConfig = require('./memory')
+const JsonFileConfig = require('./json-file')
 const LocalStorageConfig = require('./local-storage')
 
 module.exports = {
   NconfConfig,
   MemoryConfig,
+  JsonFileConfig,
   LocalStorageConfig
 }

src/config/json-file.js

@@ -0,0 +1,65 @@
+'use strict';
+
+const fs = require('fs')
+const deepSet = require('deep-set')
+const reach = require('../utils/reach')
+const logger = require('debug')('dataparty.config.memory');
+
+/**
+ * @class
+ * @implements {Config}
+ */
+class JsonFileConfig {
+
+  constructor(defaults){
+    this.path = reach(defaults, 'basePath') +'/config.json'
+    this.defaults = defaults || {}
+    this.content = Object.assign({}, this.defaults)
+  }
+
+  async load(){
+    if(!fs.existsSync(this.path)){return}
+    
+    let rawdata = fs.readFileSync(this.path)
+
+    if(rawdata && rawdata.length > 0){
+      this.content = JSON.parse(rawdata)
+    }
+  }
+
+  async start () {
+    await this.load()
+    return this
+  }
+
+  clear () {
+    this.content = {}
+  }
+
+  readAll(){
+
+    return Object.assign({}, this.content)
+  }
+
+  read(key){
+    logger('reading path: ' + key)
+    return reach( this.content, key)
+  }
+
+  async write(key, value){
+
+    deepSet(this.content, key, value)
+    await this.save()
+  }
+
+
+  exists(key){
+    return (read(key) !== undefined)
+  }
+
+  async save(){
+    fs.writeFileSync(this.path, JSON.stringify(this.content, null, 2))
+  }
+}
+
+module.exports = JsonFileConfig