script/dom/fetch/

request.rs

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at https://mozilla.org/MPL/2.0/. */

use std::cell::Ref;
use std::str::FromStr;

use cssparser::match_ignore_ascii_case;
use dom_struct::dom_struct;
use http::Method as HttpMethod;
use http::header::{CONTENT_TYPE, HeaderValue};
use http::method::InvalidMethod;
use js::context::JSContext;
use js::rust::HandleObject;
use net_traits::ReferrerPolicy as MsgReferrerPolicy;
use net_traits::fetch::headers::is_forbidden_method;
use net_traits::request::{
    CacheMode, CredentialsMode, Destination, Origin, RedirectMode, Referrer,
    Request as NetTraitsRequest, RequestBuilder, RequestMode as NetTraitsRequestMode,
    TraversableForUserPrompts,
};
use script_bindings::cell::DomRefCell;
use script_bindings::cformat;
use script_bindings::reflector::{Reflector, reflect_dom_object_with_proto};
use servo_url::ServoUrl;

use crate::conversions::Convert;
use crate::dom::RootedPromise;
use crate::dom::abortsignal::AbortSignal;
use crate::dom::bindings::codegen::Bindings::HeadersBinding::HeadersMethods;
use crate::dom::bindings::codegen::Bindings::RequestBinding::{
    ReferrerPolicy, RequestCache, RequestCredentials, RequestDestination, RequestDuplex,
    RequestInfo, RequestInit, RequestMethods, RequestMode, RequestRedirect,
};
use crate::dom::bindings::error::{Error, Fallible};
use crate::dom::bindings::reflector::DomGlobal;
use crate::dom::bindings::root::{DomRoot, MutNullableDom};
use crate::dom::bindings::str::{ByteString, DOMString, USVString};
use crate::dom::globalscope::GlobalScope;
use crate::dom::headers::{Guard, Headers};
use crate::dom::stream::readablestream::ReadableStream;
use crate::fetch::body::{
    BodyMixin, BodyType, Extractable, body_text_stream, clone_body_stream_for_dom_body,
    consume_body,
};
use crate::fetch::fetch::RequestWithGlobalScope;
use crate::url::ensure_blob_referenced_by_url_is_kept_alive;

#[dom_struct]
pub(crate) struct Request {
    reflector_: Reflector,
    #[no_trace]
    /// <https://fetch.spec.whatwg.org/#concept-request-request>
    request: DomRefCell<NetTraitsRequest>,
    /// <https://fetch.spec.whatwg.org/#concept-request-body>
    body_stream: MutNullableDom<ReadableStream>,
    /// <https://fetch.spec.whatwg.org/#request-headers>
    headers: MutNullableDom<Headers>,
    /// <https://fetch.spec.whatwg.org/#request-signal>
    signal: MutNullableDom<AbortSignal>,
}

impl Request {
    fn new_inherited(global: &GlobalScope, url: ServoUrl) -> Request {
        Request {
            reflector_: Reflector::new(),
            request: DomRefCell::new(net_request_from_global(global, url)),
            body_stream: MutNullableDom::new(None),
            headers: Default::default(),
            signal: MutNullableDom::new(None),
        }
    }

    pub(crate) fn new(
        cx: &mut JSContext,
        global: &GlobalScope,
        proto: Option<HandleObject>,
        url: ServoUrl,
    ) -> DomRoot<Request> {
        reflect_dom_object_with_proto(
            cx,
            Box::new(Request::new_inherited(global, url)),
            global,
            proto,
        )
    }

    fn from_net_request(
        cx: &mut JSContext,
        global: &GlobalScope,
        proto: Option<HandleObject>,
        net_request: NetTraitsRequest,
    ) -> DomRoot<Request> {
        let r = Request::new(cx, global, proto, net_request.current_url());
        *r.request.borrow_mut() = net_request;
        r
    }

    // https://fetch.spec.whatwg.org/#dom-request
    pub(crate) fn constructor(
        cx: &mut js::context::JSContext,
        global: &GlobalScope,
        proto: Option<HandleObject>,
        mut input: RequestInfo,
        init: &RequestInit,
    ) -> Fallible<DomRoot<Request>> {
        // Step 1. Let request be null.
        let temporary_request: NetTraitsRequest;

        // Step 2. Let fallbackMode be null.
        let mut fallback_mode: Option<NetTraitsRequestMode> = None;

        // Step 3. Let baseURL be this’s relevant settings object’s API base URL.
        let base_url = global.api_base_url();

        // Step 4. Let signal be null.
        let mut signal: Option<DomRoot<AbortSignal>> = None;

        // Required later for step 41.1
        let mut input_body_is_unusable = false;

        match input {
            // Step 5. If input is a string, then:
            RequestInfo::USVString(USVString(ref usv_string)) => {
                // Step 5.1. Let parsedURL be the result of parsing input with baseURL.
                let parsed_url = base_url.join(usv_string);
                // Step 5.2. If parsedURL is failure, then throw a TypeError.
                if parsed_url.is_err() {
                    return Err(Error::Type(c"Url could not be parsed".to_owned()));
                }
                // Step 5.3. If parsedURL includes credentials, then throw a TypeError.
                let url = parsed_url.unwrap();
                if includes_credentials(&url) {
                    return Err(Error::Type(c"Url includes credentials".to_owned()));
                }
                // Step 5.4. Set request to a new request whose URL is parsedURL.
                temporary_request = net_request_from_global(global, url);
                // Step 5.5. Set fallbackMode to "cors".
                fallback_mode = Some(NetTraitsRequestMode::CorsMode);
            },
            // Step 6. Otherwise:
            // Step 6.1. Assert: input is a Request object.
            RequestInfo::Request(ref input_request) => {
                // Preparation for step 41.1
                input_body_is_unusable = input_request.is_unusable();
                // Step 6.2. Set request to input’s request.
                temporary_request = input_request.request.borrow().clone();
                // Step 6.3. Set signal to input’s signal.
                signal = Some(input_request.Signal());
            },
        }

        // Step 7. Let origin be this’s relevant settings object’s origin.
        let origin = global.origin();
        let origin = origin.immutable();

        // Step 8. Let traversableForUserPrompts be "client".
        let mut traversable_for_user_prompts = TraversableForUserPrompts::Client;

        // Step 9. If request’s traversable for user prompts is an environment settings object
        // and its origin is same origin with origin, then set traversableForUserPrompts
        // to request’s traversable for user prompts.
        // TODO: `environment settings object` is not implemented in Servo yet.

        // Step 10. If init["window"] exists and is non-null, then throw a TypeError.
        if !init.window.get().is_null_or_undefined() {
            return Err(Error::Type(c"Window is present and is not null".to_owned()));
        }

        // Step 11. If init["window"] exists, then set traversableForUserPrompts to "no-traversable".
        if !init.window.get().is_undefined() {
            traversable_for_user_prompts = TraversableForUserPrompts::NoTraversable;
        }

        // Step 12. Set request to a new request with the following properties:
        let mut request: NetTraitsRequest;
        request = net_request_from_global(global, temporary_request.current_url());
        request.method = temporary_request.method;
        request.headers = temporary_request.headers;
        request.unsafe_request = true;
        request.traversable_for_user_prompts = traversable_for_user_prompts;
        // TODO: `entry settings object` is not implemented in Servo yet.
        request.origin = Origin::Client;
        request.referrer = temporary_request.referrer;
        request.referrer_policy = temporary_request.referrer_policy;
        request.mode = temporary_request.mode;
        request.credentials_mode = temporary_request.credentials_mode;
        request.cache_mode = temporary_request.cache_mode;
        request.redirect_mode = temporary_request.redirect_mode;
        request.integrity_metadata = temporary_request.integrity_metadata;
        // reload-navigation flag: request’s reload-navigation flag.
        request.reload_navigation = temporary_request.reload_navigation;
        // history-navigation flag: request’s history-navigation flag.
        request.history_navigation = temporary_request.history_navigation;

        // Step 13. If init is not empty, then:
        if init.body.is_some() ||
            init.cache.is_some() ||
            init.credentials.is_some() ||
            init.duplex.is_some() ||
            init.integrity.is_some() ||
            init.headers.is_some() ||
            init.keepalive.is_some() ||
            init.method.is_some() ||
            init.mode.is_some() ||
            init.redirect.is_some() ||
            init.referrer.is_some() ||
            init.referrerPolicy.is_some() ||
            !init.window.get().is_undefined()
        {
            // Step 13.1. If request’s mode is "navigate", then set it to "same-origin".
            if request.mode == NetTraitsRequestMode::Navigate {
                request.mode = NetTraitsRequestMode::SameOrigin;
            }
            // Step 13.2. Unset request’s reload-navigation flag.
            request.reload_navigation = false;
            // Step 13.3. Unset request’s history-navigation flag.
            request.history_navigation = false;
            // Step 13.4. Set request’s origin to "client".
            // TODO
            // Step 13.5. Set request’s referrer to "client".
            request.referrer = global.get_referrer();
            // Step 13.6. Set request’s referrer policy to the empty string.
            request.referrer_policy = MsgReferrerPolicy::EmptyString;
            // Step 13.7. Set request’s URL to request’s current URL.
            // TODO
            // Step 13.8. Set request’s URL list to « request’s URL ».
            // TODO
        }

        // Step 14. If init["referrer"] exists, then:
        if let Some(init_referrer) = init.referrer.as_ref() {
            // Step 14.1. Let referrer be init["referrer"].
            let referrer = &init_referrer.0;
            // Step 14.2. If referrer is the empty string, then set request’s referrer to "no-referrer".
            if referrer.is_empty() {
                request.referrer = Referrer::NoReferrer;
            // Step 14.3. Otherwise:
            } else {
                // Step 14.3.1. Let parsedReferrer be the result of parsing referrer with baseURL.
                let parsed_referrer = base_url.join(referrer);
                // Step 14.3.2. If parsedReferrer is failure, then throw a TypeError.
                if parsed_referrer.is_err() {
                    return Err(Error::Type(c"Failed to parse referrer url".to_owned()));
                }
                // Step 14.3.3. If one of the following is true
                // parsedReferrer’s scheme is "about" and path is the string "client"
                // parsedReferrer’s origin is not same origin with origin
                if let Ok(parsed_referrer) = parsed_referrer {
                    if (parsed_referrer.cannot_be_a_base() &&
                        parsed_referrer.scheme() == "about" &&
                        parsed_referrer.path() == "client") ||
                        parsed_referrer.origin() != *origin
                    {
                        // then set request’s referrer to "client".
                        request.referrer = global.get_referrer();
                    } else {
                        // Step 14.3.4. Otherwise, set request’s referrer to parsedReferrer.
                        request.referrer = Referrer::ReferrerUrl(parsed_referrer);
                    }
                }
            }
        }

        // Step 15. If init["referrerPolicy"] exists, then set request’s referrer policy to it.
        if let Some(init_referrerpolicy) = init.referrerPolicy.as_ref() {
            let init_referrer_policy = (*init_referrerpolicy).convert();
            request.referrer_policy = init_referrer_policy;
        }

        // Step 16. Let mode be init["mode"] if it exists, and fallbackMode otherwise.
        let mode = init.mode.as_ref().map(|m| (*m).convert()).or(fallback_mode);

        // Step 17. If mode is "navigate", then throw a TypeError.
        if let Some(NetTraitsRequestMode::Navigate) = mode {
            return Err(Error::Type(c"Request mode is Navigate".to_owned()));
        }

        // Step 18. If mode is non-null, set request’s mode to mode.
        if let Some(m) = mode {
            request.mode = m;
        }

        // Step 19. If init["credentials"] exists, then set request’s credentials mode to it.
        if let Some(init_credentials) = init.credentials.as_ref() {
            let credentials = (*init_credentials).convert();
            request.credentials_mode = credentials;
        }

        // Step 20. If init["cache"] exists, then set request’s cache mode to it.
        if let Some(init_cache) = init.cache.as_ref() {
            let cache = (*init_cache).convert();
            request.cache_mode = cache;
        }

        // Step 21. If request’s cache mode is "only-if-cached" and request’s mode
        // is not "same-origin", then throw a TypeError.
        if request.cache_mode == CacheMode::OnlyIfCached &&
            request.mode != NetTraitsRequestMode::SameOrigin
        {
            return Err(Error::Type(
                c"Cache is 'only-if-cached' and mode is not 'same-origin'".to_owned(),
            ));
        }

        // Step 22. If init["redirect"] exists, then set request’s redirect mode to it.
        if let Some(init_redirect) = init.redirect.as_ref() {
            let redirect = (*init_redirect).convert();
            request.redirect_mode = redirect;
        }

        // Step 23. If init["integrity"] exists, then set request’s integrity metadata to it.
        if let Some(init_integrity) = init.integrity.as_ref() {
            let integrity = init_integrity.to_string();
            request.integrity_metadata = integrity;
        }

        // Step 24. If init["keepalive"] exists, then set request’s keepalive to it.
        if let Some(init_keepalive) = init.keepalive {
            request.keep_alive = init_keepalive;
        }

        // Step 25. If init["method"] exists, then:
        // Step 25.1. Let method be init["method"].
        if let Some(init_method) = init.method.as_ref() {
            // Step 25.2. If method is not a method or method is a forbidden method, then throw a TypeError.
            if !is_method(init_method) {
                return Err(Error::Type(c"Method is not a method".to_owned()));
            }
            if is_forbidden_method(init_method) {
                return Err(Error::Type(c"Method is forbidden".to_owned()));
            }
            // Step 25.3. Normalize method.
            let method = match init_method.as_str() {
                Some(s) => normalize_method(s)
                    .map_err(|e| Error::Type(cformat!("Method is not valid: {:?}", e)))?,
                None => return Err(Error::Type(c"Method is not a valid UTF8".to_owned())),
            };
            // Step 25.4. Set request’s method to method.
            request.method = method;
        }

        // Step 26. If init["signal"] exists, then set signal to it.
        if let Some(init_signal) = init.signal.as_ref() {
            signal = init_signal.clone();
        }
        // Step 27. If init["priority"] exists, then:
        // TODO
        // Step 27.1. If request’s internal priority is not null,
        // then update request’s internal priority in an implementation-defined manner.
        // TODO
        // Step 27.2. Otherwise, set request’s priority to init["priority"].
        // TODO

        // Step 28. Set this’s request to request.
        let request = Request::from_net_request(cx, global, proto, request);

        // Step 29. Let signals be « signal » if signal is non-null; otherwise « ».
        let signals = signal.map_or(vec![], |s| vec![s]);
        // Step 30. Set this’s signal to the result of creating a dependent
        // abort signal from signals, using AbortSignal and this’s relevant realm.
        request
            .signal
            .set(Some(&AbortSignal::create_dependent_abort_signal(
                cx, signals, global,
            )));

        // Step 31. Set this’s headers to a new Headers object with this’s relevant realm,
        // whose header list is request’s header list and guard is "request".
        //
        // "or_init" looks unclear here, but it always enters the block since r
        // hasn't had any other way to initialize its headers
        request
            .headers
            .or_init(|| Headers::for_request(cx, &request.global()));

        // Step 33. If init is not empty, then:
        //
        // but spec says this should only be when non-empty init?

        // Step 33.3
        // We cannot empty `r.Headers().header_list` because
        // we would undo the Step 25 above.

        // Step 32. If this’s request’s mode is "no-cors", then:
        if request.request.borrow().mode == NetTraitsRequestMode::NoCors {
            let borrowed_request = request.request.borrow();
            // Step 32.1. If this’s request’s method is not a CORS-safelisted method, then throw a TypeError.
            if !is_cors_safelisted_method(&borrowed_request.method) {
                return Err(Error::Type(
                    c"The mode is 'no-cors' but the method is not a cors-safelisted method"
                        .to_owned(),
                ));
            }
            // Step 32.2. Set this’s headers’s guard to "request-no-cors".
            request.Headers(cx).set_guard(Guard::RequestNoCors);
        }

        match init.headers.as_ref() {
            None => {
                // Step 33.4. If headers is a Headers object, then for each header of its header list, append header to this’s headers.
                //
                // This is equivalent to the specification's concept of
                // "associated headers list". If an init headers is not given,
                // but an input with headers is given, set request's
                // headers as the input's Headers.
                if let RequestInfo::Request(ref input_request) = input {
                    request
                        .Headers(cx)
                        .copy_from_headers(&input_request.Headers(cx))?;
                }
            },
            // Step 33.5. Otherwise, fill this’s headers with headers.
            Some(headers) => request.Headers(cx).fill(Some(headers))?,
        }

        // Step 33.5 depending on how we got here
        // Copy the headers list onto the headers of net_traits::Request
        request.request.borrow_mut().headers = request.Headers(cx).get_headers_list();

        // Step 34. Let inputBody be input’s request’s body if input is a Request object; otherwise null.
        let input_body = if let RequestInfo::Request(ref mut input_request) = input {
            let mut input_request_request = input_request.request.borrow_mut();
            request.body_stream.set(input_request.body().as_deref());
            input_request_request.body.take()
        } else {
            None
        };

        // Step 35. If either init["body"] exists and is non-null or inputBody is non-null,
        // and request’s method is `GET` or `HEAD`, then throw a TypeError.
        if init.body.as_ref().is_some_and(|body| body.is_some()) || input_body.is_some() {
            let req = request.request.borrow();
            let req_method = &req.method;
            match *req_method {
                HttpMethod::GET => {
                    return Err(Error::Type(
                        c"Init's body is non-null, and request method is GET".to_owned(),
                    ));
                },
                HttpMethod::HEAD => {
                    return Err(Error::Type(
                        c"Init's body is non-null, and request method is HEAD".to_owned(),
                    ));
                },
                _ => {},
            }
        }

        // Step 36. Let initBody be null.
        let mut init_body = None;
        // Step 37. If init["body"] exists and is non-null, then:
        if let Some(Some(ref input_init_body)) = init.body {
            // Step 37.1. Let bodyWithType be the result of extracting init["body"], with keepalive set to request’s keepalive.
            let mut body_with_type =
                input_init_body.extract(cx, global, request.request.borrow().keep_alive)?;

            // Step 37.3. Let type be bodyWithType’s type.
            if let Some(contents) = body_with_type.content_type.take() {
                // Step 37.4. 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.
                let content_type_header_name = b"Content-Type";
                let headers = request.Headers(cx);
                if !headers
                    .Has(ByteString::new(content_type_header_name.to_vec()))
                    .unwrap()
                {
                    let content_type_header_value = contents.as_bytes(cx.no_gc());
                    headers.Append(
                        ByteString::new(content_type_header_name.to_vec()),
                        ByteString::new(content_type_header_value.to_vec()),
                    )?;

                    // In Servo request.Headers's header list isn't a pointer to the same
                    // actual list as request.request's, and so we need to append to both lists
                    // to keep them in sync.
                    if let Ok(header_value) = HeaderValue::from_bytes(&content_type_header_value) {
                        request
                            .request
                            .borrow_mut()
                            .headers
                            .insert(CONTENT_TYPE, header_value);
                    }
                }
            }

            // Step 37.2. Set initBody to bodyWithType’s body.
            let (net_body, stream) = body_with_type.into_net_request_body(cx);
            request.body_stream.set(Some(&*stream));
            init_body = Some(net_body);
        }

        // Step 38. Let inputOrInitBody be initBody if it is non-null; otherwise inputBody.
        // Step 40. Let finalBody be inputOrInitBody.
        // Step 41.2. Set finalBody to the result of creating a proxy for inputBody.
        //
        // There are multiple reassignments to similar values. In the end, all end up as
        // final_body. Therefore, final_body is equivalent to inputOrInitBody
        let init_body_is_non_null = init_body.is_some();
        let final_body = init_body.or(input_body);

        // Step 39. If inputOrInitBody is non-null and inputOrInitBody’s source is null, then:
        if final_body
            .as_ref()
            .is_some_and(|body| body.source_is_null())
        {
            // Step 39.1. “If initBody is non-null and init["duplex"] does not exist,
            // then throw a TypeError.”
            if init_body_is_non_null && init.duplex.is_none() {
                return Err(Error::Type(
                    c"Request with a ReadableStream body must specify duplex".to_owned(),
                ));
            }
            // Step 39.2. If this’s request’s mode is neither "same-origin" nor "cors", then throw a TypeError.
            let request_mode = &request.request.borrow().mode;
            if *request_mode != NetTraitsRequestMode::CorsMode &&
                *request_mode != NetTraitsRequestMode::SameOrigin
            {
                return Err(Error::Type(
                    c"Request mode must be Cors or SameOrigin".to_owned(),
                ));
            }
            // Step 39.3. Set this’s request’s use-CORS-preflight flag.
            // TODO
        }

        // Step 41. If initBody is null and inputBody is non-null, then:
        // Step 41.1. If inputBody is unusable, then throw a TypeError.
        //
        // We only perform this check on input_body. However, we already
        // processed the input body. Therefore, we check it all the way
        // above and throw the error at the last possible moment
        if input_body_is_unusable {
            return Err(Error::Type(c"Input body is unusable".to_owned()));
        }

        // Step 42. Set this’s request’s body to finalBody.
        request.request.borrow_mut().body = final_body;

        Ok(request)
    }

    /// <https://fetch.spec.whatwg.org/#concept-request-clone>
    fn clone_from(cx: &mut js::context::JSContext, r: &Request) -> Fallible<DomRoot<Request>> {
        let req = r.request.borrow();
        let url = req.url();
        let headers_guard = r.Headers(cx).get_guard();

        // Step 1. Let newRequest be a copy of request, except for its body.
        let mut new_req_inner = req.clone();
        let body = new_req_inner.body.take();

        let r_clone = Request::new(cx, &r.global(), None, url);
        *r_clone.request.borrow_mut() = new_req_inner;

        // Step 2. If request’s body is non-null, set newRequest’s body
        // to the result of cloning request’s body.
        if let Some(body) = body {
            r_clone.request.borrow_mut().body = Some(body);
        }

        r_clone.Headers(cx).copy_from_headers(&r.Headers(cx))?;
        r_clone.Headers(cx).set_guard(headers_guard);

        clone_body_stream_for_dom_body(cx, &r.body_stream, &r_clone.body_stream)?;

        // Step 3. Return newRequest.
        Ok(r_clone)
    }

    pub(crate) fn request(&self) -> Ref<'_, NetTraitsRequest> {
        self.request.borrow()
    }
}

fn net_request_from_global(global: &GlobalScope, url: ServoUrl) -> NetTraitsRequest {
    let url = ensure_blob_referenced_by_url_is_kept_alive(global, url);
    RequestBuilder::new(global.webview_id(), url, global.get_referrer())
        .with_global_scope(global)
        .build()
}

/// <https://fetch.spec.whatwg.org/#concept-method-normalize>
fn normalize_method(m: &str) -> Result<HttpMethod, InvalidMethod> {
    match_ignore_ascii_case! { m,
        "delete" => return Ok(HttpMethod::DELETE),
        "get" => return Ok(HttpMethod::GET),
        "head" => return Ok(HttpMethod::HEAD),
        "options" => return Ok(HttpMethod::OPTIONS),
        "post" => return Ok(HttpMethod::POST),
        "put" => return Ok(HttpMethod::PUT),
        _ => (),
    }
    debug!("Method: {:?}", m);
    HttpMethod::from_str(m)
}

/// <https://fetch.spec.whatwg.org/#concept-method>
fn is_method(m: &ByteString) -> bool {
    m.as_str().is_some()
}

/// <https://fetch.spec.whatwg.org/#cors-safelisted-method>
fn is_cors_safelisted_method(m: &HttpMethod) -> bool {
    m == HttpMethod::GET || m == HttpMethod::HEAD || m == HttpMethod::POST
}

/// <https://url.spec.whatwg.org/#include-credentials>
fn includes_credentials(input: &ServoUrl) -> bool {
    !input.username().is_empty() || input.password().is_some()
}

impl RequestMethods<crate::DomTypeHolder> for Request {
    /// <https://fetch.spec.whatwg.org/#dom-request>
    fn Constructor(
        cx: &mut js::context::JSContext,
        global: &GlobalScope,
        proto: Option<HandleObject>,
        input: RequestInfo,
        init: &RequestInit,
    ) -> Fallible<DomRoot<Request>> {
        Self::constructor(cx, global, proto, input, init)
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-method>
    fn Method(&self) -> ByteString {
        let r = self.request.borrow();
        ByteString::new(r.method.as_ref().as_bytes().into())
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-url>
    fn Url(&self) -> USVString {
        let r = self.request.borrow();
        USVString(r.url_list.first().map_or("", |u| u.as_str()).into())
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-headers>
    fn Headers(&self, cx: &mut js::context::JSContext) -> DomRoot<Headers> {
        self.headers.or_init(|| Headers::new(cx, &self.global()))
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-destination>
    fn Destination(&self) -> RequestDestination {
        self.request.borrow().destination.convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-referrer>
    fn Referrer(&self) -> USVString {
        let r = self.request.borrow();
        USVString(match r.referrer {
            Referrer::NoReferrer => String::new(),
            Referrer::Client(_) => String::from("about:client"),
            Referrer::ReferrerUrl(ref u) => {
                let u_c = u.clone();
                u_c.into_string()
            },
        })
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-referrerpolicy>
    fn ReferrerPolicy(&self) -> ReferrerPolicy {
        self.request.borrow().referrer_policy.convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-mode>
    fn Mode(&self) -> RequestMode {
        self.request.borrow().mode.clone().convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-credentials>
    fn Credentials(&self) -> RequestCredentials {
        self.request.borrow().credentials_mode.convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-cache>
    fn Cache(&self) -> RequestCache {
        self.request.borrow().cache_mode.convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-redirect>
    fn Redirect(&self) -> RequestRedirect {
        self.request.borrow().redirect_mode.convert()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-integrity>
    fn Integrity(&self) -> DOMString {
        self.request.borrow().integrity_metadata.clone().into()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-duplex>
    fn Duplex(&self) -> RequestDuplex {
        // “The duplex getter steps are to return "half".”
        RequestDuplex::Half
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-keepalive>
    fn Keepalive(&self) -> bool {
        self.request.borrow().keep_alive
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-isreloadnavigation>
    /// The isReloadNavigation getter steps are to return true if this’s request’s reload-navigation flag is set; otherwise false.
    fn IsReloadNavigation(&self) -> bool {
        self.request.borrow().reload_navigation
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-ishistorynavigation>
    // The isHistoryNavigation getter steps are to return true if this’s request’s history-navigation flag is set; otherwise false.
    fn IsHistoryNavigation(&self) -> bool {
        self.request.borrow().history_navigation
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-body>
    fn GetBody(&self) -> Option<DomRoot<ReadableStream>> {
        self.body()
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-bodyused>
    fn BodyUsed(&self) -> bool {
        self.is_body_used()
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-signal>
    fn Signal(&self) -> DomRoot<AbortSignal> {
        self.signal
            .get()
            .expect("Should always be initialized in constructor and clone")
    }

    /// <https://fetch.spec.whatwg.org/#dom-request-clone>
    fn Clone(&self, cx: &mut js::context::JSContext) -> Fallible<DomRoot<Request>> {
        // Step 1. If this is unusable, then throw a TypeError.
        if self.is_unusable() {
            return Err(Error::Type(c"Request is unusable".to_owned()));
        }

        // Step 2. Let clonedRequest be the result of cloning this’s request.
        let cloned_request = Request::clone_from(cx, self)?;
        // Step 3. Assert: this’s signal is non-null.
        let signal = self.signal.get().expect("Should always be initialized");
        // Step 4. Let clonedSignal be the result of creating a dependent
        // abort signal from « this’s signal », using AbortSignal and this’s relevant realm.
        let cloned_signal =
            AbortSignal::create_dependent_abort_signal(cx, vec![signal], &self.global());
        // Step 5. Let clonedRequestObject be the result of creating a Request object,
        // given clonedRequest, this’s headers’s guard, clonedSignal and this’s relevant realm.
        //
        // These steps already happen in `clone_from`
        cloned_request.signal.set(Some(&cloned_signal));
        // Step 6. Return clonedRequestObject.
        Ok(cloned_request)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-text>
    fn Text(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::Text)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-blob>
    fn Blob(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::Blob)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-formdata>
    fn FormData(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::FormData)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-json>
    fn Json(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::Json)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-arraybuffer>
    fn ArrayBuffer(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::ArrayBuffer)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-bytes>
    fn Bytes(&self, cx: &mut js::context::JSContext) -> RootedPromise {
        consume_body(cx, self, BodyType::Bytes)
    }

    /// <https://fetch.spec.whatwg.org/#dom-body-textstream>
    fn TextStream(&self, cx: &mut js::context::JSContext) -> Fallible<DomRoot<ReadableStream>> {
        body_text_stream(cx, self)
    }
}

impl BodyMixin for Request {
    fn is_body_used(&self) -> bool {
        let body_stream = self.body_stream.get();
        body_stream
            .as_ref()
            .is_some_and(|stream| stream.is_disturbed())
    }

    fn is_unusable(&self) -> bool {
        let body_stream = self.body_stream.get();
        body_stream
            .as_ref()
            .is_some_and(|stream| stream.is_disturbed() || stream.is_locked())
    }

    fn body(&self) -> Option<DomRoot<ReadableStream>> {
        self.body_stream.get()
    }

    fn get_mime_type(&self, cx: &mut js::context::JSContext) -> Vec<u8> {
        let headers = self.Headers(cx);
        headers.extract_mime_type()
    }
}

impl Convert<CacheMode> for RequestCache {
    fn convert(self) -> CacheMode {
        match self {
            RequestCache::Default => CacheMode::Default,
            RequestCache::No_store => CacheMode::NoStore,
            RequestCache::Reload => CacheMode::Reload,
            RequestCache::No_cache => CacheMode::NoCache,
            RequestCache::Force_cache => CacheMode::ForceCache,
            RequestCache::Only_if_cached => CacheMode::OnlyIfCached,
        }
    }
}

impl Convert<RequestCache> for CacheMode {
    fn convert(self) -> RequestCache {
        match self {
            CacheMode::Default => RequestCache::Default,
            CacheMode::NoStore => RequestCache::No_store,
            CacheMode::Reload => RequestCache::Reload,
            CacheMode::NoCache => RequestCache::No_cache,
            CacheMode::ForceCache => RequestCache::Force_cache,
            CacheMode::OnlyIfCached => RequestCache::Only_if_cached,
        }
    }
}

impl Convert<CredentialsMode> for RequestCredentials {
    fn convert(self) -> CredentialsMode {
        match self {
            RequestCredentials::Omit => CredentialsMode::Omit,
            RequestCredentials::Same_origin => CredentialsMode::CredentialsSameOrigin,
            RequestCredentials::Include => CredentialsMode::Include,
        }
    }
}

impl Convert<RequestCredentials> for CredentialsMode {
    fn convert(self) -> RequestCredentials {
        match self {
            CredentialsMode::Omit => RequestCredentials::Omit,
            CredentialsMode::CredentialsSameOrigin => RequestCredentials::Same_origin,
            CredentialsMode::Include => RequestCredentials::Include,
        }
    }
}

impl Convert<Destination> for RequestDestination {
    fn convert(self) -> Destination {
        match self {
            RequestDestination::_empty => Destination::None,
            RequestDestination::Audio => Destination::Audio,
            RequestDestination::Document => Destination::Document,
            RequestDestination::Embed => Destination::Embed,
            RequestDestination::Font => Destination::Font,
            RequestDestination::Frame => Destination::Frame,
            RequestDestination::Iframe => Destination::IFrame,
            RequestDestination::Image => Destination::Image,
            RequestDestination::Manifest => Destination::Manifest,
            RequestDestination::Json => Destination::Json,
            RequestDestination::Object => Destination::Object,
            RequestDestination::Report => Destination::Report,
            RequestDestination::Script => Destination::Script,
            RequestDestination::Sharedworker => Destination::SharedWorker,
            RequestDestination::Style => Destination::Style,
            RequestDestination::Text => Destination::Text,
            RequestDestination::Track => Destination::Track,
            RequestDestination::Video => Destination::Video,
            RequestDestination::Worker => Destination::Worker,
            RequestDestination::Xslt => Destination::Xslt,
        }
    }
}

impl Convert<RequestDestination> for Destination {
    fn convert(self) -> RequestDestination {
        match self {
            Destination::None => RequestDestination::_empty,
            Destination::Audio => RequestDestination::Audio,
            Destination::Document => RequestDestination::Document,
            Destination::Embed => RequestDestination::Embed,
            Destination::Font => RequestDestination::Font,
            Destination::Frame => RequestDestination::Frame,
            Destination::IFrame => RequestDestination::Iframe,
            Destination::Image => RequestDestination::Image,
            Destination::Manifest => RequestDestination::Manifest,
            Destination::Json => RequestDestination::Json,
            Destination::Object => RequestDestination::Object,
            Destination::Report => RequestDestination::Report,
            Destination::Script => RequestDestination::Script,
            Destination::ServiceWorker | Destination::AudioWorklet | Destination::PaintWorklet => {
                panic!("ServiceWorker request destination should not be exposed to DOM")
            },
            Destination::SharedWorker => RequestDestination::Sharedworker,
            Destination::Style => RequestDestination::Style,
            Destination::Text => RequestDestination::Text,
            Destination::Track => RequestDestination::Track,
            Destination::Video => RequestDestination::Video,
            Destination::Worker => RequestDestination::Worker,
            Destination::Xslt => RequestDestination::Xslt,
            Destination::WebIdentity => RequestDestination::_empty,
        }
    }
}

impl Convert<NetTraitsRequestMode> for RequestMode {
    fn convert(self) -> NetTraitsRequestMode {
        match self {
            RequestMode::Navigate => NetTraitsRequestMode::Navigate,
            RequestMode::Same_origin => NetTraitsRequestMode::SameOrigin,
            RequestMode::No_cors => NetTraitsRequestMode::NoCors,
            RequestMode::Cors => NetTraitsRequestMode::CorsMode,
        }
    }
}

impl Convert<RequestMode> for NetTraitsRequestMode {
    fn convert(self) -> RequestMode {
        match self {
            NetTraitsRequestMode::Navigate => RequestMode::Navigate,
            NetTraitsRequestMode::SameOrigin => RequestMode::Same_origin,
            NetTraitsRequestMode::NoCors => RequestMode::No_cors,
            NetTraitsRequestMode::CorsMode => RequestMode::Cors,
            NetTraitsRequestMode::WebSocket { .. } => {
                unreachable!("Websocket request mode should never be exposed to Dom")
            },
        }
    }
}

impl Convert<MsgReferrerPolicy> for ReferrerPolicy {
    fn convert(self) -> MsgReferrerPolicy {
        match self {
            ReferrerPolicy::_empty => MsgReferrerPolicy::EmptyString,
            ReferrerPolicy::No_referrer => MsgReferrerPolicy::NoReferrer,
            ReferrerPolicy::No_referrer_when_downgrade => {
                MsgReferrerPolicy::NoReferrerWhenDowngrade
            },
            ReferrerPolicy::Origin => MsgReferrerPolicy::Origin,
            ReferrerPolicy::Origin_when_cross_origin => MsgReferrerPolicy::OriginWhenCrossOrigin,
            ReferrerPolicy::Unsafe_url => MsgReferrerPolicy::UnsafeUrl,
            ReferrerPolicy::Same_origin => MsgReferrerPolicy::SameOrigin,
            ReferrerPolicy::Strict_origin => MsgReferrerPolicy::StrictOrigin,
            ReferrerPolicy::Strict_origin_when_cross_origin => {
                MsgReferrerPolicy::StrictOriginWhenCrossOrigin
            },
        }
    }
}

impl Convert<ReferrerPolicy> for MsgReferrerPolicy {
    fn convert(self) -> ReferrerPolicy {
        match self {
            MsgReferrerPolicy::EmptyString => ReferrerPolicy::_empty,
            MsgReferrerPolicy::NoReferrer => ReferrerPolicy::No_referrer,
            MsgReferrerPolicy::NoReferrerWhenDowngrade => {
                ReferrerPolicy::No_referrer_when_downgrade
            },
            MsgReferrerPolicy::Origin => ReferrerPolicy::Origin,
            MsgReferrerPolicy::OriginWhenCrossOrigin => ReferrerPolicy::Origin_when_cross_origin,
            MsgReferrerPolicy::UnsafeUrl => ReferrerPolicy::Unsafe_url,
            MsgReferrerPolicy::SameOrigin => ReferrerPolicy::Same_origin,
            MsgReferrerPolicy::StrictOrigin => ReferrerPolicy::Strict_origin,
            MsgReferrerPolicy::StrictOriginWhenCrossOrigin => {
                ReferrerPolicy::Strict_origin_when_cross_origin
            },
        }
    }
}

impl Convert<RedirectMode> for RequestRedirect {
    fn convert(self) -> RedirectMode {
        match self {
            RequestRedirect::Follow => RedirectMode::Follow,
            RequestRedirect::Error => RedirectMode::Error,
            RequestRedirect::Manual => RedirectMode::Manual,
        }
    }
}

impl Convert<RequestRedirect> for RedirectMode {
    fn convert(self) -> RequestRedirect {
        match self {
            RedirectMode::Follow => RequestRedirect::Follow,
            RedirectMode::Error => RequestRedirect::Error,
            RedirectMode::Manual => RequestRedirect::Manual,
        }
    }
}