blob: fbaaea43bef62c1e7b6c4bb8abe5f5404bf88a51 [file] [log] [blame]
#
# 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';
repeat_each(1);
no_long_string();
no_root_location();
log_level("debug");
add_block_preprocessor(sub {
my ($block) = @_;
my $extra_yaml_config = <<_EOC_;
plugins:
- public-api
- batch-requests
_EOC_
$block->set_value("extra_yaml_config", $extra_yaml_config);
if ((!defined $block->error_log) && (!defined $block->no_error_log)) {
$block->set_value("no_error_log", "[error]");
}
});
run_tests;
__DATA__
=== TEST 1: pre-create public API route
--- config
location /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/admin/routes/1',
ngx.HTTP_PUT,
[[{
"plugins": {
"public-api": {}
},
"uri": "/apisix/batch-requests"
}]]
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- response_body
passed
=== TEST 2: sanity
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"query": {
"base": "base_query",
"conflict": "query_value"
},
"headers": {
"Base-Header": "base",
"ConflictHeader": "header_value",
"OuterConflict": "common_value"
},
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world",
"ConflictHeader": "b-header-value"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d",
"query": {
"one": "thing",
"conflict": "d_value"
}
}]
}]=],
[=[[
{
"status": 200,
"body":"B",
"headers": {
"Client-IP": "127.0.0.1",
"Base-Header": "base",
"Base-Query": "base_query",
"X-Res": "B",
"X-Header1": "hello",
"X-Header2": "world",
"X-Conflict-Header": "b-header-value",
"X-OuterConflict": "common_value"
}
},
{
"status": 201,
"body":"C",
"headers": {
"Client-IP-From-Hdr": "127.0.0.1",
"Base-Header": "base",
"Base-Query": "base_query",
"X-Res": "C",
"X-Method": "PUT"
}
},
{
"status": 202,
"body":"D",
"headers": {
"Base-Header": "base",
"Base-Query": "base_query",
"X-Res": "D",
"X-Query-One": "thing",
"X-Query-Conflict": "d_value"
}
}
]]=],
{
ConflictHeader = "outer_header",
OuterConflict = "outer_conflict"
})
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.status = 200
ngx.header["Client-IP"] = ngx.var.remote_addr
ngx.header["Base-Header"] = ngx.req.get_headers()["Base-Header"]
ngx.header["Base-Query"] = ngx.var.arg_base
ngx.header["X-Header1"] = ngx.req.get_headers()["Header1"]
ngx.header["X-Header2"] = ngx.req.get_headers()["Header2"]
ngx.header["X-Conflict-Header"] = ngx.req.get_headers()["ConflictHeader"]
ngx.header["X-OuterConflict"] = ngx.req.get_headers()["OuterConflict"]
ngx.header["X-Res"] = "B"
ngx.print("B")
}
}
location = /c {
content_by_lua_block {
ngx.status = 201
ngx.header["Client-IP-From-Hdr"] = ngx.req.get_headers()["X-Real-IP"]
ngx.header["Base-Header"] = ngx.req.get_headers()["Base-Header"]
ngx.header["Base-Query"] = ngx.var.arg_base
ngx.header["X-Res"] = "C"
ngx.header["X-Method"] = ngx.req.get_method()
ngx.print("C")
}
}
location = /d {
content_by_lua_block {
ngx.status = 202
ngx.header["Base-Header"] = ngx.req.get_headers()["Base-Header"]
ngx.header["Base-Query"] = ngx.var.arg_base
ngx.header["X-Query-One"] = ngx.var.arg_one
ngx.header["X-Query-Conflict"] = ngx.var.arg_conflict
ngx.header["X-Res"] = "D"
ngx.print("D")
}
}
--- request
GET /aggregate
--- response_body
passed
=== TEST 3: missing pipeline
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline1":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: object matches none of the required: [\"pipeline\"]"}
=== TEST 4: timeout is not number
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": "200",
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"timeout\" validation failed: wrong type: expected integer, got string"}
=== TEST 5: different response time
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": 2000,
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=],
[=[[
{
"status": 200
},
{
"status": 201
},
{
"status": 202
}
]]=]
)
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.sleep(0.02)
ngx.status = 200
}
}
location = /c {
content_by_lua_block {
ngx.sleep(0.05)
ngx.status = 201
}
}
location = /d {
content_by_lua_block {
ngx.sleep(1)
ngx.status = 202
}
}
--- request
GET /aggregate
--- response_body
passed
=== TEST 6: last request timeout
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": 100,
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=],
[=[[
{
"status": 200
},
{
"status": 201
},
{
"status": 504,
"reason": "upstream timeout"
}
]]=]
)
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.status = 200
}
}
location = /c {
content_by_lua_block {
ngx.status = 201
}
}
location = /d {
content_by_lua_block {
ngx.sleep(1)
ngx.status = 202
}
}
--- request
GET /aggregate
--- response_body
passed
--- error_log
timeout
=== TEST 7: first request timeout
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": 100,
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=],
[=[[
{
"status": 504,
"reason": "upstream timeout"
}
]]=]
)
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.sleep(1)
ngx.status = 200
}
}
location = /c {
content_by_lua_block {
ngx.status = 201
}
}
location = /d {
content_by_lua_block {
ngx.status = 202
}
}
--- request
GET /aggregate
--- response_body
passed
--- error_log
timeout
=== TEST 8: no body in request
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
nil,
nil
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"no request body, you should give at least one pipeline setting"}
=== TEST 9: invalid body
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
"invalid json string"
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"invalid request body: invalid json string, err: Expected value but found invalid token at character 1"}
=== TEST 10: invalid pipeline's path
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline":[
{
"path": ""
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"pipeline\" validation failed: failed to validate item 1: property \"path\" validation failed: string too short, expected at least 1, got 0"}
=== TEST 11: invalid pipeline's method
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline":[{
"path": "/c",
"method": "put"
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"pipeline\" validation failed: failed to validate item 1: property \"method\" validation failed: matches none of the enum values"}
=== TEST 12: invalid pipeline's version
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline":[{
"path": "/d",
"version":1.2
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"pipeline\" validation failed: failed to validate item 1: property \"version\" validation failed: matches none of the enum values"}
=== TEST 13: invalid pipeline's ssl
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline":[{
"path": "/d",
"ssl_verify":1.2
}]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"pipeline\" validation failed: failed to validate item 1: property \"ssl_verify\" validation failed: wrong type: expected boolean, got number"}
=== TEST 14: invalid pipeline's number
--- config
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"pipeline":[]
}]=]
)
ngx.status = code
ngx.print(body)
}
}
--- request
GET /aggregate
--- error_code: 400
--- response_body
{"error_msg":"bad request body: property \"pipeline\" validation failed: expect array to have at least 1 items"}
=== TEST 15: when client body has been wrote to temp file
--- config
client_body_in_file_only on;
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": 100,
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=],
[=[[
{
"status": 200
},
{
"status": 201
},
{
"status": 202
}
]]=]
)
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.status = 200
}
}
location = /c {
content_by_lua_block {
ngx.status = 201
}
}
location = /d {
content_by_lua_block {
ngx.status = 202
}
}
--- request
GET /aggregate
--- response_body
passed
=== TEST 16: copy all header to every request except content
--- config
client_body_in_file_only on;
location = /aggregate {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"timeout": 1000,
"pipeline":[
{
"path": "/b",
"headers": {
"Header1": "hello",
"Header2": "world"
}
},{
"path": "/c",
"method": "PUT"
},{
"path": "/d"
}]
}]=],
[=[[
{
"status": 200,
"headers": {
"X-Cookie": "request-cookies-b",
"X-HeaderB": "request-header-b"
}
},
{
"status": 201,
"headers": {
"X-Cookie": "request-cookies-c",
"X-HeaderC": "request-header-c"
}
},
{
"status": 202,
"headers": {
"X-Cookie": "request-cookies-d",
"X-HeaderD": "request-header-d"
}
}
]]=],
{
Cookie = "request-cookies",
OuterHeader = "request-header"
})
ngx.status = code
ngx.say(body)
}
}
location = /b {
content_by_lua_block {
ngx.status = 200
ngx.header["X-Cookie"] = ngx.req.get_headers()["Cookie"] .. "-b"
ngx.header["X-HeaderB"] = ngx.req.get_headers()["OuterHeader"] .. "-b"
}
}
location = /c {
content_by_lua_block {
ngx.status = 201
ngx.header["X-Cookie"] = ngx.req.get_headers()["Cookie"] .. "-c"
ngx.header["X-HeaderC"] = ngx.req.get_headers()["OuterHeader"] .. "-c"
}
}
location = /d {
content_by_lua_block {
ngx.status = 202
ngx.header["X-Cookie"] = ngx.req.get_headers()["Cookie"] .. "-d"
ngx.header["X-HeaderD"] = ngx.req.get_headers()["OuterHeader"] .. "-d"
}
}
--- request
GET /aggregate
--- response_body
passed
=== TEST 17: exceed default body limit size (check header)
--- config
location = /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
("1234"):rep(1024 * 1024)
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- error_code: 413
--- response_body eval
qr/\{"error_msg":"request size 4194304 is greater than the maximum size 1048576 allowed"\}/
=== TEST 18: exceed default body limit size (check file size)
--- request eval
"POST /apisix/batch-requests
" . ("1000\r
" . ("11111111" x 512) . "\r
") x 257 . "0\r
\r
"
--- more_headers
Transfer-Encoding: chunked
--- error_code: 413
--- response_body eval
qr/\{"error_msg":"request size 1052672 is greater than the maximum size 1048576 allowed"\}/
--- error_log
attempt to read body from file
=== TEST 19: add plugin metadata
--- config
location /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/admin/plugin_metadata/batch-requests',
ngx.HTTP_PUT,
[[{
"max_body_size": 2048
}]]
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- response_body
passed
=== TEST 20: exceed body limit size
--- config
location = /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
("1234"):rep(1024)
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- error_code: 413
--- response_body eval
qr/\{"error_msg":"request size 4096 is greater than the maximum size 2048 allowed"\}/
=== TEST 21: exceed body limit size (expected)
--- config
location = /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body, res_data = t('/apisix/batch-requests',
ngx.HTTP_POST,
("1234"):rep(1024),
nil,
{EXPECT = "100-CONTINUE", ["content-length"] = 4096}
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- error_code: 413
--- response_body eval
qr/\{"error_msg":"request size 4096 is greater than the maximum size 2048 allowed"\}/
=== TEST 22: don't exceed body limit size
--- config
location = /t {
content_by_lua_block {
local core = require("apisix.core")
local t = require("lib.test_admin").test
local code, body = t('/apisix/batch-requests',
ngx.HTTP_POST,
[=[{
"headers": {
"Base-Header": "base"
},
"pipeline":[
{
"path": "/a",
"headers": {
"Header1": "hello",
"Header2": "world"
}
}
]
}]=],
[=[[
{
"status": 200,
"body":"A",
"headers": {
"Base-Header": "base",
"X-Res": "a",
"X-Header1": "hello",
"X-Header2": "world"
}
}
]]=])
ngx.status = code
ngx.say(body)
}
}
location = /a {
content_by_lua_block {
ngx.status = 200
ngx.header["Base-Header"] = ngx.req.get_headers()["Base-Header"]
ngx.header["X-Header1"] = ngx.req.get_headers()["Header1"]
ngx.header["X-Header2"] = ngx.req.get_headers()["Header2"]
ngx.header["X-Res"] = "a"
ngx.print("A")
}
}
--- request
GET /t
--- response_body
passed
=== TEST 23: invalid body size
--- config
location /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/admin/plugin_metadata/batch-requests',
ngx.HTTP_PUT,
[[{
"max_body_size": 0
}]]
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- error_code: 400
--- response_body eval
qr/\{"error_msg":"invalid configuration: property \\"max_body_size\\" validation failed: expected 0 to be greater than 0"\}/
=== TEST 24: keep environment clean
--- config
location /t {
content_by_lua_block {
local t = require("lib.test_admin").test
local code, body = t('/apisix/admin/plugin_metadata/batch-requests',
ngx.HTTP_PUT,
[[{
}]]
)
if code >= 300 then
ngx.status = code
end
ngx.say(body)
}
}
--- request
GET /t
--- response_body
passed