autolevel.js

commit 6ea44505b845182694a8873693470e240b14437e
parent b4a0d92f6d5705d7da02662d0511ed36774173c7
Author: finwo <finwo@pm.me>
Date:   Wed, 14 Nov 2018 13:57:16 +0100

Use ws instead of shoe

Diffstat:
M
src/custom/wsrpc.js
 | 
9
++++++---

1 file changed, 6 insertions(+), 3 deletions(-)
diff --git a/src/custom/wsrpc.js b/src/custom/wsrpc.js
@@ -1,5 +1,5 @@
 const multilevel = require('multilevel'),
-      shoe       = require('shoe'),
+      WebSocket  = require('ws'),
       urlParse   = require('url-parse');
 
 const protomap = {
@@ -42,8 +42,11 @@ module.exports = function (location, options, callback) {
 
   // Connect
   queue.unshift(function(callback) {
-    let stream = shoe(parsedLocation.toString(), callback);
-    stream.pipe(db.createRpcStream()).pipe(stream);
+    let stream = new WebSocket(parsedLocation.toString());
+    stream.on('open', function() {
+      stream.pipe(db.createRpcStream()).pipe(stream);
+      callback();
+    });
   });
 
   // Queue runner