ReachableCEO
54cc5f7308
- Implements Apache APISIX packaging for Cloudron platform. - Includes Dockerfile, CloudronManifest.json, and start.sh. - Configured to use Cloudron's etcd addon. 🤖 Generated with Gemini CLI Co-Authored-By: Gemini <noreply@google.com>
1130 lines
38 KiB
Perl
1130 lines
38 KiB
Perl
#
|
|
# Licensed to the Apache Software Foundation (ASF) under one or more
|
|
# contributor license agreements. See the NOTICE file distributed with
|
|
# this work for additional information regarding copyright ownership.
|
|
# The ASF licenses this file to You under the Apache License, Version 2.0
|
|
# (the "License"); you may not use this file except in compliance with
|
|
# the License. You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
#
|
|
use t::APISIX 'no_plan';
|
|
|
|
no_long_string();
|
|
no_shuffle();
|
|
no_root_location();
|
|
|
|
add_block_preprocessor(sub {
|
|
my ($block) = @_;
|
|
|
|
if (!$block->request) {
|
|
$block->set_value("request", "GET /t");
|
|
}
|
|
});
|
|
|
|
run_tests;
|
|
|
|
__DATA__
|
|
|
|
=== TEST 1: simulate simple SOAP proxy
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local xml2lua = require("xml2lua")
|
|
local xmlhandler = require("xmlhandler.tree")
|
|
local handler = xmlhandler:new()
|
|
local parser = xml2lua.parser(handler)
|
|
parser:parse(body)
|
|
|
|
ngx.print(string.format([[
|
|
<SOAP-ENV:Envelope
|
|
xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">
|
|
<SOAP-ENV:Header/>
|
|
<SOAP-ENV:Body>
|
|
<ns2:getCountryResponse
|
|
xmlns:ns2="http://spring.io/guides/gs-producing-web-service">
|
|
<ns2:country>
|
|
<ns2:name>%s</ns2:name>
|
|
<ns2:population>46704314</ns2:population>
|
|
<ns2:capital>Madrid</ns2:capital>
|
|
<ns2:currency>EUR</ns2:currency>
|
|
</ns2:country>
|
|
</ns2:getCountryResponse>
|
|
</SOAP-ENV:Body>
|
|
</SOAP-ENV:Envelope>
|
|
]], handler.root["soap-env:Envelope"]["soap-env:Body"]["ns0:getCountryRequest"]["ns0:name"]))
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
|
|
local req_template = ngx.encode_base64[[
|
|
<?xml version="1.0"?>
|
|
<soap-env:Envelope xmlns:soap-env="http://schemas.xmlsoap.org/soap/envelope/">
|
|
<soap-env:Body>
|
|
<ns0:getCountryRequest xmlns:ns0="http://spring.io/guides/gs-producing-web-service">
|
|
<ns0:name>{{_escape_xml(name)}}</ns0:name>
|
|
</ns0:getCountryRequest>
|
|
</soap-env:Body>
|
|
</soap-env:Envelope>
|
|
]]
|
|
|
|
local rsp_template = ngx.encode_base64[[
|
|
{% if Envelope.Body.Fault == nil then %}
|
|
{
|
|
"status":"{{_ctx.var.status}}",
|
|
"currency":"{{Envelope.Body.getCountryResponse.country.currency}}",
|
|
"population":{{Envelope.Body.getCountryResponse.country.population}},
|
|
"capital":"{{Envelope.Body.getCountryResponse.country.capital}}",
|
|
"name":"{{Envelope.Body.getCountryResponse.country.name}}"
|
|
}
|
|
{% else %}
|
|
{
|
|
"message":{*_escape_json(Envelope.Body.Fault.faultstring[1])*},
|
|
"code":"{{Envelope.Body.Fault.faultcode}}"
|
|
{% if Envelope.Body.Fault.faultactor ~= nil then %}
|
|
, "actor":"{{Envelope.Body.Fault.faultactor}}"
|
|
{% end %}
|
|
}
|
|
{% end %}
|
|
]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/ws",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
},
|
|
"response": {
|
|
"input_format": "xml",
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template, rsp_template, ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/ws"
|
|
local body = [[{"name": "Spain"}]]
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/json"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
local data1 = core.json.decode(res.body)
|
|
local data2 = core.json.decode[[{"status":"200","currency":"EUR","population":46704314,"capital":"Madrid","name":"Spain"}]]
|
|
assert(core.json.stably_encode(data1) == core.json.stably_encode(data2))
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 2: test JSON-to-JSON
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
assert(data.foo == "hello world" and data.bar == 30)
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foo":"{{name .. " world"}}","bar":{{age+10}}}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local body = [[{"name":"hello","age":20}]]
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/json"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 3: specify wrong input_format
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foo":"{{name .. " world"}}","bar":{{age+10}}}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"input_format": "xml",
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local body = [[{"name":"hello","age":20}]]
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/json"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 400)
|
|
}
|
|
}
|
|
--- error_log
|
|
Error Parsing XML
|
|
|
|
|
|
|
|
=== TEST 4: invalid reference in template
|
|
--- config
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foo":"{{name() .. " world"}}","bar":{{age+10}}}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local body = [[{"name":"hello","age":20}]]
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/json"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 503)
|
|
}
|
|
}
|
|
--- grep_error_log eval
|
|
qr/transform\(\): request template rendering:.*/
|
|
--- grep_error_log_out eval
|
|
qr/attempt to call global 'name' \(a string value\)/
|
|
|
|
|
|
|
|
=== TEST 5: generate request body from scratch
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
assert(data.foo == "hello world")
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{
|
|
"foo":"{{_ctx.var.arg_name .. " world"}}"
|
|
}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo",
|
|
"method": "POST"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar?name=hello"
|
|
local opt = {method = "GET"}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 6: html escape in template
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
if (data == nil) or (data.agent:find("ngx_lua/", 0, true) == nil) then
|
|
return ngx.exit(400)
|
|
end
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
-- html escape would escape '/' to '/' in string, which may be unexpected.
|
|
-- 'lua-resty-http/0.16.1 (Lua) ngx_lua/10021'
|
|
-- would be escaped into
|
|
-- 'lua-resty-http/0.16.1 (Lua) ngx_lua/10021'
|
|
local req_template = [[{
|
|
"agent":"{{_ctx.var.http_user_agent}}"
|
|
}]]
|
|
local admin_body = [[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo",
|
|
"method": "POST"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format(admin_body, req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar?name=hello"
|
|
local opt = {method = "GET"}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 400)
|
|
|
|
-- disable html escape, now it's ok
|
|
local req_template = [[{"agent":"{*_ctx.var.http_user_agent*}"}]]
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format(admin_body, req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 7: parse body in yaml format
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
if data == nil or data.foobar ~= "hello world" then
|
|
return ngx.exit(400)
|
|
end
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[
|
|
{%
|
|
local yaml = require("lyaml")
|
|
local body = yaml.load(_body)
|
|
%}
|
|
{"foobar":"{{body.foobar.foo .. " " .. body.foobar.bar}}"}
|
|
]]
|
|
local admin_body = [[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo",
|
|
"method": "POST"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format(admin_body, req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local body = [[
|
|
foobar:
|
|
foo: hello
|
|
bar: world
|
|
]]
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local opt = {method = "POST", body = body}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 8: test _escape_json
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
if data == nil or data.foobar ~= [[hello "world"]] then
|
|
return ngx.exit(400)
|
|
end
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foobar":{*_escape_json(name)*}}]]
|
|
local admin_body = [[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo",
|
|
"method": "POST"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"input_format": "json",
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format(admin_body, req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local body = [[{"name":"hello \"world\""}]]
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local opt = {method = "POST", body = body}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 9: test _escape_xml
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local xml2lua = require("xml2lua")
|
|
local xmlhandler = require("xmlhandler.tree")
|
|
local handler = xmlhandler:new()
|
|
local parser = xml2lua.parser(handler)
|
|
parser:parse(body)
|
|
assert(handler.root.foobar == "<nil>")
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[<foobar>{*_escape_xml(name)*}</foobar>]]
|
|
local admin_body = [[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo",
|
|
"method": "POST"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"input_format": "json",
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format(admin_body, req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local body = [[{"name":"<nil>"}]]
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local opt = {method = "POST", body = body}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 10: cooperation of proxy-cache plugin
|
|
--- http_config
|
|
lua_shared_dict memory_cache 50m;
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
ngx.say([[
|
|
<SOAP-ENV:Envelope
|
|
xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/">
|
|
<SOAP-ENV:Header/>
|
|
<SOAP-ENV:Body>
|
|
<ns2:CapitalCityResponse
|
|
xmlns:ns2="http://spring.io/guides/gs-producing-web-service">
|
|
<ns2:CapitalCityResult>hello</ns2:CapitalCityResult>
|
|
</ns2:CapitalCityResponse>
|
|
</SOAP-ENV:Body>
|
|
</SOAP-ENV:Envelope>
|
|
]])
|
|
}
|
|
}
|
|
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
|
|
local req_template = ngx.encode_base64[[
|
|
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:web="http://www.oorsprong.org/websamples.countryinfo">
|
|
<soapenv:Header/>
|
|
<soapenv:Body>
|
|
<web:CapitalCity>
|
|
<web:sCountryISOCode>{{_escape_xml(country)}}</web:sCountryISOCode>
|
|
</web:CapitalCity>
|
|
</soapenv:Body>
|
|
</soapenv:Envelope>
|
|
]]
|
|
|
|
local rsp_template = ngx.encode_base64[[
|
|
{"result": {*_escape_json(Envelope.Body.CapitalCityResponse.CapitalCityResult)*}}
|
|
]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/capital",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"set": {
|
|
"Accept-Encoding": "identity",
|
|
"Content-Type": "text/xml"
|
|
},
|
|
"uri": "/demo"
|
|
},
|
|
"proxy-cache":{
|
|
"cache_strategy": "memory",
|
|
"cache_bypass": ["$arg_bypass"],
|
|
"cache_http_status": [200],
|
|
"cache_key": ["$uri", "-cache-id"],
|
|
"cache_method": ["POST"],
|
|
"hide_cache_headers": true,
|
|
"no_cache": ["$arg_test"],
|
|
"cache_zone": "memory_cache"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"input_format": "json",
|
|
"template": "%s"
|
|
},
|
|
"response": {
|
|
"input_format": "xml",
|
|
"template": "%s"
|
|
}
|
|
},
|
|
"response-rewrite":{
|
|
"headers": {
|
|
"set": {
|
|
"Content-Type": "application/json"
|
|
}
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template, rsp_template, ngx.var.server_port)
|
|
)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/capital"
|
|
local body = [[{"country": "foo"}]]
|
|
local opt = {method = "POST", body = body}
|
|
local httpc = http.new()
|
|
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
local data = core.json.decode(res.body)
|
|
assert(data.result == "hello")
|
|
assert(res.headers["Apisix-Cache-Status"] == "MISS")
|
|
|
|
local res2 = httpc:request_uri(uri, opt)
|
|
assert(res2.status == 200)
|
|
local data2 = core.json.decode(res2.body)
|
|
assert(data2.result == "hello")
|
|
assert(res2.headers["Apisix-Cache-Status"] == "HIT")
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 11: return raw body with _body anytime
|
|
--- http_config
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
ngx.header.content_type = "application/json"
|
|
ngx.print('{"result": "hello world"}')
|
|
}
|
|
}
|
|
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
|
|
local rsp_template = ngx.encode_base64[[
|
|
{"raw_body": {*_escape_json(_body)*}, "result": {*_escape_json(result)*}}
|
|
]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/capital",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"response": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], rsp_template, ngx.var.server_port)
|
|
)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/capital"
|
|
local opt = {method = "GET", headers = {["Content-Type"] = "application/json"}}
|
|
local httpc = http.new()
|
|
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
local data = core.json.decode(res.body)
|
|
assert(data.result == "hello world")
|
|
assert(data.raw_body == '{"result": "hello world"}')
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 12: empty xml value should be rendered as empty string
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
ngx.print([[
|
|
<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xrd="http://x-road.eu/xsd/xroad.xsd" xmlns:prod="http://rr.x-road.eu/producer" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:id="http://x-road.eu/xsd/identifiers" xmlns:repr="http://x-road.eu/xsd/representation.xsd" xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/">
|
|
<SOAP-ENV:Body>
|
|
<prod:RR58isikEpiletResponse>
|
|
<request><Isikukood>33333333333</Isikukood></request>
|
|
<response>
|
|
<Isikukood>33333333333</Isikukood>
|
|
<KOVKood></KOVKood>
|
|
</response>
|
|
</prod:RR58isikEpiletResponse>
|
|
</SOAP-ENV:Body>
|
|
</SOAP-ENV:Envelope>
|
|
]])
|
|
}
|
|
}
|
|
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
|
|
local rsp_template = ngx.encode_base64[[
|
|
{ "KOVKood":"{{Envelope.Body.RR58isikEpiletResponse.response.KOVKood}}" }
|
|
]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/ws",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"response": {
|
|
"input_format": "xml",
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], rsp_template, ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/ws"
|
|
local opt = {method = "GET"}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
local data1 = core.json.decode(res.body)
|
|
local data2 = core.json.decode[[{"KOVKood":""}]]
|
|
assert(core.json.stably_encode(data1) == core.json.stably_encode(data2))
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 13: test x-www-form-urlencoded to JSON
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
assert(data.foo == "hello world" and data.bar == 30)
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foo":"{{name .. " world"}}","bar":{{age+10}}}]]
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local data = {name = "hello", age = 20}
|
|
local body = ngx.encode_args(data)
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/x-www-form-urlencoded"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 14: test get request to JSON
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = core.json.decode(body)
|
|
assert(data.foo == "hello world" and data.bar == 30)
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = [[{"foo":"{{name .. " world"}}","bar":{{age+10}}}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar" .. "?name=hello&age=20"
|
|
local opt = {method = "GET"}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 15: test input is in base64-encoded urlencoded format
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
local data = ngx.decode_args(body)
|
|
assert(data.foo == "hello world" and data.bar == "30")
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
local req_template = ngx.encode_base64[[foo={{name .. " world"}}&bar={{age+10}}]]
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"template_is_base64": true,
|
|
"template": "%s"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], req_template:gsub('"', '\\"'), ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local core = require("apisix.core")
|
|
local http = require("resty.http")
|
|
local uri = "http://127.0.0.1:" .. ngx.var.server_port .. "/foobar"
|
|
local data = {name = "hello", age = 20}
|
|
local body = ngx.encode_args(data)
|
|
local opt = {method = "POST", body = body, headers = {["Content-Type"] = "application/x-www-form-urlencoded"}}
|
|
local httpc = http.new()
|
|
local res = httpc:request_uri(uri, opt)
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
|
|
|
|
|
|
=== TEST 16: test for missing Content-Type and skip body parsing
|
|
--- config
|
|
location /demo {
|
|
content_by_lua_block {
|
|
local core = require("apisix.core")
|
|
local body = core.request.get_body()
|
|
assert(body == "{\"message\": \"actually json\"}")
|
|
}
|
|
}
|
|
location /t {
|
|
content_by_lua_block {
|
|
local t = require("lib.test_admin")
|
|
local core = require("apisix.core")
|
|
|
|
local code, body = t.test('/apisix/admin/routes/1',
|
|
ngx.HTTP_PUT,
|
|
string.format([[{
|
|
"uri": "/foobar",
|
|
"plugins": {
|
|
"proxy-rewrite": {
|
|
"uri": "/demo"
|
|
},
|
|
"body-transformer": {
|
|
"request": {
|
|
"input_format": "plain",
|
|
"template": "{\"message\": \"{* string.gsub(_body, 'not ', '') *}\"}"
|
|
}
|
|
}
|
|
},
|
|
"upstream": {
|
|
"type": "roundrobin",
|
|
"nodes": {
|
|
"127.0.0.1:%d": 1
|
|
}
|
|
}
|
|
}]], ngx.var.server_port)
|
|
)
|
|
|
|
if code >= 300 then
|
|
ngx.status = code
|
|
return
|
|
end
|
|
ngx.sleep(0.5)
|
|
|
|
local http = require("resty.http")
|
|
local httpc = http.new()
|
|
local res, err = httpc:request_uri("http://127.0.0.1:" .. ngx.var.server_port .. "/foobar", {
|
|
method = "POST",
|
|
body = "not actually json",
|
|
})
|
|
assert(res.status == 200)
|
|
}
|
|
}
|
|
--- no_error_log
|
|
no input format to parse
|