kong--kong
wehub-resource-sync
95 行
2.5 KiB
Lua
95 行
2.5 KiB
Lua
local helpers = require "spec.helpers"
|
|
local Errors = require "kong.db.errors"
|
|
local cjson = require "cjson"
|
|
|
|
|
|
for _, strategy in helpers.each_strategy() do
|
|
describe("Plugin: response-rate-limiting (API) [#" .. strategy .. "]", function()
|
|
local admin_client
|
|
local bp
|
|
|
|
lazy_setup(function()
|
|
bp = helpers.get_db_utils(strategy, {
|
|
"routes",
|
|
"services",
|
|
"plugins",
|
|
})
|
|
|
|
assert(helpers.start_kong({
|
|
database = strategy,
|
|
nginx_conf = "spec/fixtures/custom_nginx.template",
|
|
}))
|
|
end)
|
|
|
|
lazy_teardown(function()
|
|
helpers.stop_kong()
|
|
end)
|
|
|
|
describe("POST", function()
|
|
|
|
before_each(function()
|
|
admin_client = helpers.admin_client()
|
|
end)
|
|
|
|
after_each(function()
|
|
if admin_client then
|
|
admin_client:close()
|
|
end
|
|
end)
|
|
|
|
it("errors on empty config", function()
|
|
local route = bp.routes:insert {
|
|
hosts = { "test1.test" },
|
|
}
|
|
local res = assert(admin_client:send {
|
|
method = "POST",
|
|
path = "/plugins",
|
|
body = {
|
|
name = "response-ratelimiting",
|
|
route = { id = route.id }
|
|
},
|
|
headers = {
|
|
["Content-Type"] = "application/json"
|
|
}
|
|
})
|
|
local body = assert.res_status(400, res)
|
|
local json = cjson.decode(body)
|
|
assert.same({
|
|
code = Errors.codes.SCHEMA_VIOLATION,
|
|
name = "schema violation",
|
|
fields = {
|
|
config = {
|
|
limits = "required field missing",
|
|
}
|
|
},
|
|
message = "schema violation (config.limits: required field missing)",
|
|
}, json)
|
|
end)
|
|
it("accepts proper config and sets local policy by default", function()
|
|
local route = bp.routes:insert {
|
|
hosts = { "test1.test" },
|
|
}
|
|
local res = assert(admin_client:send {
|
|
method = "POST",
|
|
path = "/plugins",
|
|
body = {
|
|
name = "response-ratelimiting",
|
|
route = { id = route.id },
|
|
config = {
|
|
limits = {
|
|
video = { second = 10 }
|
|
}
|
|
}
|
|
},
|
|
headers = {
|
|
["Content-Type"] = "application/json"
|
|
}
|
|
})
|
|
local body = cjson.decode(assert.res_status(201, res))
|
|
assert.equal(10, body.config.limits.video.second)
|
|
assert.equal("local", body.config.policy)
|
|
end)
|
|
end)
|
|
end)
|
|
end
|