2022-07-04 11:49:15 +02:00
|
|
|
// Copyright (c) 2022 The Chromium Embedded Framework Authors. All rights
|
|
|
|
|
// reserved. Use of this source code is governed by a BSD-style license that
|
|
|
|
|
// can be found in the LICENSE file.
|
|
|
|
|
|
|
|
|
|
#include "tests/ceftests/message_router_unittest_utils.h"
|
|
|
|
|
|
|
|
|
|
namespace {
|
|
|
|
|
|
|
|
|
|
constexpr int kSingleQueryErrorCode = 5;
|
|
|
|
|
constexpr size_t kMessageSizeThreshold = 16000;
|
|
|
|
|
|
|
|
|
|
enum class TestType { SUCCESS, FAILURE };
|
|
|
|
|
|
|
|
|
|
CefString GenerateResponse(size_t size, char ch) {
|
|
|
|
|
return CefString(std::string(size, ch));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
CefString GenerateResponse(size_t size, wchar_t ch) {
|
|
|
|
|
return CefString(std::wstring(size, ch));
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
template <class CharType>
|
|
|
|
|
class ThresholdTestHandler final : public SingleLoadTestHandler {
|
|
|
|
|
public:
|
|
|
|
|
ThresholdTestHandler(TestType type, size_t message_size, CharType symbol)
|
|
|
|
|
: test_type_(type),
|
|
|
|
|
message_size_(message_size),
|
|
|
|
|
message_size_str_(std::to_string(message_size)),
|
|
|
|
|
symbol_(symbol) {}
|
|
|
|
|
|
|
|
|
|
std::string GetMainHTML() override {
|
|
|
|
|
const std::string& errorCodeStr = std::to_string(kSingleQueryErrorCode);
|
|
|
|
|
|
|
|
|
|
std::string html =
|
|
|
|
|
"<html><body><script>\n"
|
|
|
|
|
// Send the query.
|
|
|
|
|
"var request_id = window." +
|
|
|
|
|
std::string(kJSQueryFunc) + "({\n request: '" + message_size_str_ +
|
|
|
|
|
"',\n persistent: false,\n"
|
|
|
|
|
" onSuccess: function(response) {\n"
|
|
|
|
|
" window.mrtNotify(response);\n"
|
|
|
|
|
" },\n"
|
|
|
|
|
" onFailure: function(error_code, error_message) {\n"
|
|
|
|
|
" if (error_code == " +
|
|
|
|
|
errorCodeStr +
|
|
|
|
|
")\n"
|
|
|
|
|
" window.mrtNotify(error_message);\n"
|
|
|
|
|
" else\n"
|
|
|
|
|
" window.mrtNotify('error-onFailure');\n"
|
|
|
|
|
" }\n"
|
|
|
|
|
"});\n</script></body></html>";
|
|
|
|
|
|
|
|
|
|
return html;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void OnNotify(CefRefPtr<CefBrowser> browser,
|
|
|
|
|
CefRefPtr<CefFrame> frame,
|
|
|
|
|
const std::string& message) override {
|
|
|
|
|
AssertMainBrowser(browser);
|
|
|
|
|
AssertMainFrame(frame);
|
|
|
|
|
|
|
|
|
|
// OnNotify only be called once.
|
|
|
|
|
EXPECT_FALSE(got_notify_);
|
|
|
|
|
got_notify_.yes();
|
|
|
|
|
|
|
|
|
|
auto expected = GenerateResponse(message_size_, symbol_);
|
|
|
|
|
|
|
|
|
|
switch (test_type_) {
|
|
|
|
|
case TestType::SUCCESS:
|
|
|
|
|
EXPECT_EQ(expected, message);
|
|
|
|
|
break;
|
|
|
|
|
case TestType::FAILURE:
|
|
|
|
|
EXPECT_EQ(expected, message);
|
|
|
|
|
break;
|
|
|
|
|
default:
|
|
|
|
|
ADD_FAILURE();
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
DestroyTest();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void ExecuteCallback(size_t response_size) {
|
|
|
|
|
auto response = GenerateResponse(response_size, symbol_);
|
|
|
|
|
|
|
|
|
|
EXPECT_TRUE(callback_.get());
|
|
|
|
|
switch (test_type_) {
|
|
|
|
|
case TestType::SUCCESS:
|
|
|
|
|
callback_->Success(response);
|
|
|
|
|
break;
|
|
|
|
|
case TestType::FAILURE:
|
|
|
|
|
callback_->Failure(kSingleQueryErrorCode, response);
|
|
|
|
|
break;
|
|
|
|
|
default:
|
|
|
|
|
ADD_FAILURE();
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
callback_ = nullptr;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
bool OnQuery(CefRefPtr<CefBrowser> browser,
|
|
|
|
|
CefRefPtr<CefFrame> frame,
|
2023-06-01 16:06:15 +02:00
|
|
|
int64_t query_id,
|
2022-07-04 11:49:15 +02:00
|
|
|
const CefString& request,
|
|
|
|
|
bool persistent,
|
|
|
|
|
CefRefPtr<Callback> callback) override {
|
|
|
|
|
AssertMainBrowser(browser);
|
|
|
|
|
AssertMainFrame(frame);
|
|
|
|
|
EXPECT_NE(0, query_id);
|
|
|
|
|
EXPECT_FALSE(persistent);
|
|
|
|
|
EXPECT_EQ(message_size_str_, request.ToString());
|
|
|
|
|
|
|
|
|
|
const size_t message_size =
|
|
|
|
|
static_cast<size_t>(std::stoi(request.ToString()));
|
|
|
|
|
got_on_query_.yes();
|
|
|
|
|
|
|
|
|
|
callback_ = callback;
|
|
|
|
|
ExecuteCallback(message_size);
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
void DestroyTest() override {
|
|
|
|
|
EXPECT_TRUE(got_notify_);
|
|
|
|
|
EXPECT_TRUE(got_on_query_);
|
|
|
|
|
EXPECT_FALSE(callback_.get());
|
|
|
|
|
|
|
|
|
|
TestHandler::DestroyTest();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
private:
|
|
|
|
|
const TestType test_type_;
|
|
|
|
|
const size_t message_size_;
|
|
|
|
|
const std::string message_size_str_;
|
|
|
|
|
const CharType symbol_;
|
|
|
|
|
|
|
|
|
|
CefRefPtr<Callback> callback_;
|
|
|
|
|
|
|
|
|
|
TrackCallback got_on_query_;
|
|
|
|
|
TrackCallback got_notify_;
|
|
|
|
|
};
|
|
|
|
|
|
2022-07-19 16:09:10 +02:00
|
|
|
using CharTestHandler = ThresholdTestHandler<char>;
|
|
|
|
|
using CharTestHandlerPtr = CefRefPtr<CharTestHandler>;
|
|
|
|
|
|
|
|
|
|
using WCharTestHandler = ThresholdTestHandler<wchar_t>;
|
|
|
|
|
using WCharTestHandlerPtr = CefRefPtr<WCharTestHandler>;
|
2022-07-04 11:49:15 +02:00
|
|
|
|
|
|
|
|
} // namespace
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholdMessageUnderSuccessCallback) {
|
|
|
|
|
const auto UnderThreshold = kMessageSizeThreshold - 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
CharTestHandlerPtr handler =
|
|
|
|
|
new CharTestHandler(TestType::SUCCESS, UnderThreshold, 'A');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholMessageExactdSuccessCallback) {
|
2022-07-19 16:09:10 +02:00
|
|
|
CharTestHandlerPtr handler =
|
|
|
|
|
new CharTestHandler(TestType::SUCCESS, kMessageSizeThreshold, 'A');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholdMessageOverSuccessCallback) {
|
|
|
|
|
const auto OverThreshold = kMessageSizeThreshold + 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
CharTestHandlerPtr handler =
|
|
|
|
|
new CharTestHandler(TestType::SUCCESS, OverThreshold, 'A');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholdMessageUnderFailureCallback) {
|
|
|
|
|
const auto UnderThreshold = kMessageSizeThreshold - 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
CharTestHandlerPtr handler =
|
|
|
|
|
new CharTestHandler(TestType::FAILURE, UnderThreshold, 'A');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholMessageOverdFailureCallback) {
|
|
|
|
|
const auto OverThreshold = kMessageSizeThreshold + 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
CharTestHandlerPtr handler =
|
|
|
|
|
new CharTestHandler(TestType::FAILURE, OverThreshold, 'A');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholdUtf8MessageUnderSuccessCallback) {
|
|
|
|
|
const auto UnderThreshold = kMessageSizeThreshold - 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
WCharTestHandlerPtr handler =
|
|
|
|
|
new WCharTestHandler(TestType::SUCCESS, UnderThreshold, L'\u304B');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
TEST(MessageRouterTest, ThresholdUtf8MessageOverSuccessCallback) {
|
|
|
|
|
const auto OverThreshold = kMessageSizeThreshold + 1;
|
2022-07-19 16:09:10 +02:00
|
|
|
WCharTestHandlerPtr handler =
|
|
|
|
|
new WCharTestHandler(TestType::SUCCESS, OverThreshold, L'\u304B');
|
2022-07-04 11:49:15 +02:00
|
|
|
handler->SetMessageSizeThreshold(kMessageSizeThreshold);
|
|
|
|
|
|
|
|
|
|
handler->ExecuteTest();
|
|
|
|
|
|
|
|
|
|
ReleaseAndWaitForDestructor(handler);
|
2022-07-15 13:53:32 +02:00
|
|
|
}
|
