var common = require('../common'); var CHUNK_LENGTH = 10, multipartParser = require(common.lib + '/multipart_parser'), MultipartParser = multipartParser.MultipartParser, parser = new MultipartParser(), fixtures = require('../fixture/multipart'), Buffer = require('buffer').Buffer; Object.keys(fixtures).forEach(function(name) { var fixture = fixtures[name], buffer = new Buffer(Buffer.byteLength(fixture.raw, 'binary')), offset = 0, chunk, nparsed, parts = [], part = null, headerField, headerValue, endCalled = ''; parser.initWithBoundary(fixture.boundary); parser.onPartBegin = function() { part = {headers: {}, data: ''}; parts.push(part); headerField = ''; headerValue = ''; }; parser.onHeaderField = function(b, start, end) { headerField += b.toString('ascii', start, end); }; parser.onHeaderValue = function(b, start, end) { headerValue += b.toString('ascii', start, end); } parser.onHeaderEnd = function() { part.headers[headerField] = headerValue; headerField = ''; headerValue = ''; }; parser.onPartData = function(b, start, end) { var str = b.toString('ascii', start, end); part.data += b.slice(start, end); } parser.onEnd = function() { endCalled = true; } buffer.write(fixture.raw, 'binary', 0); while (offset < buffer.length) { if (offset + CHUNK_LENGTH < buffer.length) { chunk = buffer.slice(offset, offset+CHUNK_LENGTH); } else { chunk = buffer.slice(offset, buffer.length); } offset = offset + CHUNK_LENGTH; nparsed = parser.write(chunk); if (nparsed != chunk.length) { if (fixture.expectError) { return; } puts('-- ERROR --'); p(chunk.toString('ascii')); throw new Error(chunk.length+' bytes written, but only '+nparsed+' bytes parsed!'); } } if (fixture.expectError) { throw new Error('expected parse error did not happen'); } assert.ok(endCalled); assert.deepEqual(parts, fixture.parts); });