Replace Nino by Standalone whenever it is relevant.
This commit is contained in:
@@ -19,33 +19,49 @@ inherit
|
||||
|
||||
feature {NONE} -- Events
|
||||
|
||||
web_app: detachable NINO_SERVICE [TEST_EXECUTION]
|
||||
web_connector: detachable separate WGI_STANDALONE_CONNECTOR [TEST_EXECUTION]
|
||||
|
||||
port_number: INTEGER
|
||||
base_url: detachable STRING
|
||||
base_url: detachable separate STRING
|
||||
once
|
||||
if attached local_base_url as b and then not b.is_whitespace then
|
||||
create Result.make_from_separate (b)
|
||||
end
|
||||
end
|
||||
|
||||
local_base_url: detachable STRING
|
||||
once
|
||||
create Result.make_from_string ({TEST_SETTINGS}.base_url)
|
||||
if Result.is_whitespace then
|
||||
Result := Void
|
||||
end
|
||||
end
|
||||
|
||||
on_prepare
|
||||
-- <Precursor>
|
||||
local
|
||||
app: NINO_SERVICE [TEST_EXECUTION]
|
||||
wt: WORKER_THREAD
|
||||
conn: separate WGI_STANDALONE_CONNECTOR [TEST_EXECUTION]
|
||||
e: EXECUTION_ENVIRONMENT
|
||||
do
|
||||
create e
|
||||
-- port_number := 9091 -- Uncomment to use with server outside this process
|
||||
-- port_number := {TEST_SETTINGS}.port_number -- Uncomment to use with server outside this process
|
||||
if port_number = 0 then
|
||||
server_log ("== Current directory: " + e.current_working_directory)
|
||||
|
||||
port_number := 0
|
||||
base_url := "/test/"
|
||||
create app.make_custom (base_url)
|
||||
web_app := app
|
||||
|
||||
create wt.make (agent app.listen (port_number))
|
||||
wt.launch
|
||||
e.sleep (1_000_000_000 * 5)
|
||||
port_number := app.port
|
||||
server_log ("Server port=" + port_number.out)
|
||||
if attached base_url as b then
|
||||
create conn.make_with_base (b)
|
||||
else
|
||||
create conn.make
|
||||
end
|
||||
web_connector := conn
|
||||
setup_connector (conn)
|
||||
launch_connector (conn)
|
||||
|
||||
-- e.sleep (1_000_000_000 * 5)
|
||||
get_port_number (conn)
|
||||
|
||||
-- get_port_number (app.connector)
|
||||
else
|
||||
server_log ("Use existing server")
|
||||
server_log ("== Current directory: " + e.current_working_directory)
|
||||
@@ -53,6 +69,26 @@ feature {NONE} -- Events
|
||||
end
|
||||
end
|
||||
|
||||
setup_connector (conn: attached like web_connector)
|
||||
do
|
||||
conn.set_is_verbose (True)
|
||||
conn.set_port_number (port_number)
|
||||
conn.set_socket_recv_timeout (5)
|
||||
end
|
||||
|
||||
launch_connector (conn: attached like web_connector)
|
||||
do
|
||||
conn.launch
|
||||
end
|
||||
|
||||
get_port_number (conn: attached like web_connector)
|
||||
require
|
||||
conn.port > 0
|
||||
do
|
||||
port_number := conn.port
|
||||
server_log ("Server port=" + port_number.out)
|
||||
end
|
||||
|
||||
server_log_name: STRING
|
||||
local
|
||||
fn: FILE_NAME
|
||||
@@ -78,9 +114,9 @@ feature {NONE} -- Events
|
||||
|
||||
test_url (a_query_url: READABLE_STRING_8): READABLE_STRING_8
|
||||
local
|
||||
b: like base_url
|
||||
b: like local_base_url
|
||||
do
|
||||
b := base_url
|
||||
b := local_base_url
|
||||
if b = Void then
|
||||
b := ""
|
||||
end
|
||||
@@ -90,24 +126,29 @@ feature {NONE} -- Events
|
||||
on_clean
|
||||
-- <Precursor>
|
||||
do
|
||||
if attached web_app as app then
|
||||
app.shutdown
|
||||
if attached web_connector as conn then
|
||||
shutdown_server (conn)
|
||||
end
|
||||
end
|
||||
|
||||
shutdown_server (conn: attached like web_connector)
|
||||
do
|
||||
conn.shutdown_server
|
||||
end
|
||||
|
||||
http_session: detachable HTTP_CLIENT_SESSION
|
||||
|
||||
get_http_session
|
||||
local
|
||||
h: LIBCURL_HTTP_CLIENT
|
||||
b: like base_url
|
||||
h: DEFAULT_HTTP_CLIENT
|
||||
b: like local_base_url
|
||||
do
|
||||
create h.make
|
||||
b := base_url
|
||||
create h
|
||||
b := local_base_url
|
||||
if b = Void then
|
||||
b := "/"
|
||||
end
|
||||
if attached {HTTP_CLIENT_SESSION} h.new_session ("localhost:" + port_number.out + b) as sess then
|
||||
if attached {HTTP_CLIENT_SESSION} h.new_session ("http://localhost:" + port_number.out + b) as sess then
|
||||
http_session := sess
|
||||
sess.set_timeout (-1)
|
||||
sess.set_is_debug (True)
|
||||
@@ -120,15 +161,24 @@ feature {NONE} -- Events
|
||||
do
|
||||
get_http_session
|
||||
if attached http_session as sess then
|
||||
print ("Request: " + a_url + " ...%N")
|
||||
if attached sess.get (a_url, adapted_context (ctx)) as res then
|
||||
if attached res.body as l_body then
|
||||
if res.error_occurred then
|
||||
assert ("Request %""+a_url+"%" failed, got=[" + l_body + "]", False)
|
||||
if attached res.error_message as err_msg then
|
||||
assert ("Request %""+a_url+"%" failed, got=[" + l_body + "] error:" + err_msg, False)
|
||||
else
|
||||
assert ("Request %""+a_url+"%" failed, got=[" + l_body + "] error:N/A", False)
|
||||
end
|
||||
else
|
||||
assert ("Good answer got=%""+l_body+"%" expected=%""+a_expected_body+"%"", l_body.same_string (a_expected_body))
|
||||
end
|
||||
else
|
||||
assert ("Request %""+a_url+"%" failed, no body, status=" + res.status.out , False)
|
||||
if attached res.error_message as err_msg then
|
||||
assert ("Request %""+a_url+"%" failed, no body, status=" + res.status.out + " error:" + err_msg, False)
|
||||
else
|
||||
assert ("Request %""+a_url+"%" failed, no body, status=" + res.status.out + " error:N/A", False)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -146,18 +196,34 @@ feature {NONE} -- Events
|
||||
end
|
||||
end
|
||||
|
||||
test_post_request_with_filename (a_url: READABLE_STRING_8; ctx: detachable HTTP_CLIENT_REQUEST_CONTEXT; a_fn: STRING; a_expected_body: READABLE_STRING_8)
|
||||
test_post_request_with_filename (a_url: READABLE_STRING_8; ctx: detachable HTTP_CLIENT_REQUEST_CONTEXT; a_fn: STRING; a_expected_body: detachable READABLE_STRING_8; a_expected_starting_body: detachable READABLE_STRING_8)
|
||||
do
|
||||
get_http_session
|
||||
if attached http_session as sess then
|
||||
if attached sess.post_file (a_url, adapted_context (ctx), a_fn) as res and then not res.error_occurred and then attached res.body as l_body then
|
||||
assert ("Good answer got=%""+l_body+"%" expected=%""+a_expected_body+"%"", l_body.same_string (a_expected_body))
|
||||
if
|
||||
attached sess.post_file (a_url, adapted_context (ctx), a_fn) as res and then
|
||||
not res.error_occurred and then
|
||||
attached res.body as l_body
|
||||
then
|
||||
assert ("Good answer got=%""+l_body+"%" expected=%""+ safe_out (a_expected_body) +"%"",
|
||||
(a_expected_body /= Void implies l_body.same_string (a_expected_body))
|
||||
and (a_expected_starting_body /= Void implies l_body.starts_with (a_expected_starting_body))
|
||||
)
|
||||
else
|
||||
assert ("Request %""+a_url+"%" failed", False)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
safe_out (s: detachable READABLE_STRING_8): STRING
|
||||
do
|
||||
if s = Void then
|
||||
Result := "Void"
|
||||
else
|
||||
Result := s.out
|
||||
end
|
||||
end
|
||||
|
||||
adapted_context (ctx: detachable HTTP_CLIENT_REQUEST_CONTEXT): HTTP_CLIENT_REQUEST_CONTEXT
|
||||
do
|
||||
if ctx /= Void then
|
||||
@@ -173,6 +239,7 @@ feature -- Test routines
|
||||
test_get_request_01
|
||||
-- New test routine
|
||||
do
|
||||
assert ("has port", port_number > 0)
|
||||
get_http_session
|
||||
if attached http_session as sess then
|
||||
test_get_request ("get/01", Void, "get-01")
|
||||
@@ -199,11 +266,11 @@ feature -- Test routines
|
||||
s := "This is an uploaded file%NTesting purpose%N"
|
||||
f.put_string (s)
|
||||
f.close
|
||||
test_post_request_with_filename ("post/file/01", Void, fn.string, "post-file-01%N" + s)
|
||||
test_post_request_with_filename ("post/file/01 #1", Void, fn.string, "post-file-01", "post-file-01")
|
||||
|
||||
create ctx.make
|
||||
ctx.add_form_parameter ("foo", "bar")
|
||||
test_post_request_with_filename ("post/file/01", ctx, fn.string, "post-file-01%N" + s)
|
||||
test_post_request_with_filename ("post/file/01 #2", ctx, fn.string, Void, "post-file-01")
|
||||
else
|
||||
assert ("not_implemented", False)
|
||||
end
|
||||
|
||||
Reference in New Issue
Block a user