local effil = require 'effil'
function main()
while not isSampAvailable() do wait(0) end
if not isSampfuncsLoaded() and not isCleoLoaded() then return end
while true do wait(0)
if isKeyJustPressed(0x31) then -- 1
-- request GET
local bool, response, statusCode, headers, status = wrapperHttpRequest('https://httpbin.org/get', {
query = {
key = "123"
}
})
print(bool, response)
end
if isKeyJustPressed(0x32) then -- 2
-- standart GET request
local bool, response, statusCode, headers, status = wrapperHttpRequest('https://httpbin.org/get')
print(bool, response)
end
if isKeyJustPressed(0x33) then -- 3
-- callback GET and User-Agent
wrapperHttpRequest('https://httpbin.org/get', {
query = {
unknown = "str"
},
headers = {
['User-Agent'] = 'macintosh',
["Content-Type"] = "application/x-www-form-urlencoded",
["Accept"] = "*/*"
}
}, function (bool, response, statusCode, headers, status)
print(bool, response)
end)
end
if isKeyJustPressed(0x34) then -- 4
-- callback POST
wrapperHttpRequest('https://httpbin.org/post', {
method = 'POST',
body = {
param = 101
}
}, function (bool, response, statusCode, headers, status)
print(bool, response)
end)
end
end
end
function wrapperHttpRequest(url, options, callback) -- return bool, response, statusCode, headers, status
local options = options or {}
local method = options.method or "GET"
local url = (options.query) and url .. "?" .. http_build_query(options.query) or url
local body = (options.body) and http_build_query(options.body) or nil
local headers = options.headers or {["Content-Type"] = "application/x-www-form-urlencoded", ["Accept"] = "*/*"}
local data = {
data = body,
headers = headers
}
if callback then
lua_thread.create(function ()
callback(async_http_request(method, url, data))
end)
else
return async_http_request(method, url, data)
end
end
function url_encode(str)
local str = string.gsub(str, "\\", "\\")
str = string.gsub(str, "([^%w])", function(text)
return string.format("%%%02X", string.byte(text))
end)
return str
end
function http_build_query(query)
local buff = ""
if type(query) == "table" then
for k, v in pairs(query) do
buff = buff .. string.format("%s=%s&", k, url_encode(v))
end
buff = string.reverse(string.gsub(string.reverse(buff), "&", "", 1))
end
return buff;
end
function async_http_request(method, url, args)
local request_thread = effil.thread(function (method, url, args)
local requests = require 'requests'
local result, response = pcall(requests.request, method, url, args)
if result then
response.json, response.xml = nil, nil
return true, response
else
return false, response
end
end)(method, url, args)
-- проверка выполнения потока
local runner = request_thread
while true do
local status, err = runner:status()
if not err then
if status == 'completed' then
local result, response = runner:get()
if result then
return true, response.text, response.status_code, response.headers, response.status
else
return false
end
elseif status == 'canceled' then
return false
end
else
return false
end
wait(0)
end
end
