# # 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("info"); run_tests; __DATA__ === TEST 1: sanity --- config location /t { content_by_lua_block { local get_seed = require("apisix.core.utils").get_seed_from_urandom ngx.say("random seed ", get_seed()) ngx.say("twice: ", get_seed() == get_seed()) } } --- request GET /t --- response_body_like eval qr/random seed \d+(\.\d+)?(e\+\d+)?\ntwice: false/ === TEST 2: parse_addr --- config location /t { content_by_lua_block { local parse_addr = require("apisix.core.utils").parse_addr local cases = { {addr = "127.0.0.1", host = "127.0.0.1", port = 80}, {addr = "127.0.0.1:90", host = "127.0.0.1", port = 90}, {addr = "www.test.com", host = "www.test.com", port = 80}, {addr = "www.test.com:90", host = "www.test.com", port = 90}, {addr = "[127.0.0.1:90", host = "[127.0.0.1:90", port = 80}, {addr = "[::1]", host = "[::1]", port = 80}, {addr = "[::1]:1234", host = "[::1]", port = 1234}, {addr = "[::1234:1234]:12345", host = "[::1234:1234]", port = 12345}, } for _, case in ipairs(cases) do local host, port = parse_addr(case.addr) assert(host == case.host, string.format("host %s mismatch %s", host, case.host)) assert(port == case.port, string.format("port %s mismatch %s", port, case.port)) end } } --- request GET /t --- no_error_log [error] === TEST 3: specify resolvers --- config location /t { content_by_lua_block { local core = require("apisix.core") local resolvers = {"8.8.8.8"} core.utils.set_resolver(resolvers) local ip_info, err = core.utils.dns_parse("github.com", resolvers) if not ip_info then core.log.error("failed to parse domain: ", host, ", error: ",err) end ngx.say(require("toolkit.json").encode(ip_info)) } } --- request GET /t --- response_body eval qr/"address":.+,"name":"github.com"/ --- no_error_log [error] === TEST 4: default resolvers --- config location /t { content_by_lua_block { local core = require("apisix.core") local ip_info, err = core.utils.dns_parse("github.com") if not ip_info then core.log.error("failed to parse domain: ", host, ", error: ",err) end core.log.info("ip_info: ", require("toolkit.json").encode(ip_info)) ngx.say("resolvers: ", require("toolkit.json").encode(core.utils.resolvers)) } } --- request GET /t --- response_body resolvers: ["8.8.8.8","114.114.114.114"] --- error_log eval qr/"address":.+,"name":"github.com"/ --- no_error_log [error] === TEST 5: enable_server_tokens false --- yaml_config apisix: node_listen: 1984 enable_server_tokens: false admin_key: null --- 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, [[{ "upstream": { "nodes": { "127.0.0.1:1980": 1 }, "type": "roundrobin" }, "uri": "/hello" }]] ) if code >= 300 then ngx.status = code ngx.say("failed") return end do local sock = ngx.socket.tcp() sock:settimeout(2000) local ok, err = sock:connect("127.0.0.1", 1984) if not ok then ngx.say("failed to connect: ", err) return end ngx.say("connected: ", ok) local req = "GET /hello HTTP/1.0\r\nHost: www.test.com\r\nConnection: close\r\n\r\n" local bytes, err = sock:send(req) if not bytes then ngx.say("failed to send http request: ", err) return end ngx.say("sent http request: ", bytes, " bytes.") while true do local line, err = sock:receive() if not line then -- ngx.say("failed to receive response status line: ", err) break end ngx.say("received: ", line) end local ok, err = sock:close() ngx.say("close: ", ok, " ", err) end -- do } } --- request GET /t --- response_body eval qr{connected: 1 sent http request: 62 bytes. received: HTTP/1.1 200 OK received: Content-Type: text/plain received: Content-Length: 12 received: Connection: close received: Server: APISIX received: \nreceived: hello world close: 1 nil} --- no_error_log [error] === TEST 6: resolve_var --- config location /t { content_by_lua_block { local resolve_var = require("apisix.core.utils").resolve_var local cases = { "", "xx", "$me", "$me run", "talk with $me", "tell $me to", "$you and $me", "$eva and $me", "$you and \\$me", "${you}_${me}", "${you}${me}", "${you}$me", } local ctx = { you = "John", me = "David", } for _, case in ipairs(cases) do ngx.say("res:", resolve_var(case, ctx)) end } } --- request GET /t --- response_body res: res:xx res:David res:David run res:talk with David res:tell David to res:John and David res: and David res:John and \$me res:John_David res:JohnDavid res:JohnDavid