connect-yii - npm Package Compare versions

Comparing version 0.0.10 to 0.0.11

node-php.js

@@ -8,2 +8,3 @@ var net = require("net");
 var HTTPParser = process.binding("http_parser").HTTPParser;
+var stream = require("stream");
 
@@ -337,3 +338,3 @@ /*
 				case "PUT":
-					request.cb(new Error("not implemented"));
+					request.cb(new Error("PUT: not implemented"));
 					break;
@@ -367,7 +368,24 @@ case "POST":
 						var rbBuf = req.rawBody;
-						var size = 32*1024; // kb -> bytes = what i want.
-						for(var i=0; i*size<rbBuf.length; i++) {
-							var from = i===0 ? 0 : (i*size);
-							var to = ((i*size)+size);
+						var size = fastcgi.constants.general.FCGI_MAX_BODY-1;
+						var st = new stream.Readable;
+						st.__i = 0;
+						st._read = function(n) {
+							if(this.__i*size >= rbBuf.length+1) {
+								return this.push(null);
+							}
+							var from = (this.__i*size);
+							var to = ((this.__i*size)+size);
 							var nbuf = rbBuf.slice(from, to);
+							this.push(nbuf);
+							console.log("Stats",{
+								i: this.__i,
+								from: from,
+								to: to,
+								length: rbBuf.length,
+								"content-length": req.headers["content-length"],
+								"buffer-length": nbuf.length
+							});
+							this.__i++;
+						}
+						st.on("data", function(chunk) {
 							connection.writer.writeHeader({
@@ -377,21 +395,22 @@ "version": fastcgi.constants.version,
 								"recordId": request.id,
-								"contentLength": nbuf.length,
+								"contentLength": chunk.length,
 								"paddingLength": 0
 							});
-							connection.writer.writeBody(nbuf);
+							connection.writer.writeBody(chunk);
 							connection.write(connection.writer.tobuffer());
-						}
-						// Done
-						connection.writer.writeHeader({
-							"version": fastcgi.constants.version,
-							"type": fastcgi.constants.record.FCGI_STDIN,
-							"recordId": request.id,
-							"contentLength": 0,
-							"paddingLength": 0
 						});
-						connection.write(connection.writer.tobuffer());
+						st.on("end", function() {
+							connection.writer.writeHeader({
+								"version": fastcgi.constants.version,
+								"type": fastcgi.constants.record.FCGI_STDIN,
+								"recordId": request.id,
+								"contentLength": 0,
+								"paddingLength": 0
+							});
+							connection.write(connection.writer.tobuffer());
+						});
 					}
 					break;
 				case "DELETE":
-					request.cb(new Error("not implemented"));
+					request.cb(new Error("DELETE: not implemented"));
 					break;
@@ -398,0 +417,0 @@ }

package.json

 {
   "name": "connect-yii",
-  "version": "0.0.10",
+  "version": "0.0.11",
   "description": "connect middleware to pass requests to FastCGI server",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

21423

2.51%

Lines of code

553

3.56%

No dependency changes