make websocket compatible

Author: dignifiedquire

package.json

@@ -36,6 +36,7 @@
   "dependencies": {
     "chai": "^3.5.0",
     "multiaddr": "^2.0.2",
+    "pull-goodbye": "0.0.1",
     "pull-stream": "^3.4.4"
   }
 }

src/dial-test.js

@@ -3,6 +3,7 @@
 
 const expect = require('chai').expect
 const pull = require('pull-stream')
+const goodbye = require('pull-goodbye')
 
 module.exports = (common) => {
   describe('dial', () => {
@@ -27,7 +28,12 @@ module.exports = (common) => {
       listener = transport.createListener((conn) => {
         pull(
           conn,
-          pull.map((x) => new Buffer(x.toString() + '!')),
+          pull.map((x) => {
+            if (x.toString() !== 'GOODBYE') {
+              return new Buffer(x.toString() + '!')
+            }
+            return x
+          }),
           conn
         )
       })
@@ -39,10 +45,9 @@ module.exports = (common) => {
     })
 
     it('simple', (done) => {
-      pull(
-        pull.values(['hey']),
-        transport.dial(addrs[0]),
-        pull.collect((err, values) => {
+      const s = goodbye({
+        source: pull.values([new Buffer('hey')]),
+        sink: pull.collect((err, values) => {
           expect(err).to.not.exist
           expect(
             values
@@ -51,7 +56,9 @@ module.exports = (common) => {
           )
           done()
         })
-      )
+      })
+
+      pull(s, transport.dial(addrs[0]), s)
     })
 
     it('to non existent listener', (done) => {