/* * Copyright (c) 2020, Andreas Kling * Copyright (c) 2021-2022, Linus Groh * Copyright (c) 2022, Luke Wilde * Copyright (c) 2022, Ali Mohammad Pur * Copyright (c) 2022, Kenneth Myhra * * SPDX-License-Identifier: BSD-2-Clause */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace Web::XHR { JS::NonnullGCPtr XMLHttpRequest::construct_impl(JS::Realm& realm) { auto& window = verify_cast(realm.global_object()); return *realm.heap().allocate(realm, window); } XMLHttpRequest::XMLHttpRequest(HTML::Window& window) : XMLHttpRequestEventTarget(window.realm()) , m_window(window) , m_response_type(Bindings::XMLHttpRequestResponseType::Empty) { set_prototype(&Bindings::cached_web_prototype(window.realm(), "XMLHttpRequest")); } XMLHttpRequest::~XMLHttpRequest() = default; void XMLHttpRequest::visit_edges(Cell::Visitor& visitor) { Base::visit_edges(visitor); visitor.visit(m_window.ptr()); if (auto* value = m_response_object.get_pointer()) visitor.visit(*value); } void XMLHttpRequest::set_ready_state(ReadyState ready_state) { m_ready_state = ready_state; dispatch_event(*DOM::Event::create(realm(), EventNames::readystatechange)); } void XMLHttpRequest::fire_progress_event(String const& event_name, u64 transmitted, u64 length) { ProgressEventInit event_init {}; event_init.length_computable = true; event_init.loaded = transmitted; event_init.total = length; dispatch_event(*ProgressEvent::create(realm(), event_name, event_init)); } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-responsetext WebIDL::ExceptionOr XMLHttpRequest::response_text() const { // 1. If this’s response type is not the empty string or "text", then throw an "InvalidStateError" DOMException. if (m_response_type != Bindings::XMLHttpRequestResponseType::Empty && m_response_type != Bindings::XMLHttpRequestResponseType::Text) return WebIDL::InvalidStateError::create(realm(), "XHR responseText can only be used for responseType \"\" or \"text\""); // 2. If this’s state is not loading or done, then return the empty string. if (m_ready_state != ReadyState::Loading && m_ready_state != ReadyState::Done) return String::empty(); return get_text_response(); } // https://xhr.spec.whatwg.org/#response WebIDL::ExceptionOr XMLHttpRequest::response() { // 1. If this’s response type is the empty string or "text", then: if (m_response_type == Bindings::XMLHttpRequestResponseType::Empty || m_response_type == Bindings::XMLHttpRequestResponseType::Text) { // 1. If this’s state is not loading or done, then return the empty string. if (m_ready_state != ReadyState::Loading && m_ready_state != ReadyState::Done) return JS::Value(JS::js_string(vm(), "")); // 2. Return the result of getting a text response for this. return JS::Value(JS::js_string(vm(), get_text_response())); } // 2. If this’s state is not done, then return null. if (m_ready_state != ReadyState::Done) return JS::js_null(); // 3. If this’s response object is failure, then return null. if (m_response_object.has()) return JS::js_null(); // 4. If this’s response object is non-null, then return it. if (!m_response_object.has()) return m_response_object.get(); // 5. If this’s response type is "arraybuffer", if (m_response_type == Bindings::XMLHttpRequestResponseType::Arraybuffer) { // then set this’s response object to a new ArrayBuffer object representing this’s received bytes. If this throws an exception, then set this’s response object to failure and return null. auto buffer_result = JS::ArrayBuffer::create(realm(), m_received_bytes.size()); if (buffer_result.is_error()) { m_response_object = Failure(); return JS::js_null(); } auto buffer = buffer_result.release_value(); buffer->buffer().overwrite(0, m_received_bytes.data(), m_received_bytes.size()); m_response_object = JS::Value(buffer); } // 6. Otherwise, if this’s response type is "blob", set this’s response object to a new Blob object representing this’s received bytes with type set to the result of get a final MIME type for this. else if (m_response_type == Bindings::XMLHttpRequestResponseType::Blob) { auto blob_part = FileAPI::Blob::create(realm(), m_received_bytes, get_final_mime_type().type()); auto blob = TRY(FileAPI::Blob::create(realm(), Vector { JS::make_handle(*blob_part) })); m_response_object = JS::Value(blob.ptr()); } // 7. Otherwise, if this’s response type is "document", set a document response for this. else if (m_response_type == Bindings::XMLHttpRequestResponseType::Document) { // FIXME: Implement this. return WebIDL::SimpleException { WebIDL::SimpleExceptionType::TypeError, "XHR Document type not implemented" }; } // 8. Otherwise: else { // 1. Assert: this’s response type is "json". // Note: Automatically done by the layers above us. // 2. If this’s response’s body is null, then return null. // FIXME: Implement this once we have 'Response'. if (m_received_bytes.is_empty()) return JS::Value(JS::js_null()); // 3. Let jsonObject be the result of running parse JSON from bytes on this’s received bytes. If that threw an exception, then return null. TextCodec::UTF8Decoder decoder; auto json_object_result = JS::call(vm(), realm().intrinsics().json_parse_function(), JS::js_undefined(), JS::js_string(vm(), decoder.to_utf8({ m_received_bytes.data(), m_received_bytes.size() }))); if (json_object_result.is_error()) return JS::Value(JS::js_null()); // 4. Set this’s response object to jsonObject. m_response_object = json_object_result.release_value(); } // 9. Return this’s response object. return m_response_object.get(); } // https://xhr.spec.whatwg.org/#text-response String XMLHttpRequest::get_text_response() const { // FIXME: 1. If xhr’s response’s body is null, then return the empty string. // 2. Let charset be the result of get a final encoding for xhr. auto charset = get_final_encoding(); auto is_xml_mime_type = [](MimeSniff::MimeType const& mime_type) { // An XML MIME type is any MIME type whose subtype ends in "+xml" or whose essence is "text/xml" or "application/xml". [RFC7303] if (mime_type.essence().is_one_of("text/xml"sv, "application/xml"sv)) return true; return mime_type.subtype().ends_with("+xml"sv); }; // 3. If xhr’s response type is the empty string, charset is null, and the result of get a final MIME type for xhr is an XML MIME type, if (m_response_type == Bindings::XMLHttpRequestResponseType::Empty && !charset.has_value() && is_xml_mime_type(get_final_mime_type())) { // FIXME: then use the rules set forth in the XML specifications to determine the encoding. Let charset be the determined encoding. [XML] [XML-NAMES] } // 4. If charset is null, then set charset to UTF-8. if (!charset.has_value()) charset = "UTF-8"sv; // 5. Return the result of running decode on xhr’s received bytes using fallback encoding charset. auto* decoder = TextCodec::decoder_for(charset.value()); // If we don't support the decoder yet, let's crash instead of attempting to return something, as the result would be incorrect and create obscure bugs. VERIFY(decoder); return TextCodec::convert_input_to_utf8_using_given_decoder_unless_there_is_a_byte_order_mark(*decoder, m_received_bytes); } // https://xhr.spec.whatwg.org/#final-mime-type MimeSniff::MimeType XMLHttpRequest::get_final_mime_type() const { // 1. If xhr’s override MIME type is null, return the result of get a response MIME type for xhr. if (!m_override_mime_type.has_value()) return get_response_mime_type(); // 2. Return xhr’s override MIME type. return *m_override_mime_type; } // https://xhr.spec.whatwg.org/#response-mime-type MimeSniff::MimeType XMLHttpRequest::get_response_mime_type() const { // FIXME: Use an actual HeaderList for XHR headers. auto header_list = make_ref_counted(); for (auto const& entry : m_response_headers) { auto header = Fetch::Infrastructure::Header { .name = MUST(ByteBuffer::copy(entry.key.bytes())), .value = MUST(ByteBuffer::copy(entry.value.bytes())), }; MUST(header_list->append(move(header))); } // 1. Let mimeType be the result of extracting a MIME type from xhr’s response’s header list. auto mime_type = header_list->extract_mime_type(); // 2. If mimeType is failure, then set mimeType to text/xml. if (!mime_type.has_value()) return MimeSniff::MimeType("text"sv, "xml"sv); // 3. Return mimeType. return mime_type.release_value(); } // https://xhr.spec.whatwg.org/#final-charset Optional XMLHttpRequest::get_final_encoding() const { // 1. Let label be null. Optional label; // 2. Let responseMIME be the result of get a response MIME type for xhr. auto response_mime = get_response_mime_type(); // 3. If responseMIME’s parameters["charset"] exists, then set label to it. auto response_mime_charset_it = response_mime.parameters().find("charset"sv); if (response_mime_charset_it != response_mime.parameters().end()) label = response_mime_charset_it->value; // 4. If xhr’s override MIME type’s parameters["charset"] exists, then set label to it. if (m_override_mime_type.has_value()) { auto override_mime_charset_it = m_override_mime_type->parameters().find("charset"sv); if (override_mime_charset_it != m_override_mime_type->parameters().end()) label = override_mime_charset_it->value; } // 5. If label is null, then return null. if (!label.has_value()) return {}; // 6. Let encoding be the result of getting an encoding from label. auto encoding = TextCodec::get_standardized_encoding(label.value()); // 7. If encoding is failure, then return null. // 8. Return encoding. return encoding; } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-setrequestheader WebIDL::ExceptionOr XMLHttpRequest::set_request_header(String const& name_string, String const& value_string) { auto name = name_string.to_byte_buffer(); auto value = value_string.to_byte_buffer(); // 1. If this’s state is not opened, then throw an "InvalidStateError" DOMException. if (m_ready_state != ReadyState::Opened) return WebIDL::InvalidStateError::create(realm(), "XHR readyState is not OPENED"); // 2. If this’s send() flag is set, then throw an "InvalidStateError" DOMException. if (m_send) return WebIDL::InvalidStateError::create(realm(), "XHR send() flag is already set"); // 3. Normalize value. value = MUST(Fetch::Infrastructure::normalize_header_value(value)); // 4. If name is not a header name or value is not a header value, then throw a "SyntaxError" DOMException. if (!Fetch::Infrastructure::is_header_name(name)) return WebIDL::SyntaxError::create(realm(), "Header name contains invalid characters."); if (!Fetch::Infrastructure::is_header_value(value)) return WebIDL::SyntaxError::create(realm(), "Header value contains invalid characters."); // 5. If name is a forbidden header name, then return. if (Fetch::Infrastructure::is_forbidden_header_name(name)) return {}; // 6. Combine (name, value) in this’s author request headers. // FIXME: The header name look-up should be case-insensitive. // FIXME: Headers should be stored as raw byte sequences, not Strings. if (m_request_headers.contains(StringView { name })) { // 1. If list contains name, then set the value of the first such header to its value, // followed by 0x2C 0x20, followed by value. auto maybe_header_value = m_request_headers.get(StringView { name }); m_request_headers.set(StringView { name }, String::formatted("{}, {}", maybe_header_value.release_value(), StringView { name })); } else { // 2. Otherwise, append (name, value) to list. m_request_headers.set(StringView { name }, StringView { value }); } return {}; } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-open WebIDL::ExceptionOr XMLHttpRequest::open(String const& method_string, String const& url) { // 8. If the async argument is omitted, set async to true, and set username and password to null. return open(method_string, url, true, {}, {}); } WebIDL::ExceptionOr XMLHttpRequest::open(String const& method_string, String const& url, bool async, String const& username, String const& password) { auto method = method_string.to_byte_buffer(); // 1. Let settingsObject be this’s relevant settings object. auto& settings_object = m_window->associated_document().relevant_settings_object(); // 2. If settingsObject has a responsible document and it is not fully active, then throw an "InvalidStateError" DOMException. if (settings_object.responsible_document() && !settings_object.responsible_document()->is_active()) return WebIDL::InvalidStateError::create(realm(), "Invalid state: Responsible document is not fully active."); // 3. If method is not a method, then throw a "SyntaxError" DOMException. if (!Fetch::Infrastructure::is_method(method)) return WebIDL::SyntaxError::create(realm(), "An invalid or illegal string was specified."); // 4. If method is a forbidden method, then throw a "SecurityError" DOMException. if (Fetch::Infrastructure::is_forbidden_method(method)) return WebIDL::SecurityError::create(realm(), "Forbidden method, must not be 'CONNECT', 'TRACE', or 'TRACK'"); // 5. Normalize method. method = MUST(Fetch::Infrastructure::normalize_method(method)); // 6. Let parsedURL be the result of parsing url with settingsObject’s API base URL and settingsObject’s API URL character encoding. auto parsed_url = settings_object.api_base_url().complete_url(url); // 7. If parsedURL is failure, then throw a "SyntaxError" DOMException. if (!parsed_url.is_valid()) return WebIDL::SyntaxError::create(realm(), "Invalid URL"); // 8. If the async argument is omitted, set async to true, and set username and password to null. // NOTE: This is handled in the overload lacking the async argument. // 9. If parsedURL’s host is non-null, then: if (!parsed_url.host().is_null()) { // 1. If the username argument is not null, set the username given parsedURL and username. if (!username.is_null()) parsed_url.set_username(username); // 2. If the password argument is not null, set the password given parsedURL and password. if (!password.is_null()) parsed_url.set_password(password); } // FIXME: 10. If async is false, the current global object is a Window object, and either this’s timeout is // not 0 or this’s response type is not the empty string, then throw an "InvalidAccessError" DOMException. // FIXME: 11. Terminate the ongoing fetch operated by the XMLHttpRequest object. // 12. Set variables associated with the object as follows: // Unset this’s send() flag. m_send = false; // Unset this’s upload listener flag. m_upload_listener = false; // Set this’s request method to method. m_method = move(method); // Set this’s request URL to parsedURL. m_url = parsed_url; // Set this’s synchronous flag if async is false; otherwise unset this’s synchronous flag. m_synchronous = !async; // Empty this’s author request headers. m_request_headers.clear(); // FIXME: Set this’s response to a network error. // Set this’s received bytes to the empty byte sequence. m_received_bytes = {}; // Set this’s response object to null. m_response_object = {}; // 13. If this’s state is not opened, then: if (m_ready_state != ReadyState::Opened) { // 1. Set this’s state to opened. // 2. Fire an event named readystatechange at this. set_ready_state(ReadyState::Opened); } return {}; } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-send WebIDL::ExceptionOr XMLHttpRequest::send(Optional body) { auto& vm = this->vm(); auto& realm = *vm.current_realm(); if (m_ready_state != ReadyState::Opened) return WebIDL::InvalidStateError::create(realm, "XHR readyState is not OPENED"); if (m_send) return WebIDL::InvalidStateError::create(realm, "XHR send() flag is already set"); // If this’s request method is `GET` or `HEAD`, then set body to null. if (m_method.is_one_of("GET"sv, "HEAD"sv)) body = {}; auto body_with_type = body.has_value() ? TRY(Fetch::extract_body(realm, body.value())) : Optional {}; AK::URL request_url = m_window->associated_document().parse_url(m_url.to_string()); dbgln("XHR send from {} to {}", m_window->associated_document().url(), request_url); // TODO: Add support for preflight requests to support CORS requests auto request_url_origin = HTML::Origin(request_url.scheme(), request_url.host(), request_url.port_or_default()); bool should_enforce_same_origin_policy = true; if (auto* page = m_window->page()) should_enforce_same_origin_policy = page->is_same_origin_policy_enabled(); if (should_enforce_same_origin_policy && !m_window->associated_document().origin().is_same_origin(request_url_origin)) { dbgln("XHR failed to load: Same-Origin Policy violation: {} may not load {}", m_window->associated_document().url(), request_url); set_ready_state(ReadyState::Done); dispatch_event(*DOM::Event::create(realm, HTML::EventNames::error)); return {}; } auto request = LoadRequest::create_for_url_on_page(request_url, m_window->page()); request.set_method(m_method); if (body_with_type.has_value()) { TRY_OR_RETURN_OOM(realm, body_with_type->body.source().visit([&](ByteBuffer const& buffer) -> ErrorOr { request.set_body(buffer); return {}; }, [&](JS::Handle const& blob) -> ErrorOr { auto byte_buffer = TRY(ByteBuffer::copy(blob->bytes())); request.set_body(byte_buffer); return {}; }, [](auto&) -> ErrorOr { return {}; })); if (body_with_type->type.has_value()) { // If type is non-null and this’s headers’s header list does not contain `Content-Type`, then append (`Content-Type`, type) to this’s headers. if (!m_request_headers.contains("Content-Type"sv)) request.set_header("Content-Type", String { body_with_type->type->span() }); } } for (auto& it : m_request_headers) request.set_header(it.key, it.value); m_upload_complete = false; m_timed_out = false; // FIXME: If req’s body is null (which it always is currently) m_upload_complete = true; m_send = true; if (!m_synchronous) { fire_progress_event(EventNames::loadstart, 0, 0); // FIXME: If this’s upload complete flag is unset and this’s upload listener flag is set, // then fire a progress event named loadstart at this’s upload object with 0 and req’s body’s total bytes. if (m_ready_state != ReadyState::Opened || !m_send) return {}; // FIXME: in order to properly set ReadyState::HeadersReceived and ReadyState::Loading, // we need to make ResourceLoader give us more detailed updates than just "done" and "error". // FIXME: In the Fetch spec, which XHR gets its definition of `status` from, the status code is 0-999. // We could clamp, wrap around (current browser behavior!), or error out. // See: https://github.com/whatwg/fetch/issues/1142 ResourceLoader::the().load( request, [weak_this = make_weak_ptr()](auto data, auto& response_headers, auto status_code) { JS::GCPtr strong_this = weak_this.ptr(); if (!strong_this) return; auto& xhr = const_cast(*weak_this); // FIXME: Handle OOM failure. auto response_data = ByteBuffer::copy(data).release_value_but_fixme_should_propagate_errors(); // FIXME: There's currently no difference between transmitted and length. u64 transmitted = response_data.size(); u64 length = response_data.size(); if (!xhr.m_synchronous) { xhr.m_received_bytes = response_data; xhr.fire_progress_event(EventNames::progress, transmitted, length); } xhr.m_ready_state = ReadyState::Done; xhr.m_status = status_code.value_or(0); xhr.m_response_headers = move(response_headers); xhr.m_send = false; xhr.dispatch_event(*DOM::Event::create(xhr.realm(), EventNames::readystatechange)); xhr.fire_progress_event(EventNames::load, transmitted, length); xhr.fire_progress_event(EventNames::loadend, transmitted, length); }, [weak_this = make_weak_ptr()](auto& error, auto status_code) { dbgln("XHR failed to load: {}", error); JS::GCPtr strong_this = weak_this.ptr(); if (!strong_this) return; auto& xhr = const_cast(*strong_this); xhr.set_ready_state(ReadyState::Done); xhr.set_status(status_code.value_or(0)); xhr.dispatch_event(*DOM::Event::create(xhr.realm(), HTML::EventNames::error)); }, m_timeout, [weak_this = make_weak_ptr()] { JS::GCPtr strong_this = weak_this.ptr(); if (!strong_this) return; auto& xhr = const_cast(*strong_this); xhr.dispatch_event(*DOM::Event::create(xhr.realm(), EventNames::timeout)); }); } else { TODO(); } return {}; } WebIDL::CallbackType* XMLHttpRequest::onreadystatechange() { return event_handler_attribute(Web::XHR::EventNames::readystatechange); } void XMLHttpRequest::set_onreadystatechange(WebIDL::CallbackType* value) { set_event_handler_attribute(Web::XHR::EventNames::readystatechange, value); } // https://xhr.spec.whatwg.org/#the-getallresponseheaders()-method String XMLHttpRequest::get_all_response_headers() const { // FIXME: Implement the spec-compliant sort order. StringBuilder builder; auto keys = m_response_headers.keys(); quick_sort(keys); for (auto& key : keys) { builder.append(key); builder.append(": "sv); builder.append(m_response_headers.get(key).value()); builder.append("\r\n"sv); } return builder.to_string(); } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-overridemimetype WebIDL::ExceptionOr XMLHttpRequest::override_mime_type(String const& mime) { // 1. If this’s state is loading or done, then throw an "InvalidStateError" DOMException. if (m_ready_state == ReadyState::Loading || m_ready_state == ReadyState::Done) return WebIDL::InvalidStateError::create(realm(), "Cannot override MIME type when state is Loading or Done."); // 2. Set this’s override MIME type to the result of parsing mime. m_override_mime_type = MimeSniff::MimeType::from_string(mime); // 3. If this’s override MIME type is failure, then set this’s override MIME type to application/octet-stream. if (!m_override_mime_type.has_value()) m_override_mime_type = MimeSniff::MimeType("application"sv, "octet-stream"sv); return {}; } // https://xhr.spec.whatwg.org/#ref-for-dom-xmlhttprequest-timeout%E2%91%A2 WebIDL::ExceptionOr XMLHttpRequest::set_timeout(u32 timeout) { // 1. If the current global object is a Window object and this’s synchronous flag is set, // then throw an "InvalidAccessError" DOMException. if (is(HTML::current_global_object()) && m_synchronous) return WebIDL::InvalidAccessError::create(realm(), "Use of XMLHttpRequest's timeout attribute is not supported in the synchronous mode in window context."); // 2. Set this’s timeout to the given value. m_timeout = timeout; return {}; } // https://xhr.spec.whatwg.org/#dom-xmlhttprequest-timeout u32 XMLHttpRequest::timeout() const { return m_timeout; } }