local ltn12 = require("ltn12")
local proxy_location = "/proxy"
local methods = setmetatable({ }, {
  __index = function(self, name)
    local id = ngx["HTTP_" .. tostring(name:upper())]
    self[name] = id
    return id
  end
})
local set_proxy_location
set_proxy_location = function(loc)
  proxy_location = loc
end
local encode_query_string
do
  local _obj_0 = require("lapis.util")
  encode_query_string = _obj_0.encode_query_string
end
local simple
simple = function(req, body)
  if type(req) == "string" then
    req = {
      url = req
    }
  end
  if body then
    req.method = "POST"
    req.body = body
  end
  if type(req.body) == "table" then
    req.body = encode_query_string(req.body)
    req.headers = req.headers or { }
    req.headers["Content-type"] = "application/x-www-form-urlencoded"
  end
  local res = ngx.location.capture(proxy_location, {
    method = methods[req.method or "GET"],
    body = req.body,
    ctx = {
      headers = req.headers
    },
    vars = {
      _url = req.url
    }
  })
  return res.body, res.status, res.header
end
local request
request = function(url, str_body)
  local return_res_body
  local req
  if type(url) == "table" then
    req = url
  else
    return_res_body = true
    req = {
      url = url,
      source = str_body and ltn12.source.string(str_body),
      headers = str_body and {
        ["Content-type"] = "application/x-www-form-urlencoded"
      }
    }
  end
  req.method = req.method or (req.source and "POST" or "GET")
  local body
  if req.source then
    local buff = { }
    local sink = ltn12.sink.table(buff)
    ltn12.pump.all(req.source, sink)
    body = table.concat(buff)
  end
  local res = ngx.location.capture(proxy_location, {
    method = methods[req.method],
    body = body,
    ctx = {
      headers = req.headers
    },
    vars = {
      _url = req.url
    }
  })
  local out
  if return_res_body then
    out = res.body
  else
    if req.sink then
      ltn12.pump.all(ltn12.source.string(res.body), req.sink)
    end
    out = 1
  end
  return out, res.status, res.header
end
local ngx_replace_headers
ngx_replace_headers = function(new_headers)
  if new_headers == nil then
    new_headers = nil
  end
  local req
  do
    local _obj_0 = ngx
    req = _obj_0.req
  end
  new_headers = new_headers or ngx.ctx.headers
  for k, v in pairs(req.get_headers()) do
    if k ~= 'content-length' then
      req.clear_header(k)
    end
  end
  if new_headers then
    for k, v in pairs(new_headers) do
      req.set_header(k, v)
    end
  end
end
return {
  request = request,
  simple = simple,
  set_proxy_location = set_proxy_location,
  ngx_replace_headers = ngx_replace_headers,
  methods = methods
}