var common = require('../common');
var CHUNK_LENGTH = 10,
    multipartParser = require(common.lib + '/multipart_parser'),
    MultipartParser = multipartParser.MultipartParser,
    parser = new MultipartParser(),
    fixtures = require(TEST_FIXTURES + '/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);
});