forked from 3scale/APIcast
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request 3scale#1106 from eloycoto/THREESCALE-2886
Gateway: Add a option to enable keepalive-timeout
- Loading branch information
Showing
6 changed files
with
263 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,237 @@ | ||
| use lib 't'; | ||
| use Test::APIcast::Blackbox 'no_plan'; | ||
|
|
||
| repeat_each(1); | ||
|
|
||
| run_tests(); | ||
|
|
||
| __DATA__ | ||
|
|
||
| === TEST 1: Keepalive is not set if no env variable | ||
| --- configuration | ||
| { | ||
| "services": [ | ||
| { | ||
| "id": 42, | ||
| "backend_version": 1, | ||
| "backend_authentication_type": "service_token", | ||
| "backend_authentication_value": "token-value", | ||
| "proxy": { | ||
| "hosts": [ | ||
| "one" | ||
| ], | ||
| "api_backend": "http://test:$TEST_NGINX_SERVER_PORT/", | ||
| "proxy_rules": [ | ||
| { "pattern": "/", "http_method": "GET", "metric_system_name": "hits", "delta": 1 } | ||
| ], | ||
| "policy_chain": [ | ||
| { "name": "apicast.policy.apicast" } | ||
| ] | ||
| } | ||
| } | ||
| ] | ||
| } | ||
| --- upstream env | ||
| location / { | ||
| content_by_lua_block { | ||
| ngx.say('yay, api backend'); | ||
| } | ||
| } | ||
| --- backend | ||
| location /transactions/authrep.xml { | ||
| content_by_lua_block { | ||
| ngx.exit(200) | ||
| } | ||
| } | ||
| --- test env | ||
| content_by_lua_block { | ||
| local sock = ngx.socket.tcp() | ||
| local ok, err = sock:connect(ngx.var.server_addr, ngx.var.apicast_port) | ||
| if not ok then | ||
| ngx.say("failed to connect: ", err) | ||
| ngx.exit(400) | ||
| return | ||
| end | ||
|
|
||
| local function send_request(sock) | ||
| local bytes, err = sock:send("GET /?user_key=foo HTTP/1.1\r\nHost:one\r\n\r\n") | ||
| if not bytes then | ||
| return false, string.format("failed to send bytes: %s", err) | ||
| end | ||
|
|
||
| local data, err = sock:receiveany(10 * 1024) -- read any data, at most 10K | ||
| if not data then | ||
| return false, string.format("failed to receive data: %s", err) | ||
| end | ||
|
|
||
| return true, nil | ||
| end | ||
|
|
||
| local result, err = send_request(sock) | ||
| ngx.say("First request status: ", result, " err:", err) | ||
| ngx.sleep(1) | ||
| local result, err = send_request(sock) | ||
| ngx.say("Second request status: ", result, " err:", err) | ||
| } | ||
| --- response_body | ||
| First request status: true err:nil | ||
| Second request status: true err:nil | ||
| --- no_error_log | ||
| [error] | ||
|
|
||
| === TEST 2: Keepalive timeout cleans correctly on timeout. | ||
| --- env eval | ||
| ("HTTP_KEEPALIVE_TIMEOUT", "0") | ||
| --- configuration | ||
| { | ||
| "services": [ | ||
| { | ||
| "id": 42, | ||
| "backend_version": 1, | ||
| "backend_authentication_type": "service_token", | ||
| "backend_authentication_value": "token-value", | ||
| "proxy": { | ||
| "hosts": [ | ||
| "one" | ||
| ], | ||
| "api_backend": "http://test:$TEST_NGINX_SERVER_PORT/", | ||
| "proxy_rules": [ | ||
| { "pattern": "/", "http_method": "GET", "metric_system_name": "hits", "delta": 1 } | ||
| ], | ||
| "policy_chain": [ | ||
| { "name": "apicast.policy.apicast" } | ||
| ] | ||
| } | ||
| } | ||
| ] | ||
| } | ||
| --- upstream env | ||
| location / { | ||
| content_by_lua_block { | ||
| ngx.say('yay, api backend'); | ||
| } | ||
| } | ||
| --- backend | ||
| location /transactions/authrep.xml { | ||
| content_by_lua_block { | ||
| ngx.exit(200) | ||
| } | ||
| } | ||
| --- test env | ||
| content_by_lua_block { | ||
| local sock = ngx.socket.tcp() | ||
| local ok, err = sock:connect(ngx.var.server_addr, ngx.var.apicast_port) | ||
| if not ok then | ||
| ngx.say("failed to connect: ", err) | ||
| ngx.exit(400) | ||
| return | ||
| end | ||
|
|
||
| local function send_request(sock) | ||
| local bytes, err = sock:send("GET /?user_key=foo HTTP/1.1\r\nHost:one\r\n\r\n") | ||
| if not bytes then | ||
| return false, string.format("failed to send bytes: %s", err) | ||
| end | ||
|
|
||
| local data, err = sock:receiveany(10 * 1024) -- read any data, at most 10K | ||
| if not data then | ||
| return false, string.format("failed to receive data: %s", err) | ||
| end | ||
|
|
||
| return true, nil | ||
| end | ||
|
|
||
| local result, err = send_request(sock) | ||
| ngx.say("First request status: ", result, " err:", err) | ||
| ngx.sleep(1) | ||
|
|
||
| result, err = send_request(sock) | ||
| ngx.say("Second request status: ", result, " err:", err) | ||
| } | ||
| --- response_body | ||
| First request status: true err:nil | ||
| Second request status: false err:failed to receive data: closed | ||
| --- no_error_log | ||
| [error] | ||
|
|
||
| === TEST 3: Keepalive timeout can be set correctly. | ||
| --- env eval | ||
| ( | ||
| "HTTP_KEEPALIVE_TIMEOUT" => 2 | ||
| ) | ||
| --- timeout: 10s | ||
| --- configuration | ||
| { | ||
| "services": [ | ||
| { | ||
| "id": 42, | ||
| "backend_version": 1, | ||
| "backend_authentication_type": "service_token", | ||
| "backend_authentication_value": "token-value", | ||
| "proxy": { | ||
| "hosts": [ | ||
| "one" | ||
| ], | ||
| "api_backend": "http://test:$TEST_NGINX_SERVER_PORT/", | ||
| "proxy_rules": [ | ||
| { "pattern": "/", "http_method": "GET", "metric_system_name": "hits", "delta": 1 } | ||
| ], | ||
| "policy_chain": [ | ||
| { "name": "apicast.policy.apicast" } | ||
| ] | ||
| } | ||
| } | ||
| ] | ||
| } | ||
| --- upstream env | ||
| location / { | ||
| content_by_lua_block { | ||
| ngx.say('yay, api backend'); | ||
| } | ||
| } | ||
| --- backend | ||
| location /transactions/authrep.xml { | ||
| content_by_lua_block { | ||
| ngx.exit(200) | ||
| } | ||
| } | ||
| --- test env | ||
| content_by_lua_block { | ||
| local sock = ngx.socket.tcp() | ||
| local ok, err = sock:connect(ngx.var.server_addr, ngx.var.apicast_port) | ||
| if not ok then | ||
| ngx.say("failed to connect: ", err) | ||
| ngx.exit(400) | ||
| return | ||
| end | ||
|
|
||
| local function send_request(sock) | ||
| local bytes, err = sock:send("GET /?user_key=foo HTTP/1.1\r\nHost:one\r\n\r\n") | ||
| if not bytes then | ||
| return false, string.format("failed to send bytes: %s", err) | ||
| end | ||
|
|
||
| local data, err = sock:receiveany(10 * 1024) -- read any data, at most 10K | ||
| if not data then | ||
| return false, string.format("failed to receive data: %s", err) | ||
| end | ||
|
|
||
| return true, nil | ||
| end | ||
|
|
||
| local result, err = send_request(sock) | ||
| ngx.say("First request status: ", result, " err:", err) | ||
| ngx.sleep(1) | ||
| result, err = send_request(sock) | ||
| ngx.say("Second request status: ", result, " err:", err) | ||
|
|
||
| ngx.sleep(3) | ||
| result, err = send_request(sock) | ||
| ngx.say("Third request status: ", result, " err:", err) | ||
| } | ||
| --- response_body | ||
| First request status: true err:nil | ||
| Second request status: true err:nil | ||
| Third request status: false err:failed to receive data: closed | ||
| --- no_error_log | ||
| [error] |