wehub-resource-sync
66 lines
1.6 KiB
Lua
66 lines
1.6 KiB
Lua
local helpers = require "spec.helpers"
|
|
|
|
|
|
local UDP_PROXY_PORT = 26001
|
|
|
|
|
|
local function reload_router(flavor)
|
|
helpers = require("spec.internal.module").reload_helpers(flavor)
|
|
end
|
|
|
|
|
|
-- TODO: remove it when we confirm it is not needed
|
|
local function gen_route(flavor, r)
|
|
return r
|
|
end
|
|
|
|
|
|
for _, flavor in ipairs({ "traditional", "traditional_compatible", "expressions" }) do
|
|
for _, strategy in helpers.each_strategy() do
|
|
|
|
describe("UDP Proxying [#" .. strategy .. ", flavor = " .. flavor .. "]", function()
|
|
reload_router(flavor)
|
|
|
|
lazy_setup(function()
|
|
local bp = helpers.get_db_utils(strategy, {
|
|
"routes",
|
|
"services",
|
|
})
|
|
|
|
local service = assert(bp.services:insert {
|
|
name = "udp-service",
|
|
url = "udp://127.0.0.1:" .. helpers.mock_upstream_stream_port,
|
|
})
|
|
|
|
assert(bp.routes:insert(gen_route(flavor, {
|
|
protocols = { "udp" },
|
|
service = service,
|
|
sources = { { ip = "127.0.0.1", }, }
|
|
})))
|
|
|
|
assert(helpers.start_kong {
|
|
router_flavor = flavor,
|
|
database = strategy,
|
|
nginx_conf = "spec/fixtures/custom_nginx.template",
|
|
stream_listen = "127.0.0.1:" .. UDP_PROXY_PORT .. " udp",
|
|
})
|
|
|
|
end)
|
|
|
|
lazy_teardown(function()
|
|
helpers.stop_kong()
|
|
end)
|
|
|
|
it("proxies udp", function()
|
|
local client = ngx.socket.udp()
|
|
assert(client:setpeername("127.0.0.1", UDP_PROXY_PORT))
|
|
|
|
assert(client:send("HELLO WORLD!\n"))
|
|
local echo = assert(client:receive())
|
|
|
|
assert.equal("HELLO WORLD!\n", echo)
|
|
end)
|
|
end)
|
|
end
|
|
end -- for flavor
|