Merge 03fbd21 into 2bed4c7

lib/server.js

@@ -217,7 +217,7 @@ Server.prototype._requestListener = function (req, res) {
       chunks.push(chunk);
     });
     source.on('end', function () {
-      var xml = chunks.join('');
+      var xml = Buffer.concat(chunks).toString();
       var result;
       var error;
       self._processRequestXml(req, res, xml);

test/post-data-concat-test.js

@@ -0,0 +1,59 @@
+'use strict';
+
+var fs = require('fs');
+var soap = require('..');
+var assert = require('assert');
+var http = require('http');
+
+
+describe('post data concat test', function () {
+    var server = http.createServer(function (req, res) { });
+
+    before(function () {
+        server.listen(51515);
+    });
+
+    after(function () {
+        server.close();
+    });
+
+    it('should consider the situation about multi-byte character between two tcp packets', function (done) {
+        var check = function (a, b) {
+            if (a && b) {
+                assert(a === b);
+                done();
+            }
+        };
+
+        var wsdl = 'test/wsdl/default_namespace.wsdl';
+        var xml = fs.readFileSync(wsdl, 'utf8');
+        var service = {
+            MyService: {
+                MyServicePort: {
+                    MyOperation: function (arg) {
+                        check(arg, postdata);
+                        return "0";
+                    }
+                }
+            }
+        };
+
+        soap.listen(server, '/wsdl', service, xml);
+
+        var postdata = "";
+        for (var i = 0; i < 20000; i++) {
+            postdata += "测试";
+        }
+
+        soap.createClient(wsdl, {
+            endpoint: 'http://localhost:51515/wsdl'
+        }, function (error, client) {
+            assert(!error);
+            client.MyOperation(postdata, function (error, response) {
+                assert(!error);
+            });
+        });
+
+    });
+});
+