fix bug in weapp (#913)

* add support for Ali Mini Program

* remove test for wx and ali Mini Program

* refactor lib/connect/ali.js

* rewrite wx.js

* fix wx.js

* remove unuse console, and fix connect/index.js for alis

* revert ws.js

* fix ali.js

* remove weapp-test script in package.json

* fix README.md

* fix ali.js to adapt IDE

* fix ali.js and wx.js

* fix wx.js

* fix: change let to var

lib/connect/ali.js

@@ -14,7 +14,7 @@ function buildProxy () {
   var proxy = new Transform()
   proxy._write = function (chunk, encoding, next) {
     my.sendSocketMessage({
-      data: chunk,
+      data: chunk.buffer,
       success: function () {
         next()
       },

lib/connect/wx.js

@@ -12,7 +12,7 @@ function buildProxy () {
   var proxy = new Transform()
   proxy._write = function (chunk, encoding, next) {
     socketTask.send({
-      data: chunk,
+      data: chunk.buffer,
       success: function () {
         next()
       },
@@ -78,7 +78,7 @@ function bindEventHandler () {
   })
 
   socketTask.onError(function (res) {
-    stream.destroy(res)
+    stream.destroy(new Error(res.errMsg))
   })
 }
 
@@ -104,6 +104,27 @@ function buildStream (client, opts) {
 
   proxy = buildProxy()
   stream = duplexify.obj()
+  stream._destroy = function (err, cb) {
+    socketTask.close({
+      success: function () {
+        cb && cb(err)
+      }
+    })
+  }
+
+  var destroyRef = stream.destroy
+  stream.destroy = function () {
+    stream.destroy = destroyRef
+
+    var self = this
+    process.nextTick(function () {
+      socketTask.close({
+        fail: function () {
+          self._destroy(new Error())
+        }
+      })
+    })
+  }.bind(stream)
 
   bindEventHandler()