switch (m) {

case HTTP_DELETE: return delete_sym;

case HTTP_GET: return get_sym;

case HTTP_HEAD: return head_sym;

case HTTP_POST: return post_sym;

case HTTP_PUT: return put_sym;

case HTTP_CONNECT: return connect_sym;

case HTTP_OPTIONS: return options_sym;

case HTTP_TRACE: return trace_sym;

case HTTP_PATCH: return patch_sym;

case HTTP_COPY: return copy_sym;

case HTTP_LOCK: return lock_sym;

case HTTP_MKCOL: return mkcol_sym;

case HTTP_MOVE: return move_sym;

case HTTP_PROPFIND: return propfind_sym;

case HTTP_PROPPATCH: return proppatch_sym;

case HTTP_UNLOCK: return unlock_sym;

case HTTP_REPORT: return report_sym;

case HTTP_MKACTIVITY: return mkactivity_sym;

case HTTP_CHECKOUT: return checkout_sym;

case HTTP_MERGE: return merge_sym;

case HTTP_MSEARCH: return msearch_sym;

case HTTP_NOTIFY: return notify_sym;

case HTTP_SUBSCRIBE: return subscribe_sym;

case HTTP_UNSUBSCRIBE:return unsubscribe_sym;

default: return unknown_method_sym;

}

StringPtr() {

on_heap_ = false;

Reset();

}

~StringPtr() {

Reset();

}

void Reset() {

if (on_heap_) {

delete[] str_;

on_heap_ = false;

}

str_ = NULL;

size_ = 0;

}

void Update(const char* str, size_t size) {

if (str_ == NULL)

str_ = str;

else if (on_heap_ || str_ + size != str) {

// Non-consecutive input, make a copy on the heap.

// TODO Use slab allocation, O(n) allocs is bad.

char* s = new char[size_ + size];

memcpy(s, str_, size_);

memcpy(s + size_, str, size);

if (on_heap_)

delete[] str_;

else

on_heap_ = true;

str_ = s;

}

size_ += size;

}

Handle<String> ToString() const {

if (str_)

return String::New(str_, size_);

else

return String::Empty();

}

const char* str_;

bool on_heap_;

size_t size_;

Parser(enum http_parser_type type) : ObjectWrap() {

Init(type);

}

~Parser() {

}

HTTP_CB(on_message_begin) {

num_fields_ = num_values_ = -1;

url_.Reset();

return 0;

}

HTTP_DATA_CB(on_url) {

url_.Update(at, length);

return 0;

}

HTTP_DATA_CB(on_header_field) {

if (num_fields_ == num_values_) {

// start of new field name

if (++num_fields_ == ARRAY_SIZE(fields_)) {

Flush();

num_fields_ = 0;

num_values_ = -1;

}

fields_[num_fields_].Reset();

}

assert(num_fields_ < (int)ARRAY_SIZE(fields_));

assert(num_fields_ == num_values_ + 1);

fields_[num_fields_].Update(at, length);

return 0;

}

HTTP_DATA_CB(on_header_value) {

if (num_values_ != num_fields_) {

// start of new header value

values_[++num_values_].Reset();

}

assert(num_values_ < (int)ARRAY_SIZE(values_));

assert(num_values_ == num_fields_);

values_[num_values_].Update(at, length);

return 0;

}

HTTP_CB(on_headers_complete) {

Local<Value> cb = handle_->Get(on_headers_complete_sym);

if (!cb->IsFunction())

return 0;

Local<Object> message_info = Object::New();

if (have_flushed_) {

// Slow case, flush remaining headers.

Flush();

}

else {

// Fast case, pass headers and URL to JS land.

message_info->Set(headers_sym, CreateHeaders());

if (parser_.type == HTTP_REQUEST)

message_info->Set(url_sym, url_.ToString());

}

num_fields_ = num_values_ = -1;

// METHOD

if (parser_.type == HTTP_REQUEST) {

message_info->Set(method_sym, method_to_str(parser_.method));

}

// STATUS

if (parser_.type == HTTP_RESPONSE) {

message_info->Set(status_code_sym, Integer::New(parser_.status_code));

}

// VERSION

message_info->Set(version_major_sym, Integer::New(parser_.http_major));

message_info->Set(version_minor_sym, Integer::New(parser_.http_minor));

message_info->Set(should_keep_alive_sym,

http_should_keep_alive(&parser_) ? True() : False());

message_info->Set(upgrade_sym, parser_.upgrade ? True() : False());

Local<Value> argv[1] = { message_info };

Local<Value> head_response =

Local<Function>::Cast(cb)->Call(handle_, 1, argv);

if (head_response.IsEmpty()) {

got_exception_ = true;

return -1;

}

return head_response->IsTrue() ? 1 : 0;

}

HTTP_DATA_CB(on_body) {

HandleScope scope;

Local<Value> cb = handle_->Get(on_body_sym);

if (!cb->IsFunction())

return 0;

Handle<Value> argv[3] = {

*current_buffer,

Integer::New(at - current_buffer_data),

Integer::New(length)

};

Local<Value> r = Local<Function>::Cast(cb)->Call(handle_, 3, argv);

if (r.IsEmpty()) {

got_exception_ = true;

return -1;

}

return 0;

}

HTTP_CB(on_message_complete) {

HandleScope scope;

if (num_fields_ != -1)

Flush(); // Flush trailing HTTP headers.

Local<Value> cb = handle_->Get(on_message_complete_sym);

if (!cb->IsFunction())

return 0;

Local<Value> r = Local<Function>::Cast(cb)->Call(handle_, 0, NULL);

if (r.IsEmpty()) {

got_exception_ = true;

return -1;

}

return 0;

}

static Handle<Value> New(const Arguments& args) {

HandleScope scope;

http_parser_type type =

static_cast<http_parser_type>(args[0]->Int32Value());

if (type != HTTP_REQUEST && type != HTTP_RESPONSE) {

return ThrowException(Exception::Error(String::New(

"Argument must be HTTPParser.REQUEST or HTTPParser.RESPONSE")));

}

Parser* parser = new Parser(type);

parser->Wrap(args.This());

return args.This();

}

// var bytesParsed = parser->execute(buffer, off, len);

static Handle<Value> Execute(const Arguments& args) {

HandleScope scope;

Parser* parser = ObjectWrap::Unwrap<Parser>(args.This());

assert(!current_buffer);

assert(!current_buffer_data);

if (current_buffer) {

return ThrowException(Exception::TypeError(

String::New("Already parsing a buffer")));

}

Local<Value> buffer_v = args[0];

if (!Buffer::HasInstance(buffer_v)) {

return ThrowException(Exception::TypeError(

String::New("Argument should be a buffer")));

}

Local<Object> buffer_obj = buffer_v->ToObject();

char *buffer_data = Buffer::Data(buffer_obj);

size_t buffer_len = Buffer::Length(buffer_obj);

size_t off = args[1]->Int32Value();

if (off >= buffer_len) {

return ThrowException(Exception::Error(

String::New("Offset is out of bounds")));

}

size_t len = args[2]->Int32Value();

if (off+len > buffer_len) {

return ThrowException(Exception::Error(

String::New("Length is extends beyond buffer")));

}

// Assign 'buffer_' while we parse. The callbacks will access that varible.

current_buffer = &buffer_v;

current_buffer_data = buffer_data;

current_buffer_len = buffer_len;

parser->got_exception_ = false;

size_t nparsed =

http_parser_execute(&parser->parser_, &settings, buffer_data + off, len);

// Unassign the 'buffer_' variable

assert(current_buffer);

current_buffer = NULL;

current_buffer_data = NULL;

// If there was an exception in one of the callbacks

if (parser->got_exception_) return Local<Value>();

Local<Integer> nparsed_obj = Integer::New(nparsed);

// If there was a parse error in one of the callbacks

// TODO What if there is an error on EOF?

if (!parser->parser_.upgrade && nparsed != len) {

Local<Value> e = Exception::Error(String::NewSymbol("Parse Error"));

Local<Object> obj = e->ToObject();

obj->Set(String::NewSymbol("bytesParsed"), nparsed_obj);

return scope.Close(e);

} else {

return scope.Close(nparsed_obj);

}

}

static Handle<Value> Finish(const Arguments& args) {

HandleScope scope;

Parser* parser = ObjectWrap::Unwrap<Parser>(args.This());

assert(!current_buffer);

parser->got_exception_ = false;

int rv = http_parser_execute(&(parser->parser_), &settings, NULL, 0);

if (parser->got_exception_) return Local<Value>();

if (rv != 0) {

Local<Value> e = Exception::Error(String::NewSymbol("Parse Error"));

Local<Object> obj = e->ToObject();

obj->Set(String::NewSymbol("bytesParsed"), Integer::New(0));

return scope.Close(e);

}

return Undefined();

}

static Handle<Value> Reinitialize(const Arguments& args) {

HandleScope scope;

http_parser_type type =

static_cast<http_parser_type>(args[0]->Int32Value());

if (type != HTTP_REQUEST && type != HTTP_RESPONSE) {

return ThrowException(Exception::Error(String::New(

"Argument must be HTTPParser.REQUEST or HTTPParser.RESPONSE")));

}

Parser* parser = ObjectWrap::Unwrap<Parser>(args.This());

parser->Init(type);

return Undefined();

}

Local<Array> CreateHeaders() {

// num_values_ is either -1 or the entry # of the last header

// so num_values_ == 0 means there's a single header

Local<Array> headers = Array::New(2 * (num_values_ + 1));

for (int i = 0; i < num_values_ + 1; ++i) {

headers->Set(2 * i, fields_[i].ToString());

headers->Set(2 * i + 1, values_[i].ToString());

}

return headers;

}

// spill headers and request path to JS land

void Flush() {

HandleScope scope;

Local<Value> cb = handle_->Get(on_headers_sym);

if (!cb->IsFunction())

return;

Handle<Value> argv[2] = {

CreateHeaders(),

url_.ToString()

};

Local<Value> r = Local<Function>::Cast(cb)->Call(handle_, 2, argv);

if (r.IsEmpty())

got_exception_ = true;

url_.Reset();

have_flushed_ = true;

}

void Init(enum http_parser_type type) {

http_parser_init(&parser_, type);

url_.Reset();

num_fields_ = -1;

num_values_ = -1;

have_flushed_ = false;

got_exception_ = false;

}

http_parser parser_;

StringPtr fields_[32]; // header fields

StringPtr values_[32]; // header values

StringPtr url_;

int num_fields_;

int num_values_;

bool have_flushed_;

bool got_exception_;

HandleScope scope;

Local<FunctionTemplate> t = FunctionTemplate::New(Parser::New);

t->InstanceTemplate()->SetInternalFieldCount(1);

t->SetClassName(String::NewSymbol("HTTPParser"));

PropertyAttribute attrib = (PropertyAttribute) (ReadOnly | DontDelete);

t->Set(String::NewSymbol("REQUEST"), Integer::New(HTTP_REQUEST), attrib);

t->Set(String::NewSymbol("RESPONSE"), Integer::New(HTTP_RESPONSE), attrib);

NODE_SET_PROTOTYPE_METHOD(t, "execute", Parser::Execute);

NODE_SET_PROTOTYPE_METHOD(t, "finish", Parser::Finish);

NODE_SET_PROTOTYPE_METHOD(t, "reinitialize", Parser::Reinitialize);

target->Set(String::NewSymbol("HTTPParser"), t->GetFunction());

on_headers_sym = NODE_PSYMBOL("onHeaders");

on_headers_complete_sym = NODE_PSYMBOL("onHeadersComplete");

on_body_sym = NODE_PSYMBOL("onBody");

on_message_complete_sym = NODE_PSYMBOL("onMessageComplete");

delete_sym = NODE_PSYMBOL("DELETE");

get_sym = NODE_PSYMBOL("GET");

head_sym = NODE_PSYMBOL("HEAD");

post_sym = NODE_PSYMBOL("POST");

put_sym = NODE_PSYMBOL("PUT");

connect_sym = NODE_PSYMBOL("CONNECT");

options_sym = NODE_PSYMBOL("OPTIONS");

trace_sym = NODE_PSYMBOL("TRACE");

patch_sym = NODE_PSYMBOL("PATCH");

copy_sym = NODE_PSYMBOL("COPY");

lock_sym = NODE_PSYMBOL("LOCK");

mkcol_sym = NODE_PSYMBOL("MKCOL");

move_sym = NODE_PSYMBOL("MOVE");

propfind_sym = NODE_PSYMBOL("PROPFIND");

proppatch_sym = NODE_PSYMBOL("PROPPATCH");

unlock_sym = NODE_PSYMBOL("UNLOCK");

report_sym = NODE_PSYMBOL("REPORT");

mkactivity_sym = NODE_PSYMBOL("MKACTIVITY");

checkout_sym = NODE_PSYMBOL("CHECKOUT");

merge_sym = NODE_PSYMBOL("MERGE");

msearch_sym = NODE_PSYMBOL("M-SEARCH");

notify_sym = NODE_PSYMBOL("NOTIFY");

subscribe_sym = NODE_PSYMBOL("SUBSCRIBE");

unsubscribe_sym = NODE_PSYMBOL("UNSUBSCRIBE");;

unknown_method_sym = NODE_PSYMBOL("UNKNOWN_METHOD");

method_sym = NODE_PSYMBOL("method");

status_code_sym = NODE_PSYMBOL("statusCode");

http_version_sym = NODE_PSYMBOL("httpVersion");

version_major_sym = NODE_PSYMBOL("versionMajor");

version_minor_sym = NODE_PSYMBOL("versionMinor");

should_keep_alive_sym = NODE_PSYMBOL("shouldKeepAlive");

upgrade_sym = NODE_PSYMBOL("upgrade");

headers_sym = NODE_PSYMBOL("headers");

url_sym = NODE_PSYMBOL("url");

settings.on_message_begin = Parser::on_message_begin;

settings.on_url = Parser::on_url;

settings.on_header_field = Parser::on_header_field;

settings.on_header_value = Parser::on_header_value;

settings.on_headers_complete = Parser::on_headers_complete;

settings.on_body = Parser::on_body;

settings.on_message_complete = Parser::on_message_complete;