GitHub - MunifTanjim/llhttp.lua: Lua interface for https://github.com/nodejs/llhttp

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()

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