Wip2.0

.gitignore

@@ -1,8 +1,9 @@
 /@todo/*
 /node_modules/*
 /package-lock.json
+/pnpm-lock.yaml
 /npm-debug.log
 
 /yarn.lock
 /yarn-error.log
-.DS_Store
+.DS_Store

demo/bootstrapper.js

@@ -0,0 +1,37 @@
+const DHT = require('@hyperswarm/dht')
+
+module.exports = bootstrappers
+
+async function bootstrappers ({ amount = 1, log = console.log.bind(console) } = {}) {
+  if ((!Number.isInteger(amount)) || amount < 2) amount = 1
+
+  const node0 = await make_node({ port: 10000, ephemeral: false, bootstrap: [] })
+  const info0 = info(node0)
+
+  const bootstrap_nodes = [{ host: info0.address.host, port: info0.address.port }]
+
+
+  for (var i = 0; i < amount; i++) {
+    const node = await make_node({ port: 10001 + i, ephemeral: false, bootstrap: bootstrap_nodes })
+    const meta = info(node)
+    bootstrap_nodes.push({ host: meta.address.host, port: meta.address.port })
+  }
+
+  log('bootstrap_nodes', ...bootstrap_nodes)
+  return bootstrap_nodes
+}
+
+async function make_node ({ port = 10000, ephemeral = true, bootstrap = [] }) {
+  const node = new DHT({ bootstrap, ephemeral, firewalled: false })
+  await node.bind(port)
+  return node
+}
+
+function info (node) {
+  const pk = node.defaultKeyPair.publicKey.toString('hex')
+  const sk = node.defaultKeyPair.secretKey.toString('hex')
+  // Your DHT routing id is hash(publicIp + publicPort) and will be autoconfigured internally.
+  const id = node.table.id.toString('hex')
+  const { host, port } = node.address()
+  return { id, pk, sk, address: { host, port } }
+}

demo/scenarios/1.js

@@ -0,0 +1,21 @@
+
+module.exports = [
+  { "name": "alice", "behavior": ["register_chain_account", "subscribe_to_plan", "offer_service"] },
+  { "name": "eve", "behavior": ["register_chain_account", "author_hypercore"] },
+  { "name": "bob", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "charlie", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "dave", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "janice", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "ferdie", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "one", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "two", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "tom", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "ashley", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "emma", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "joe", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "anna", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "paul", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "rachel", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "alfie", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "poppy", "behavior": ["register_chain_account", "offer_service"] },
+]

demo/scenarios/2.js

@@ -0,0 +1,11 @@
+
+module.exports = [
+  { "name": "iva", "behavior": ["author_hypercore"] },
+  { "name": "luigi", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "rok", "behavior": ["register_chain_account", "subscribe_to_plan"] },
+  { "name": "bianca", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "bent", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "felix", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "elfi", "behavior": ["register_chain_account", "offer_service"] },
+  { "name": "clemens", "behavior": ["register_chain_account", "offer_service"] },
+]

demo/scenarios/3.js

@@ -0,0 +1,3 @@
+// TODO:
+// bob tries to register as a offer_hosting twice
+// author has no additional actions

demo/simulation.js

@@ -0,0 +1,99 @@
+process.env.DEBUG = '*,-hypercore-protocol'
+const spawn = require('cross-spawn')
+const path = require('path')
+const bootstrapper = require('./bootstrapper.js')
+
+run()
+
+async function run (){
+
+  const bootstrap_nodes = await bootstrapper({ amount: 10 })
+
+  console.log({bootstrap_nodes})
+
+  await new Promise(resolve => setTimeout(resolve, 250))
+
+  const [scenarioName, flag] = process.argv.slice(2)
+  process.env.REPORT = `*
+   +**,-
+   +*:*:**@bar#xxx;
+
+   alice:chain
+
+   asdf@fooo#x
+   asdf@fooo
+   asdf#x
+   @fooo#x
+   asdf
+   @fooo
+   #x
+  `
+
+  if (!scenarioName) return console['log'](`
+    USAGE:    npm run simulation <scenario-filename>
+
+              (To customise logs,
+               edit "demo/simulation.js"
+               and change "process.env.REPORT")
+
+    SCENARIOS:
+      ./demo/scenarios/1.js
+      ./demo/scenarios/2.js
+      ./demo/scenarios/foo.js
+
+    EXAMPLE 1
+      > npm run simulation 1
+
+    EXAMPLE 2
+      > npm run simulation foo.js
+  `)
+
+  const scenario = require(`./scenarios/${scenarioName}`)
+
+  const all = [process]
+  const url = 'ws://localhost'
+
+  const config = JSON.stringify({ chain: [url, 3399], chat: [url, 6697], bootstrap: bootstrap_nodes })
+
+ if (flag === '--production') {
+    throw new Error('"--production" is currently unsuported')
+    // const command1 = path.join(__dirname, '../datdot-substrate/target/release/datdot-node')
+    // const child = spawn(command1, ['--dev'], { stdio: 'inherit' })
+    // all.push(child)
+  } else {
+    const args1 = [path.join(__dirname, '../src/node_modules/datdot-node-javascript/chain.js'), config, /*logkeeper*/9001]
+    const chain = spawn('node', args1, { stdio: 'inherit' })
+    all.push(chain)
+  }
+
+  const args2 = [path.join(__dirname, '../src/node_modules/_chat/server.js'), config, /*logkeeper*/ 9002]
+  const chatserver = spawn('node', args2, { stdio: 'inherit' })
+  all.push(chatserver)
+
+  const users = scenario
+  const PORTS = [9001, 9002]
+  const file = path.join(__dirname, '../src/node_modules/datdot-simulate-user/user.js')
+  for (var i = 0, len = users.length; i < len; i++) {
+    const scenario = JSON.stringify(users[i])
+    const logkeeper_port = 9003 + i
+    PORTS.push(logkeeper_port)
+    const args = [file, scenario, config, logkeeper_port]
+    const child = spawn('node', args, { stdio: 'inherit' })
+    all.push(child)
+  }
+
+  const args3 = [path.join(__dirname, '../src/node_modules/datdot-explorer/demo/registry.js'), JSON.stringify(PORTS)]
+  const logkeeper = spawn('node', args3, { stdio: 'inherit' })
+  all.push(logkeeper)
+
+  process.on('SIGINT', () => {
+    console['log']("\n Terminating all processes")
+    const [main, ...processes] = all
+    for (var i = 0, len = processes.length; i < len; i++) {
+      const child = processes[i]
+      child.kill()
+    }
+    console['log']('done')
+    main.exit(0)
+  })
+}