wehub-resource-sync
108 lines
2.5 KiB
Lua
108 lines
2.5 KiB
Lua
local fmt = string.format
|
|
local helpers = require "spec.helpers"
|
|
|
|
|
|
local SERVICE_YML = [[
|
|
- name: my-service-%d
|
|
url: https://example%d.dev
|
|
routes:
|
|
- name: my-route-%d
|
|
paths:
|
|
- /%d
|
|
]]
|
|
|
|
|
|
local POST_FUNC_YML = [[
|
|
plugins:
|
|
- name: post-function
|
|
config:
|
|
rewrite:
|
|
- |
|
|
return function(conf)
|
|
local db = kong.db
|
|
|
|
-- check max_page_size
|
|
|
|
assert(db.routes.pagination.max_page_size == 2048)
|
|
assert(db.services.pagination.max_page_size == 2048)
|
|
|
|
-- check each()
|
|
|
|
local r, err = db.routes:each(1000)
|
|
assert(r and not err)
|
|
|
|
local r, err = db.routes:each(2047)
|
|
assert(r and not err)
|
|
|
|
local r, err = db.routes:each(2048)
|
|
assert(r and not err)
|
|
|
|
local r, err = db.routes:each(2049)
|
|
assert(not r)
|
|
assert(err == "[off] size must be an integer between 1 and 2048")
|
|
|
|
-- check page()
|
|
|
|
local entities, err = db.routes:page(1000)
|
|
assert(#entities == 1000 and not err)
|
|
|
|
local entities, err = db.routes:page(2047)
|
|
assert(#entities == 2047 and not err)
|
|
|
|
local entities, err = db.routes:page(2048)
|
|
assert(#entities == 2048 and not err)
|
|
|
|
local entities, err = db.routes:page(2049)
|
|
assert(not entities)
|
|
assert(err == "[off] size must be an integer between 1 and 2048")
|
|
|
|
ngx.exit(200)
|
|
end
|
|
]]
|
|
|
|
|
|
local COUNT = 3000
|
|
|
|
|
|
describe("dbless pagination #off", function()
|
|
lazy_setup(function()
|
|
assert(helpers.start_kong({
|
|
database = "off",
|
|
}))
|
|
end)
|
|
|
|
lazy_teardown(function()
|
|
helpers.stop_kong()
|
|
end)
|
|
|
|
it("max pagesize should be 2048", function()
|
|
local buffer = {"_format_version: '3.0'", POST_FUNC_YML, "services:"}
|
|
for i = 1, COUNT do
|
|
buffer[#buffer + 1] = fmt(SERVICE_YML, i, i, i, i)
|
|
end
|
|
|
|
local config = table.concat(buffer, "\n")
|
|
|
|
local admin_client = assert(helpers.admin_client())
|
|
local res = admin_client:post("/config",{
|
|
body = { config = config },
|
|
headers = {
|
|
["Content-Type"] = "application/json",
|
|
}
|
|
})
|
|
assert.res_status(201, res)
|
|
admin_client:close()
|
|
|
|
assert(helpers.restart_kong({
|
|
database = "off",
|
|
}))
|
|
|
|
local proxy_client = assert(helpers.proxy_client())
|
|
|
|
res = assert(proxy_client:get("/1", { headers = { host = "example1.dev" } }))
|
|
assert.res_status(200, res)
|
|
|
|
assert.logfile().has.no.line("[error]", true)
|
|
end)
|
|
end)
|