updated

Author: calidion

README.md

@@ -34,21 +34,29 @@ var nodeWeixinMessage = require('node-weixin-message');
 //在http请求里的处理方式
 app.get('weixin/text', function(req, res) {
   var messages = nodeWeixinMessage.messages;
-  function text(message) {
-    //只会被调用一次
+
+  function text(message, res, callback, extra) {
+    //message => 解析后的JSON
+    //res => res
+    //callback => callback
+    //extra => 'some data',
+
+    //Extra
     res.send(message);
   }
-  //多次相同的回调函数只会被调用一次
+
+  //多次侦听相同的回调函数只会被调用一次
   messages.on.text(text);
   messages.on.text(text);
   messages.on.text(text);
+  messages.onXML(req.body, res, function callback(message) {
+    //After message handled.
+  }
+  //后面可以接系统允许的最大数量的参数，只要跟text的处理函数一一对应就可以了。
+  //唯一不同的是req.body会被解析成JSON
+  //,
+  //'some data');
 
-  x2j.parseString(req.body, {
-    explicitArray: false,
-    ignoreAttrs: true
-  }, function(error, json) {
-    messages.parse(json.xml);
-  });
 });
 ```
 

lib/incoming.js

@@ -36,6 +36,7 @@ module.exports = {
   on: ons,
   onXML: function(xml) {
     var self = this;
+    var preArg = arguments;
     x2j.parseString(xml, {
       explicitArray: false,
       ignoreAttrs: true
@@ -44,8 +45,8 @@ module.exports = {
         throw Error('Failed Parsing XML!');
       }
       var args = [json.xml];
-      for (var i = 1; i < arguments.length; i++) {
-        args.push(arguments[i]);
+      for (var i = 1; i < preArg.length; i++) {
+        args.push(preArg[i]);
       }
       self.parse.apply(self, args);
     });

package.json

@@ -1,6 +1,6 @@
 {
   "name": "node-weixin-message",
-  "version": "0.0.9",
+  "version": "0.0.10",
   "description": "",
   "homepage": "",
   "author": {

test/incoming.js

@@ -355,4 +355,35 @@ describe('node-weixin-message', function() {
     }
     http(r1, r2);
   });
+
+  it('should not be able to use onXML', function(done) {
+    var r1 = {};
+    var r2 = {};
+    r2.send = function(message) {
+      assert.equal(true, message.FromUserName === 'fromUser');
+      assert.equal(true, message.ToUserName === 'toUser');
+      assert.equal(true, message.CreateTime === '1351776360');
+      assert.equal(true, message.MsgType === 'link');
+      assert.equal(true, message.Title === '公众平台官网链接');
+      assert.equal(true, message.Description === '公众平台官网链接');
+      assert.equal(true, message.Url === 'url');
+      assert.equal(true, message.MsgId === '1234567890123456');
+    };
+
+    function http(req, res) {
+      var messages = nodeWeixinMessage.messages;
+      function A(message, res, cb, more) {
+        assert.equal(res, r2);
+        assert.equal(more, 'and more');
+        res.send(message);
+        cb();
+      }
+      messages.on.link(A);
+      var xml = fs.readFileSync(path.resolve(__dirname, './messages/link.xml'));
+      messages.onXML(xml, res, function() {
+        done();
+      }, 'and more');
+    }
+    http(r1, r2);
+  });
 });

test/template.js

@@ -55,7 +55,7 @@ describe('node-weixin-message', function () {
       }, function (error, data) {
         assert.equal(true, !error);
         if (data.errcode === 40036) {
-          console.log(error, data);
+          console.error(error, data);
         } else {
           assert.equal(true, data.errcode === 0);
           assert.equal(true, data.errmsg === 'ok');