t/admin/standalone.t

#
# 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.
#
BEGIN {
    # restarts cause the memory cache to be emptied, don't do this
    $ENV{TEST_NGINX_FORCE_RESTART_ON_TEST} = 0;
}

use t::APISIX 'no_plan';

repeat_each(1);
no_long_string();
no_root_location();
use_hup();

add_block_preprocessor(sub {
    my ($block) = @_;

    if (!defined $block->yaml_config) {
        $block->set_value("yaml_config", <<'EOF');
deployment:
    role: traditional
    role_traditional:
        config_provider: yaml
    admin:
        admin_key:
            - name: admin
              key: edd1c9f034335f136f87ad84b625c8f1
              role: admin
EOF
    }

    $block->set_value("stream_enable", 1);

    if (!defined $block->no_error_log) {
        $block->set_value("no_error_log", "");
    }
});

run_tests();

__DATA__

=== TEST 1: test
--- timeout: 15
--- max_size: 204800
--- exec
cd t && pnpm test admin/standalone.spec.ts 2>&1
--- no_error_log
failed to execute the script with status
--- response_body eval
qr/PASS admin\/standalone.spec.ts/



=== TEST 2: init conf_version
--- config
    location /t {} # force the worker to restart by changing the configuration
--- request
PUT /apisix/admin/configs
{
    "consumer_groups_conf_version": 1000,
    "consumers_conf_version": 1000,
    "global_rules_conf_version": 1000,
    "plugin_configs_conf_version": 1000,
    "plugin_metadata_conf_version": 1000,
    "protos_conf_version": 1000,
    "routes_conf_version": 1000,
    "stream_routes_conf_version": 1000,
    "secrets_conf_version": 1000,
    "services_conf_version": 1000,
    "ssls_conf_version": 1000,
    "upstreams_conf_version": 1000
}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t2
--- error_code: 202



=== TEST 3: get config
--- config
    location /config {
        content_by_lua_block {
            local json = require("toolkit.json")
            local t = require("lib.test_admin")
            local code, body = t.test('/apisix/admin/configs',
                ngx.HTTP_GET,
                nil,
                [[{
                    "consumer_groups_conf_version": 1000,
                    "consumers_conf_version": 1000,
                    "global_rules_conf_version": 1000,
                    "plugin_configs_conf_version": 1000,
                    "plugin_metadata_conf_version": 1000,
                    "protos_conf_version": 1000,
                    "routes_conf_version": 1000,
                    "stream_routes_conf_version": 1000,
                    "secrets_conf_version": 1000,
                    "services_conf_version": 1000,
                    "ssls_conf_version": 1000,
                    "upstreams_conf_version": 1000
                }]],
                {
                    ["X-API-KEY"] = "edd1c9f034335f136f87ad84b625c8f1"
                }
            )
            ngx.say(body)
        }
    }
--- request
GET /config
--- response_body
passed



=== TEST 4: configure route
--- config
    location /t {} # force the worker to restart by changing the configuration
--- request
PUT /apisix/admin/configs
{"routes":[{"id":"r1","uri":"/r1","upstream":{"nodes":{"127.0.0.1:1980":1},"type":"roundrobin"},"plugins":{"proxy-rewrite":{"uri":"/hello"}}}]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t4
--- error_code: 202



=== TEST 5: test route
--- config
    location /t1 {}
--- request
GET /r1
--- error_code: 200
--- response_body
hello world



=== TEST 6: remove route
--- config
    location /t2 {}
--- request
PUT /apisix/admin/configs
{}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t6
--- error_code: 202



=== TEST 7: test non-exist route
--- config
    location /t3 {}
--- request
GET /r1
--- error_code: 404



=== TEST 8: route references upstream, but only updates the route
--- config
    location /t6 {}
--- pipelined_requests eval
[
    "PUT /apisix/admin/configs\n" . "{\"routes_conf_version\":1060,\"upstreams_conf_version\":1060,\"routes\":[{\"id\":\"r1\",\"uri\":\"/r1\",\"upstream_id\":\"u1\",\"plugins\":{\"proxy-rewrite\":{\"uri\":\"/hello\"}}}],\"upstreams\":[{\"id\":\"u1\",\"nodes\":{\"127.0.0.1:1980\":1},\"type\":\"roundrobin\"}]}",
    "PUT /apisix/admin/configs\n" . "{\"routes_conf_version\":1062,\"upstreams_conf_version\":1060,\"routes\":[{\"id\":\"r1\",\"uri\":\"/r2\",\"upstream_id\":\"u1\",\"plugins\":{\"proxy-rewrite\":{\"uri\":\"/hello\"}}}],\"upstreams\":[{\"id\":\"u1\",\"nodes\":{\"127.0.0.1:1980\":1},\"type\":\"roundrobin\"}]}"
]
--- more_headers eval
[
    "X-API-KEY: edd1c9f034335f136f87ad84b625c8f1\n" . "X-Digest: t8-1",
    "X-API-KEY: edd1c9f034335f136f87ad84b625c8f1\n" . "x-apisix-conf-version-routes: 100\n" . "X-Digest: t8-2",
]
--- error_code eval
[202, 202]



=== TEST 9: hit r2
--- config
    location /t3 {}
--- pipelined_requests eval
["GET /r1", "GET /r2"]
--- error_code eval
[404, 200]



=== TEST 10: routes_conf_version < 1062 is not allowed
--- config
    location /t {}
--- request
PUT /apisix/admin/configs
{"routes_conf_version":1,"routes":[{"id":"r1","uri":"/r2","upstream_id":"u1","plugins":{"proxy-rewrite":{"uri":"/hello"}}}]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
x-apisix-conf-version-routes: 100
X-Digest: t10
--- error_code: 400
--- response_body
{"error_msg":"routes_conf_version must be greater than or equal to (1062)"}



=== TEST 11: duplicate route id found
--- config
    location /t11 {}
--- request
PUT /apisix/admin/configs
{"routes_conf_version":1063,"routes":[{"id":"r1","uri":"/r2","upstream_id":"u1","plugins":{"proxy-rewrite":{"uri":"/hello"}}},
{"id":"r1","uri":"/r2","upstream_id":"u1","plugins":{"proxy-rewrite":{"uri":"/hello"}}}]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t11
--- error_code: 400
--- response_body
{"error_msg":"found duplicate id r1 in routes"}



=== TEST 12: duplicate consumer username found
--- config
    location /t12 {}
--- request
PUT /apisix/admin/configs
{"consumers_conf_version":1064,"consumers":[{"username":"consumer1","plugins":{"key-auth":{"key":"consumer1"}}},
{"username":"consumer1","plugins":{"key-auth":{"key":"consumer1"}}}]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t12
--- error_code: 400
--- response_body
{"error_msg":"found duplicate username consumer1 in consumers"}



=== TEST 13: duplicate consumer credential id found
--- config
    location /t13 {}
--- request
PUT /apisix/admin/configs
{"consumers_conf_version":1065,"consumers":[
    {"username": "john_1"},
    {"id":"john_1/credentials/john-a","plugins":{"key-auth":{"key":"auth-a"}}},
    {"id":"john_1/credentials/john-a","plugins":{"key-auth":{"key":"auth-a"}}}
]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t13
--- error_code: 400
--- response_body
{"error_msg":"found duplicate credential id john_1/credentials/john-a in consumers"}



=== TEST 14: configure stream route
--- request
PUT /apisix/admin/configs
{"stream_routes":[{"modifiedIndex": 1, "server_addr":"127.0.0.1","server_port":1985,"id":1,"upstream":{"nodes":{"127.0.0.1:1995":1},"type":"roundrobin"}}]}
--- more_headers
X-API-KEY: edd1c9f034335f136f87ad84b625c8f1
X-Digest: t14
--- error_code: 202



=== TEST 15: hit stream route
--- config
location /stream_request {
    content_by_lua_block {
        ngx.sleep(1)  -- wait for the stream route to take effect

        local tcp_request = function(host, port)
            local sock, err = ngx.socket.tcp()
            assert(sock, err)

            local ok, err = sock:connect(host, port)
            if not ok then
                ngx.say("connect to stream server error: ", err)
                return
            end
            local bytes, err = sock:send("mmm")
            if not bytes then
                ngx.say("send stream request error: ", err)
                return
            end

            local data, err = sock:receive("*a")
            if not data then
                sock:close()
                ngx.say("receive stream response error: ", err)
                return
            end
            sock:close()
            ngx.print(data)
        end

        tcp_request("127.0.0.1", 1985)

        -- update the stream route in runtime to confirm the new stream route takes effect
        local t = require("lib.test_admin").test
        local code, body = t('/apisix/admin/configs',
            ngx.HTTP_PUT,
            [[{
              "stream_routes": [
                {
                  "modifiedIndex": 2,
                  "server_addr": "127.0.0.2",
                  "server_port": 1985,
                  "id": 1,
                  "upstream": {
                    "nodes": {
                      "127.0.0.1:1995": 1
                    },
                    "type": "roundrobin"
                  }
                }
              ]
            }]], nil, { ["X-API-KEY"] = "edd1c9f034335f136f87ad84b625c8f1", ["X-Digest"] = "t15"}
        )
        if code ~= 202 then
            ngx.print("failed to update stream route, code: ", code, ", body: ", body)
            return
        end

        ngx.sleep(1)

        tcp_request("127.0.0.1", 1985)
        tcp_request("127.0.0.2", 1985)
    }
}
--- request
GET /stream_request
--- response_body
hello world
receive stream response error: connection reset by peer
hello world