Benchmarks for busboy

.nycrc

@@ -7,10 +7,10 @@
 		"text-summary"
 	],
 	"exclude": [
+		"bench",
 		"test",
 		"coverage",
-		".eslintrc.js",
-		"deps/dicer/bench"
+		".eslintrc.js"
 	],
     "check-coverage": true,
     "lines": 51,

bench/busboy-bench.js

@@ -0,0 +1,62 @@
+const Busboy = require('busboy');
+
+function createMultipartBuffer(boundary, size) {
+  const head =
+    '--' + boundary + '\r\n'
+    + 'content-disposition: form-data; name="field1"\r\n'
+    + '\r\n'
+    , tail = '\r\n--' + boundary + '--\r\n'
+    , buffer = Buffer.allocUnsafe(size);
+
+  buffer.write(head, 0, 'ascii');
+  buffer.write(tail, buffer.length - tail.length, 'ascii');
+  return buffer;
+}
+
+for (let i = 0, il = 10; i < il; i++) {
+  const boundary = '-----------------------------168072824752491622650073',
+    d = new Busboy({
+      headers: {
+        'content-type': 'multipart/form-data; boundary=' + boundary
+      }
+    }),
+    mb = 100,
+    buffer = createMultipartBuffer(boundary, mb * 1024 * 1024),
+    callbacks =
+    {
+      partBegin: -1,
+      partEnd: -1,
+      headerField: -1,
+      headerValue: -1,
+      partData: -1,
+      end: -1,
+    };
+
+
+  d.on('part', function (p) {
+    callbacks.partBegin++;
+    p.on('header', function (header) {
+      /*for (var h in header)
+      console.log('Part header: k: ' + inspect(h) + ', v: ' + inspect(header[h]));*/
+    });
+    p.on('data', function (data) {
+      callbacks.partData++;
+      //console.log('Part data: ' + inspect(data.toString()));
+    });
+    p.on('end', function () {
+      //console.log('End of part\n');
+      callbacks.partEnd++;
+    });
+  });
+  d.on('end', function () {
+    //console.log('End of parts');
+    callbacks.end++;
+  });
+
+  const start = +new Date();
+  d.write(buffer);
+  const duration = +new Date - start;
+  const mbPerSec = (mb / (duration / 1000)).toFixed(2);
+
+  console.log(mbPerSec + ' mb/sec');
+}

deps/dicer/bench/dicer-bench-multipart-parser.js → bench/dicer/dicer-bench-multipart-parser.js

@@ -1,4 +1,4 @@
-const Dicer = require('../lib/Dicer')
+const Dicer = require('../../deps/dicer/lib/Dicer')
 
 function createMultipartBuffer(boundary, size) {
   const head =

bench/fastify-busboy-bench.js

@@ -0,0 +1,57 @@
+const Busboy = require('../lib/main');
+
+function createMultipartBuffer(boundary, size) {
+  const head =
+    '--' + boundary + '\r\n'
+    + 'content-disposition: form-data; name="field1"\r\n'
+    + '\r\n'
+    , tail = '\r\n--' + boundary + '--\r\n'
+    , buffer = Buffer.allocUnsafe(size);
+
+  buffer.write(head, 0, 'ascii');
+  buffer.write(tail, buffer.length - tail.length, 'ascii');
+  return buffer;
+}
+
+for (let i = 0, il = 10; i < il; i++) {
+  const boundary = '-----------------------------168072824752491622650073',
+    d = new Busboy({
+      headers: {
+        'content-type': 'multipart/form-data; boundary=' + boundary
+      }
+    }),
+    mb = 100,
+    buffer = createMultipartBuffer(boundary, mb * 1024 * 1024),
+    callbacks =
+    {
+      partBegin: -1,
+      partEnd: -1,
+      headerField: -1,
+      headerValue: -1,
+      partData: -1,
+      end: -1,
+    };
+
+
+  d.on('part', function (p) {
+    callbacks.partBegin++;
+    p.on('header', function (header) {
+    });
+    p.on('data', function (data) {
+      callbacks.partData++;
+    });
+    p.on('end', function () {
+      callbacks.partEnd++;
+    });
+  });
+  d.on('end', function () {
+    callbacks.end++;
+  });
+
+  const start = +new Date();
+  d.write(buffer);
+  const duration = +new Date - start;
+  const mbPerSec = (mb / (duration / 1000)).toFixed(2);
+
+  console.log(mbPerSec + ' mb/sec');
+}

package.json

@@ -19,7 +19,8 @@
   "main": "lib/main",
   "types": "lib/main.d.ts",
   "scripts": {
-    "bench:dicer": "node deps/dicer/bench/dicer-bench-multipart-parser.js",
+    "bench:busboy": "node bench/fastify-busboy-bench.js",
+    "bench:dicer": "node bench/dicer/dicer-bench-multipart-parser.js",
     "coveralls": "nyc report --reporter=lcov",
     "lint": "eslint .",
     "lint:everything": "npm run lint && npm run test:types",
@@ -33,6 +34,7 @@
   },
   "devDependencies": {
     "@types/node": "^16.11.10",
+    "busboy": "^0.3.1",
     "chai": "^4.3.4",
     "eslint": "^8.3.0",
     "eslint-plugin-node": "^11.1.0",