| 1 | /* |
| 2 | * Copyright (C) 2017 Igalia S.L. |
| 3 | * |
| 4 | * This library is free software; you can redistribute it and/or |
| 5 | * modify it under the terms of the GNU Lesser General Public |
| 6 | * License as published by the Free Software Foundation; either |
| 7 | * version 2,1 of the License, or (at your option) any later version. |
| 8 | * |
| 9 | * This library is distributed in the hope that it will be useful, |
| 10 | * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 11 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
| 12 | * Library General Public License for more details. |
| 13 | * |
| 14 | * You should have received a copy of the GNU Library General Public License |
| 15 | * along with this library; see the file COPYING.LIB. If not, write to |
| 16 | * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, |
| 17 | * Boston, MA 02110-1301, USA. |
| 18 | */ |
| 19 | |
| 20 | #include "config.h" |
| 21 | |
| 22 | #include "TestMain.h" |
| 23 | #include <gio/gio.h> |
| 24 | #include <wtf/UUID.h> |
| 25 | #include <wtf/text/StringBuilder.h> |
| 26 | |
| 27 | class AutomationTest: public Test { |
| 28 | public: |
| 29 | MAKE_GLIB_TEST_FIXTURE(AutomationTest); |
| 30 | |
| 31 | AutomationTest() |
| 32 | : m_mainLoop(adoptGRef(g_main_loop_new(nullptr, TRUE))) |
| 33 | { |
| 34 | g_dbus_connection_new_for_address("tcp:host=127.0.0.1,port=2229" , |
| 35 | G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT, nullptr, nullptr, [](GObject*, GAsyncResult* result, gpointer userData) { |
| 36 | GRefPtr<GDBusConnection> connection = adoptGRef(g_dbus_connection_new_for_address_finish(result, nullptr)); |
| 37 | static_cast<AutomationTest*>(userData)->setConnection(WTFMove(connection)); |
| 38 | }, this); |
| 39 | g_main_loop_run(m_mainLoop.get()); |
| 40 | } |
| 41 | |
| 42 | ~AutomationTest() |
| 43 | { |
| 44 | } |
| 45 | |
| 46 | struct Target { |
| 47 | Target() = default; |
| 48 | Target(guint64 id, CString name, bool isPaired) |
| 49 | : id(id) |
| 50 | , name(name) |
| 51 | , isPaired(isPaired) |
| 52 | { |
| 53 | } |
| 54 | |
| 55 | guint64 id { 0 }; |
| 56 | CString name; |
| 57 | bool isPaired { false }; |
| 58 | }; |
| 59 | |
| 60 | const GDBusInterfaceVTable s_interfaceVTable = { |
| 61 | // method_call |
| 62 | [](GDBusConnection* connection, const gchar* sender, const gchar* objectPath, const gchar* interfaceName, const gchar* methodName, GVariant* parameters, GDBusMethodInvocation* invocation, gpointer userData) { |
| 63 | auto* test = static_cast<AutomationTest*>(userData); |
| 64 | if (!g_strcmp0(methodName, "SetTargetList" )) { |
| 65 | guint64 connectionID; |
| 66 | GUniqueOutPtr<GVariantIter> iter; |
| 67 | g_variant_get(parameters, "(ta(tsssb))" , &connectionID, &iter.outPtr()); |
| 68 | guint64 targetID; |
| 69 | const char* type; |
| 70 | const char* name; |
| 71 | const char* dummy; |
| 72 | gboolean isPaired; |
| 73 | while (g_variant_iter_loop(iter.get(), "(t&s&s&sb)" , &targetID, &type, &name, &dummy, &isPaired)) { |
| 74 | if (!g_strcmp0(type, "Automation" )) { |
| 75 | test->setTarget(connectionID, Target(targetID, name, isPaired)); |
| 76 | break; |
| 77 | } |
| 78 | } |
| 79 | g_dbus_method_invocation_return_value(invocation, nullptr); |
| 80 | } else if (!g_strcmp0(methodName, "SendMessageToFrontend" )) { |
| 81 | guint64 connectionID, targetID; |
| 82 | const char* message; |
| 83 | g_variant_get(parameters, "(tt&s)" , &connectionID, &targetID, &message); |
| 84 | test->receivedMessage(connectionID, targetID, message); |
| 85 | g_dbus_method_invocation_return_value(invocation, nullptr); |
| 86 | } |
| 87 | }, |
| 88 | // get_property |
| 89 | nullptr, |
| 90 | // set_property |
| 91 | nullptr, |
| 92 | // padding |
| 93 | { 0 } |
| 94 | }; |
| 95 | |
| 96 | void registerDBusObject() |
| 97 | { |
| 98 | static const char introspectionXML[] = |
| 99 | "<node>" |
| 100 | " <interface name='org.webkit.RemoteInspectorClient'>" |
| 101 | " <method name='SetTargetList'>" |
| 102 | " <arg type='t' name='connectionID' direction='in'/>" |
| 103 | " <arg type='a(tsssb)' name='list' direction='in'/>" |
| 104 | " </method>" |
| 105 | " <method name='SendMessageToFrontend'>" |
| 106 | " <arg type='t' name='connectionID' direction='in'/>" |
| 107 | " <arg type='t' name='target' direction='in'/>" |
| 108 | " <arg type='s' name='message' direction='in'/>" |
| 109 | " </method>" |
| 110 | " </interface>" |
| 111 | "</node>" ; |
| 112 | static GDBusNodeInfo* introspectionData = nullptr; |
| 113 | if (!introspectionData) |
| 114 | introspectionData = g_dbus_node_info_new_for_xml(introspectionXML, nullptr); |
| 115 | g_dbus_connection_register_object(m_connection.get(), "/org/webkit/RemoteInspectorClient" , introspectionData->interfaces[0], &s_interfaceVTable, this, nullptr, nullptr); |
| 116 | } |
| 117 | |
| 118 | void setConnection(GRefPtr<GDBusConnection>&& connection) |
| 119 | { |
| 120 | g_assert_true(G_IS_DBUS_CONNECTION(connection.get())); |
| 121 | m_connection = WTFMove(connection); |
| 122 | registerDBusObject(); |
| 123 | g_main_loop_quit(m_mainLoop.get()); |
| 124 | } |
| 125 | |
| 126 | void setTarget(guint64 connectionID, Target&& target) |
| 127 | { |
| 128 | bool newConnection = !m_connectionID; |
| 129 | bool wasPaired = m_target.isPaired; |
| 130 | m_connectionID = connectionID; |
| 131 | m_target = WTFMove(target); |
| 132 | if (newConnection || (!wasPaired && m_target.isPaired)) |
| 133 | g_main_loop_quit(m_mainLoop.get()); |
| 134 | } |
| 135 | |
| 136 | void receivedMessage(guint64 connectionID, guint64 targetID, const char* message) |
| 137 | { |
| 138 | g_assert_cmpuint(connectionID, ==, m_connectionID); |
| 139 | g_assert_cmpuint(targetID, ==, m_target.id); |
| 140 | m_message = message; |
| 141 | g_main_loop_quit(m_mainLoop.get()); |
| 142 | } |
| 143 | |
| 144 | void sendCommandToBackend(const String& command, const String& parameters = String()) |
| 145 | { |
| 146 | static long sequenceID = 0; |
| 147 | StringBuilder messageBuilder; |
| 148 | messageBuilder.appendLiteral("{\"id\":" ); |
| 149 | messageBuilder.appendNumber(++sequenceID); |
| 150 | messageBuilder.appendLiteral(",\"method\":\"Automation." ); |
| 151 | messageBuilder.append(command); |
| 152 | messageBuilder.append('"'); |
| 153 | if (!parameters.isNull()) { |
| 154 | messageBuilder.appendLiteral(",\"params\":" ); |
| 155 | messageBuilder.append(parameters); |
| 156 | } |
| 157 | messageBuilder.append('}'); |
| 158 | g_dbus_connection_call(m_connection.get(), nullptr, "/org/webkit/Inspector" , "org.webkit.Inspector" , |
| 159 | "SendMessageToBackend" , g_variant_new("(tts)" , m_connectionID, m_target.id, messageBuilder.toString().utf8().data()), |
| 160 | nullptr, G_DBUS_CALL_FLAGS_NO_AUTO_START, -1, nullptr, nullptr, nullptr); |
| 161 | } |
| 162 | |
| 163 | static WebKitWebView* createWebViewCallback(WebKitAutomationSession* session, AutomationTest* test) |
| 164 | { |
| 165 | test->m_createWebViewWasCalled = true; |
| 166 | return test->m_webViewForAutomation; |
| 167 | } |
| 168 | |
| 169 | void automationStarted(WebKitAutomationSession* session) |
| 170 | { |
| 171 | m_session = session; |
| 172 | assertObjectIsDeletedWhenTestFinishes(G_OBJECT(m_session)); |
| 173 | g_assert_null(webkit_automation_session_get_application_info(session)); |
| 174 | WebKitApplicationInfo* info = webkit_application_info_new(); |
| 175 | webkit_application_info_set_name(info, "AutomationTestBrowser" ); |
| 176 | webkit_application_info_set_version(info, WEBKIT_MAJOR_VERSION, WEBKIT_MINOR_VERSION, WEBKIT_MICRO_VERSION); |
| 177 | webkit_automation_session_set_application_info(session, info); |
| 178 | webkit_application_info_unref(info); |
| 179 | g_assert_true(webkit_automation_session_get_application_info(session) == info); |
| 180 | } |
| 181 | |
| 182 | static void automationStartedCallback(WebKitWebContext* webContext, WebKitAutomationSession* session, AutomationTest* test) |
| 183 | { |
| 184 | g_assert_true(webContext == test->m_webContext.get()); |
| 185 | g_assert_true(WEBKIT_IS_AUTOMATION_SESSION(session)); |
| 186 | test->automationStarted(session); |
| 187 | } |
| 188 | |
| 189 | static GUniquePtr<char> toVersionString(unsigned major, unsigned minor, unsigned micro) |
| 190 | { |
| 191 | if (!micro && !minor) |
| 192 | return GUniquePtr<char>(g_strdup_printf("%u" , major)); |
| 193 | |
| 194 | if (!micro) |
| 195 | return GUniquePtr<char>(g_strdup_printf("%u.%u" , major, minor)); |
| 196 | |
| 197 | return GUniquePtr<char>(g_strdup_printf("%u.%u.%u" , major, minor, micro)); |
| 198 | } |
| 199 | |
| 200 | WebKitAutomationSession* requestSession(const char* sessionID) |
| 201 | { |
| 202 | auto signalID = g_signal_connect(m_webContext.get(), "automation-started" , G_CALLBACK(automationStartedCallback), this); |
| 203 | g_dbus_connection_call(m_connection.get(), nullptr, "/org/webkit/Inspector" , "org.webkit.Inspector" , |
| 204 | "StartAutomationSession" , g_variant_new("(sa{sv})" , sessionID, nullptr), nullptr, G_DBUS_CALL_FLAGS_NO_AUTO_START, -1, nullptr, |
| 205 | [](GObject* source, GAsyncResult* result, gpointer userData) { |
| 206 | auto* test = static_cast<AutomationTest*>(userData); |
| 207 | if (!test->m_session) |
| 208 | return; |
| 209 | |
| 210 | GRefPtr<GVariant> capabilities = adoptGRef(g_dbus_connection_call_finish(G_DBUS_CONNECTION(source), result, nullptr)); |
| 211 | g_assert_nonnull(capabilities.get()); |
| 212 | const char* browserName; |
| 213 | const char* browserVersion; |
| 214 | g_variant_get(capabilities.get(), "(&s&s)" , &browserName, &browserVersion); |
| 215 | g_assert_cmpstr(browserName, ==, "AutomationTestBrowser" ); |
| 216 | GUniquePtr<char> versionString = toVersionString(WEBKIT_MAJOR_VERSION, WEBKIT_MINOR_VERSION, WEBKIT_MICRO_VERSION); |
| 217 | g_assert_cmpstr(browserVersion, ==, versionString.get()); |
| 218 | }, this |
| 219 | ); |
| 220 | auto timeoutID = g_timeout_add(1000, [](gpointer userData) -> gboolean { |
| 221 | g_main_loop_quit(static_cast<GMainLoop*>(userData)); |
| 222 | return G_SOURCE_REMOVE; |
| 223 | }, m_mainLoop.get()); |
| 224 | g_main_loop_run(m_mainLoop.get()); |
| 225 | if (!m_connectionID) |
| 226 | m_session = nullptr; |
| 227 | if (m_session && m_connectionID) |
| 228 | g_source_remove(timeoutID); |
| 229 | g_signal_handler_disconnect(m_webContext.get(), signalID); |
| 230 | return m_session; |
| 231 | } |
| 232 | |
| 233 | void setupIfNeeded() |
| 234 | { |
| 235 | if (m_target.isPaired) |
| 236 | return; |
| 237 | g_assert_cmpuint(m_target.id, !=, 0); |
| 238 | g_dbus_connection_call(m_connection.get(), nullptr, "/org/webkit/Inspector" , "org.webkit.Inspector" , |
| 239 | "Setup" , g_variant_new("(tt)" , m_connectionID, m_target.id), nullptr, G_DBUS_CALL_FLAGS_NO_AUTO_START, -1, nullptr, nullptr, nullptr); |
| 240 | g_main_loop_run(m_mainLoop.get()); |
| 241 | g_assert_true(m_target.isPaired); |
| 242 | } |
| 243 | |
| 244 | bool createTopLevelBrowsingContext(WebKitWebView* webView) |
| 245 | { |
| 246 | setupIfNeeded(); |
| 247 | m_webViewForAutomation = webView; |
| 248 | m_createWebViewWasCalled = false; |
| 249 | m_message = CString(); |
| 250 | auto signalID = g_signal_connect(m_session, "create-web-view" , G_CALLBACK(createWebViewCallback), this); |
| 251 | sendCommandToBackend("createBrowsingContext" ); |
| 252 | g_main_loop_run(m_mainLoop.get()); |
| 253 | g_signal_handler_disconnect(m_session, signalID); |
| 254 | g_assert_true(m_createWebViewWasCalled); |
| 255 | g_assert_false(m_message.isNull()); |
| 256 | m_webViewForAutomation = nullptr; |
| 257 | |
| 258 | if (strstr(m_message.data(), "The remote session failed to create a new browsing context" )) |
| 259 | return false; |
| 260 | if (strstr(m_message.data(), "handle" )) |
| 261 | return true; |
| 262 | return false; |
| 263 | } |
| 264 | |
| 265 | GRefPtr<GMainLoop> m_mainLoop; |
| 266 | GRefPtr<GDBusConnection> m_connection; |
| 267 | WebKitAutomationSession* m_session; |
| 268 | guint64 m_connectionID { 0 }; |
| 269 | Target m_target; |
| 270 | |
| 271 | WebKitWebView* m_webViewForAutomation { nullptr }; |
| 272 | bool m_createWebViewWasCalled { false }; |
| 273 | CString m_message; |
| 274 | }; |
| 275 | |
| 276 | static void testAutomationSessionRequestSession(AutomationTest* test, gconstpointer) |
| 277 | { |
| 278 | String sessionID = createCanonicalUUIDString(); |
| 279 | // WebKitAutomationSession::automation-started is never emitted if automation is not enabled. |
| 280 | g_assert_false(webkit_web_context_is_automation_allowed(test->m_webContext.get())); |
| 281 | auto* session = test->requestSession(sessionID.utf8().data()); |
| 282 | g_assert_null(session); |
| 283 | |
| 284 | webkit_web_context_set_automation_allowed(test->m_webContext.get(), TRUE); |
| 285 | g_assert_true(webkit_web_context_is_automation_allowed(test->m_webContext.get())); |
| 286 | |
| 287 | // There can't be more than one context with automation enabled |
| 288 | GRefPtr<WebKitWebContext> otherContext = adoptGRef(webkit_web_context_new()); |
| 289 | test->removeLogFatalFlag(G_LOG_LEVEL_WARNING); |
| 290 | webkit_web_context_set_automation_allowed(otherContext.get(), TRUE); |
| 291 | test->addLogFatalFlag(G_LOG_LEVEL_WARNING); |
| 292 | g_assert_false(webkit_web_context_is_automation_allowed(otherContext.get())); |
| 293 | |
| 294 | session = test->requestSession(sessionID.utf8().data()); |
| 295 | g_assert_cmpstr(webkit_automation_session_get_id(session), ==, sessionID.utf8().data()); |
| 296 | g_assert_cmpuint(test->m_target.id, >, 0); |
| 297 | ASSERT_CMP_CSTRING(test->m_target.name, ==, sessionID.utf8()); |
| 298 | g_assert_false(test->m_target.isPaired); |
| 299 | |
| 300 | // Will fail to create a browsing context when not creating a web view (or not handling the signal). |
| 301 | g_assert_false(test->createTopLevelBrowsingContext(nullptr)); |
| 302 | |
| 303 | // Will also fail if the web view is not controlled by automation. |
| 304 | auto webView = Test::adoptView(Test::createWebView(test->m_webContext.get())); |
| 305 | g_assert_false(webkit_web_view_is_controlled_by_automation(webView.get())); |
| 306 | g_assert_false(test->createTopLevelBrowsingContext(webView.get())); |
| 307 | |
| 308 | // And will work with a proper web view. |
| 309 | webView = Test::adoptView(g_object_new(WEBKIT_TYPE_WEB_VIEW, |
| 310 | #if PLATFORM(WPE) |
| 311 | "backend" , Test::createWebViewBackend(), |
| 312 | #endif |
| 313 | "web-context" , test->m_webContext.get(), |
| 314 | "is-controlled-by-automation" , TRUE, |
| 315 | nullptr)); |
| 316 | g_assert_true(webkit_web_view_is_controlled_by_automation(webView.get())); |
| 317 | g_assert_true(test->createTopLevelBrowsingContext(webView.get())); |
| 318 | |
| 319 | webkit_web_context_set_automation_allowed(test->m_webContext.get(), FALSE); |
| 320 | } |
| 321 | |
| 322 | static void testAutomationSessionApplicationInfo(Test* test, gconstpointer) |
| 323 | { |
| 324 | WebKitApplicationInfo* info = webkit_application_info_new(); |
| 325 | g_assert_cmpstr(webkit_application_info_get_name(info), ==, g_get_prgname()); |
| 326 | webkit_application_info_set_name(info, "WebKitGTKBrowser" ); |
| 327 | g_assert_cmpstr(webkit_application_info_get_name(info), ==, "WebKitGTKBrowser" ); |
| 328 | webkit_application_info_set_name(info, nullptr); |
| 329 | g_assert_cmpstr(webkit_application_info_get_name(info), ==, g_get_prgname()); |
| 330 | |
| 331 | guint64 major, minor, micro; |
| 332 | webkit_application_info_get_version(info, &major, nullptr, nullptr); |
| 333 | g_assert_cmpuint(major, ==, 0); |
| 334 | webkit_application_info_set_version(info, 1, 2, 3); |
| 335 | webkit_application_info_get_version(info, &major, &minor, µ); |
| 336 | g_assert_cmpuint(major, ==, 1); |
| 337 | g_assert_cmpuint(minor, ==, 2); |
| 338 | g_assert_cmpuint(micro, ==, 3); |
| 339 | |
| 340 | webkit_application_info_unref(info); |
| 341 | } |
| 342 | |
| 343 | |
| 344 | void beforeAll() |
| 345 | { |
| 346 | g_setenv("WEBKIT_INSPECTOR_SERVER" , "127.0.0.1:2229" , TRUE); |
| 347 | |
| 348 | AutomationTest::add("WebKitAutomationSession" , "request-session" , testAutomationSessionRequestSession); |
| 349 | Test::add("WebKitAutomationSession" , "application-info" , testAutomationSessionApplicationInfo); |
| 350 | } |
| 351 | |
| 352 | void afterAll() |
| 353 | { |
| 354 | g_unsetenv("WEBKIT_INSPECTOR_SERVER" ); |
| 355 | } |
| 356 | |