/* * Copyright (c) 2021, Brandon Scott * Copyright (c) 2020, Hunter Salyer * Copyright (c) 2021, Sam Atkins * * SPDX-License-Identifier: BSD-2-Clause */ #include "WebContentConsoleClient.h" #include #include #include #include #include #include #include #include namespace WebContent { WebContentConsoleClient::WebContentConsoleClient(JS::Console& console, WeakPtr interpreter, ClientConnection& client) : ConsoleClient(console) , m_client(client) , m_interpreter(interpreter) { JS::DeferGC defer_gc(m_interpreter->heap()); auto console_global_object = m_interpreter->heap().allocate_without_global_object(static_cast(m_interpreter->global_object())); console_global_object->initialize_global_object(); m_console_global_object = JS::make_handle(console_global_object); } void WebContentConsoleClient::handle_input(String const& js_source) { auto& settings = verify_cast(*m_interpreter->realm().host_defined()); auto script = Web::HTML::ClassicScript::create("(console)", js_source, settings, settings.api_base_url()); // FIXME: Add parse error printouts back once ClassicScript can report parse errors. auto result = script->run(); StringBuilder output_html; if (result.is_abrupt()) { output_html.append("Uncaught exception: "); auto error = *result.release_error().value(); if (error.is_object()) output_html.append(JS::MarkupGenerator::html_from_error(error.as_object())); else output_html.append(JS::MarkupGenerator::html_from_value(error)); print_html(output_html.string_view()); return; } if (result.value().has_value()) print_html(JS::MarkupGenerator::html_from_value(*result.value())); } void WebContentConsoleClient::print_html(String const& line) { m_message_log.append({ .type = ConsoleOutput::Type::HTML, .data = line }); m_client.async_did_output_js_console_message(m_message_log.size() - 1); } void WebContentConsoleClient::clear_output() { m_message_log.append({ .type = ConsoleOutput::Type::Clear, .data = "" }); m_client.async_did_output_js_console_message(m_message_log.size() - 1); } void WebContentConsoleClient::begin_group(String const& label, bool start_expanded) { m_message_log.append({ .type = start_expanded ? ConsoleOutput::Type::BeginGroup : ConsoleOutput::Type::BeginGroupCollapsed, .data = label }); m_client.async_did_output_js_console_message(m_message_log.size() - 1); } void WebContentConsoleClient::end_group() { m_message_log.append({ .type = ConsoleOutput::Type::EndGroup, .data = "" }); m_client.async_did_output_js_console_message(m_message_log.size() - 1); } void WebContentConsoleClient::send_messages(i32 start_index) { // FIXME: Cap the number of messages we send at once? auto messages_to_send = m_message_log.size() - start_index; if (messages_to_send < 1) { // When the console is first created, it requests any messages that happened before // then, by requesting with start_index=0. If we don't have any messages at all, that // is still a valid request, and we can just ignore it. if (start_index != 0) m_client.did_misbehave("Requested non-existent console message index."); return; } // FIXME: Replace with a single Vector of message structs Vector message_types; Vector messages; message_types.ensure_capacity(messages_to_send); messages.ensure_capacity(messages_to_send); for (size_t i = start_index; i < m_message_log.size(); i++) { auto& message = m_message_log[i]; switch (message.type) { case ConsoleOutput::Type::HTML: message_types.append("html"); break; case ConsoleOutput::Type::Clear: message_types.append("clear"); break; case ConsoleOutput::Type::BeginGroup: message_types.append("group"); break; case ConsoleOutput::Type::BeginGroupCollapsed: message_types.append("groupCollapsed"); break; case ConsoleOutput::Type::EndGroup: message_types.append("groupEnd"); break; } messages.append(message.data); } m_client.async_did_get_js_console_messages(start_index, message_types, messages); } void WebContentConsoleClient::clear() { clear_output(); } // 2.3. Printer(logLevel, args[, options]), https://console.spec.whatwg.org/#printer JS::ThrowCompletionOr WebContentConsoleClient::printer(JS::Console::LogLevel log_level, PrinterArguments arguments) { if (log_level == JS::Console::LogLevel::Trace) { auto trace = arguments.get(); StringBuilder html; if (!trace.label.is_empty()) html.appendff("{}
", escape_html_entities(trace.label)); html.append(""); for (auto& function_name : trace.stack) html.appendff("-> {}
", escape_html_entities(function_name)); html.append("
"); print_html(html.string_view()); return JS::js_undefined(); } if (log_level == JS::Console::LogLevel::Group || log_level == JS::Console::LogLevel::GroupCollapsed) { auto group = arguments.get(); begin_group(group.label, log_level == JS::Console::LogLevel::Group); return JS::js_undefined(); } auto output = String::join(" ", arguments.get>()); m_console.output_debug_message(log_level, output); StringBuilder html; switch (log_level) { case JS::Console::LogLevel::Debug: html.append("(d) "); break; case JS::Console::LogLevel::Error: html.append("(e) "); break; case JS::Console::LogLevel::Info: html.append("(i) "); break; case JS::Console::LogLevel::Log: html.append(" "); break; case JS::Console::LogLevel::Warn: case JS::Console::LogLevel::CountReset: html.append("(w) "); break; default: html.append(""); break; } html.append(escape_html_entities(output)); html.append(""); print_html(html.string_view()); return JS::js_undefined(); } }