Pipe the workerstream to websocket stream, try mineflayer in worker. G…

…H-8

Requires deathcap/wsmc@45096b5

clientmc.js

@@ -241,15 +241,21 @@ ClientMC.prototype.enable = function() {
 
   this.mfworker = webworkify(require('./mf-worker.js'));
   this.mfworkerStream = workerstream(this.mfworker);
+  this.websocketStream = websocket_stream(this.opts.url);
+
+  this.websocketStream.pipe(this.mfworkerStream);
+
+  /*
   this.mfworkerStream.write('test');
   this.mfworkerStream.on('data', function(data) {
     console.log('mfworkerStream data',data);
   });
+  */
 
   // create bot
   this.bot = mineflayer.createBot({
     username: username,
-    stream: websocket_stream(this.opts.url)
+    stream: this.websocketStream,
   });
 
   this.game.voxels.on('missingChunk', this.missingChunk.bind(this));

mf-worker.js

@@ -1,11 +1,26 @@
 'use strict';
 
 var ParentStream = require('workerstream/parent');
+var mineflayer = require('wsmc/mineflayer-stream');
 
 module.exports = function(self) {
+  console.log('mf-worker initializing',self);
+  console.log('Object=',Object.prototype);
+
+  self.parentStream = ParentStream();
+
+  /*
+  self.bot = mineflayer.createBot({
+    username: 'user1', // TODO
+    stream: self.parentStream,
+  });
+
+  console.log('mf-worker bot',self.bot);
+  */
+
   self.onmessage = function(event) {
     console.log('mf-worker onmessage',event);
-    self.postMessage({whats: 'up'});
+    //self.postMessage({whats: 'up'});
   };
 };