feat: initial work on testing, other fixes

.aegir.js

@@ -0,0 +1,20 @@
+'use strict'
+
+const Server = require('./src/server')
+let server
+
+function pre (done) {
+  server = new Server({})
+  server.start.then(done, done)
+}
+
+function post (done) {
+  server.stop(done, done)
+}
+
+module.exports = {
+  hooks: {
+    pre,
+    post
+  }
+}

package.json

@@ -14,10 +14,19 @@
   "author": "Maciej Krüger <[email protected]>",
   "license": "MPL-2.0",
   "dependencies": {
-    "libp2p-mplex": "^0.8.4",
-    "libp2p-websockets": "^0.12.0",
-    "multistream-select": "^0.14.3",
-    "peer-id": "^0.12.1",
-    "protons": "^1.0.1"
+    "lint": "aegir lint",
+    "build": "aegir build",
+    "test": "aegir test",
+    "test:node": "aegir test --target node",
+    "test:browser": "aegir test --target browser",
+    "test:webworker": "aegir test --target webworker",
+    "release": "aegir release --target node --target browser",
+    "release-minor": "aegir release --type minor --target node --target browser",
+    "release-major": "aegir release --type major --target node --target browser",
+    "coverage": "aegir coverage",
+    "coverage-publish": "aegir coverage --provider coveralls"
+  },
+  "devDependencies": {
+    "aegir": "^18.0.2"
   }
 }

src/client/index.js

@@ -38,15 +38,16 @@ class Client {
 }
 
 class Connection {
-  constructor (client, address) {
+  constructor (client, handler) {
     this.client = client
-    this.address = address
+    this.handler = handler
   }
 
-  async connect () {
+  async connect (address) {
     if (this.connected) { return }
+    this.address = address
 
-    let conn = await this.client.switch.dial(this.address)
+    let conn = await this.client.switch.dial(address)
     const muxed = await this.client.swtich.wrapInMuxer(conn, false)
 
     conn = await prom(cb => muxed.newStream(cb))