llhttp (original) (raw)

llhttp.lua

Lua interface for nodejs/llhttp.

Usage

local Parser = require("llhttp.parser") local enum = require("llhttp.enum")

local parser = Parser:new({ type = enum.type.REQUEST, })

local request = "GET /test HTTP/1.1\r\nContent-Length: 12\r\n\r\nHello World!\r\n" local data = { _body_chunks = {} }

local chunk_size = 4 local offset = 1

while offset <= #request do local buf = string.sub(request, offset, math.min(offset + chunk_size - 1, #request))

local err, consumed, pause_cause = parser:execute(buf)

if err == enum.errno.PAUSED then if pause_cause == enum.pause_cause.METHOD_COMPLETED then data.method = parser:get_method() elseif pause_cause == enum.pause_cause.URL_COMPLETED then data.url = parser:pull_url() elseif pause_cause == enum.pause_cause.HEADERS_COMPLETED then data.headers = parser:pull_headers() elseif pause_cause == enum.pause_cause.BODY_CHUNK_READY or pause_cause == enum.pause_cause.MESSAGE_COMPLETED_WITH_BODY_CHUNK then data._body_chunks[#data._body_chunks + 1] = parser:pull_body_chunk() end

if
  pause_cause == enum.pause_cause.MESSAGE_COMPLETED_WITH_BODY_CHUNK
  or pause_cause == enum.pause_cause.MESSAGE_COMPLETED
then
  data.body = table.concat(data._body_chunks)
end

parser:resume()

elseif err == enum.errno.PAUSED_UPGRADE then parser:resume_after_upgrade() elseif err ~= enum.errno.OK then error(parser:get_error_reason()) end

offset = offset + consumed end

print(string.format("%s %s", data.method, data.url)) print("=======") for k, v in pairs(data.headers) do print(string.format("%s: %s", k, v)) end print("=======") print(data.body)

parser:reset()

LuaJIT FFI

local ffi = require("ffi")

local llhttp_library_path = "./libllhttp.so" local llhttpffi = require("llhttp.ffi").load(llhttp_library_path)

local ctype = llhttpffi.ctype local enum = llhttpffi.enum local lib = llhttpffi.lib

local llhttp_settings = ctype.llhttp_settings() lib.llhttp_settings_init(llhttp_settings)

llhttp_settings.on_message_begin = function() print("on_message_begin") return enum.errno.OK end

llhttp_settings.on_message_complete = function() print("on_message_complete") return enum.errno.OK end

local llhttp = ctype.llhttp() lib.llhttp_init(llhttp, enum.type.REQUEST, llhttp_settings)

local request = "GET / HTTP/1.1\r\n\r\n" local buf_len = string.len(request) local buf = ctype.char_ptr(buf_len, request)

local err = lib.llhttp_execute(llhttp, buf, buf_len) if err ~= enum.errno.OK then print(string.format("error(%s): %s", ffi.string(lib.llhttp_errno_name(err)), ffi.string(llhttp.reason))) end

License

Licensed under the MIT License. Check the LICENSE file for details.