/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ /* vim: set ts=8 sts=2 et sw=2 tw=80: */ /* 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 http://mozilla.org/MPL/2.0/. */ #include "Fetch.h" #include "js/RootingAPI.h" #include "js/Value.h" #include "mozilla/CycleCollectedJSContext.h" #include "mozilla/StaticPrefs_dom.h" #include "mozilla/dom/Document.h" #include "mozilla/ipc/BackgroundChild.h" #include "mozilla/ipc/PBackgroundChild.h" #include "mozilla/ipc/PBackgroundSharedTypes.h" #include "mozilla/ipc/IPCStreamUtils.h" #include "nsIGlobalObject.h" #include "nsDOMString.h" #include "nsJSUtils.h" #include "nsNetUtil.h" #include "nsReadableUtils.h" #include "nsStreamUtils.h" #include "nsStringStream.h" #include "nsProxyRelease.h" #include "mozilla/ErrorResult.h" #include "mozilla/dom/BindingDeclarations.h" #include "mozilla/dom/BodyConsumer.h" #include "mozilla/dom/Exceptions.h" #include "mozilla/dom/DOMException.h" #include "mozilla/dom/FetchDriver.h" #include "mozilla/dom/File.h" #include "mozilla/dom/FormData.h" #include "mozilla/dom/Headers.h" #include "mozilla/dom/Promise.h" #include "mozilla/dom/PromiseWorkerProxy.h" #include "mozilla/dom/ReadableStreamDefaultReader.h" #include "mozilla/dom/RemoteWorkerChild.h" #include "mozilla/dom/Request.h" #include "mozilla/dom/Response.h" #include "mozilla/dom/ScriptSettings.h" #include "mozilla/dom/URLSearchParams.h" #include "mozilla/net/CookieJarSettings.h" #include "BodyExtractor.h" #include "FetchChild.h" #include "FetchObserver.h" #include "InternalRequest.h" #include "InternalResponse.h" #include "mozilla/dom/WorkerCommon.h" #include "mozilla/dom/WorkerRef.h" #include "mozilla/dom/WorkerRunnable.h" #include "mozilla/dom/WorkerScope.h" namespace mozilla::dom { namespace { // Step 17.2.1.2 and 17.2.2 of // https://fetch.spec.whatwg.org/#concept-http-network-fetch // If stream is readable, then error stream with ... void AbortStream(JSContext* aCx, ReadableStream* aReadableStream, ErrorResult& aRv, JS::Handle aReasonDetails) { if (aReadableStream->State() != ReadableStream::ReaderState::Readable) { return; } JS::Rooted value(aCx, aReasonDetails); if (aReasonDetails.isUndefined()) { RefPtr e = DOMException::Create(NS_ERROR_DOM_ABORT_ERR); if (!GetOrCreateDOMReflector(aCx, e, &value)) { return; } } aReadableStream->ErrorNative(aCx, value, aRv); } } // namespace class AbortSignalMainThread final : public AbortSignalImpl { public: NS_DECL_CYCLE_COLLECTING_ISUPPORTS NS_DECL_CYCLE_COLLECTION_SCRIPT_HOLDER_CLASS(AbortSignalMainThread) explicit AbortSignalMainThread(bool aAborted) : AbortSignalImpl(aAborted, JS::UndefinedHandleValue) { mozilla::HoldJSObjects(this); } private: ~AbortSignalMainThread() { mozilla::DropJSObjects(this); }; }; NS_IMPL_CYCLE_COLLECTION_CLASS(AbortSignalMainThread) NS_IMPL_CYCLE_COLLECTION_UNLINK_BEGIN(AbortSignalMainThread) AbortSignalImpl::Unlink(static_cast(tmp)); NS_IMPL_CYCLE_COLLECTION_UNLINK_END NS_IMPL_CYCLE_COLLECTION_TRAVERSE_BEGIN(AbortSignalMainThread) AbortSignalImpl::Traverse(static_cast(tmp), cb); NS_IMPL_CYCLE_COLLECTION_TRAVERSE_END NS_IMPL_CYCLE_COLLECTION_TRACE_BEGIN(AbortSignalMainThread) NS_IMPL_CYCLE_COLLECTION_TRACE_JS_MEMBER_CALLBACK(mReason) NS_IMPL_CYCLE_COLLECTION_TRACE_END NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(AbortSignalMainThread) NS_INTERFACE_MAP_ENTRY(nsISupports) NS_INTERFACE_MAP_END NS_IMPL_CYCLE_COLLECTING_ADDREF(AbortSignalMainThread) NS_IMPL_CYCLE_COLLECTING_RELEASE(AbortSignalMainThread) class AbortSignalProxy; // This runnable propagates changes from the AbortSignalImpl on workers to the // AbortSignalImpl on main-thread. class AbortSignalProxyRunnable final : public Runnable { RefPtr mProxy; public: explicit AbortSignalProxyRunnable(AbortSignalProxy* aProxy) : Runnable("dom::AbortSignalProxyRunnable"), mProxy(aProxy) {} NS_IMETHOD Run() override; }; // This class orchestrates the proxying of AbortSignal operations between the // main thread and a worker thread. class AbortSignalProxy final : public AbortFollower { // This is created and released on the main-thread. RefPtr mSignalImplMainThread; // The main-thread event target for runnable dispatching. nsCOMPtr mMainThreadEventTarget; // This value is used only when creating mSignalImplMainThread on the main // thread, to create it in already-aborted state if necessary. It does *not* // reflect the instantaneous is-aborted status of the worker thread's // AbortSignal. const bool mAborted; public: NS_DECL_THREADSAFE_ISUPPORTS AbortSignalProxy(AbortSignalImpl* aSignalImpl, nsIEventTarget* aMainThreadEventTarget) : mMainThreadEventTarget(aMainThreadEventTarget), mAborted(aSignalImpl->Aborted()) { MOZ_ASSERT(!NS_IsMainThread()); MOZ_ASSERT(mMainThreadEventTarget); Follow(aSignalImpl); } // AbortFollower void RunAbortAlgorithm() override; AbortSignalImpl* GetOrCreateSignalImplForMainThread() { MOZ_ASSERT(NS_IsMainThread()); if (!mSignalImplMainThread) { mSignalImplMainThread = new AbortSignalMainThread(mAborted); } return mSignalImplMainThread; } AbortSignalImpl* GetSignalImplForTargetThread() { MOZ_ASSERT(!NS_IsMainThread()); return Signal(); } nsIEventTarget* MainThreadEventTarget() { return mMainThreadEventTarget; } void Shutdown() { MOZ_ASSERT(!NS_IsMainThread()); Unfollow(); } private: ~AbortSignalProxy() { NS_ProxyRelease("AbortSignalProxy::mSignalImplMainThread", mMainThreadEventTarget, mSignalImplMainThread.forget()); } }; NS_IMPL_ISUPPORTS0(AbortSignalProxy) NS_IMETHODIMP AbortSignalProxyRunnable::Run() { MOZ_ASSERT(NS_IsMainThread()); AbortSignalImpl* signalImpl = mProxy->GetOrCreateSignalImplForMainThread(); signalImpl->SignalAbort(JS::UndefinedHandleValue); return NS_OK; } void AbortSignalProxy::RunAbortAlgorithm() { MOZ_ASSERT(!NS_IsMainThread()); RefPtr runnable = new AbortSignalProxyRunnable(this); MainThreadEventTarget()->Dispatch(runnable.forget(), NS_DISPATCH_NORMAL); } class WorkerFetchResolver final : public FetchDriverObserver { // Thread-safe: RefPtr mPromiseProxy; RefPtr mSignalProxy; // Touched only on the worker thread. RefPtr mFetchObserver; RefPtr mWorkerRef; bool mIsShutdown; Atomic mNeedOnDataAvailable; public: // Returns null if worker is shutting down. static already_AddRefed Create( WorkerPrivate* aWorkerPrivate, Promise* aPromise, AbortSignalImpl* aSignalImpl, FetchObserver* aObserver) { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); RefPtr proxy = PromiseWorkerProxy::Create(aWorkerPrivate, aPromise); if (!proxy) { return nullptr; } RefPtr signalProxy; if (aSignalImpl) { signalProxy = new AbortSignalProxy( aSignalImpl, aWorkerPrivate->MainThreadEventTarget()); } RefPtr r = new WorkerFetchResolver(proxy, signalProxy, aObserver); RefPtr workerRef = WeakWorkerRef::Create( aWorkerPrivate, [r]() { r->Shutdown(r->mWorkerRef->GetPrivate()); }); if (NS_WARN_IF(!workerRef)) { return nullptr; } r->mWorkerRef = std::move(workerRef); return r.forget(); } AbortSignalImpl* GetAbortSignalForMainThread() { MOZ_ASSERT(NS_IsMainThread()); if (!mSignalProxy) { return nullptr; } return mSignalProxy->GetOrCreateSignalImplForMainThread(); } AbortSignalImpl* GetAbortSignalForTargetThread() { mPromiseProxy->GetWorkerPrivate()->AssertIsOnWorkerThread(); if (!mSignalProxy) { return nullptr; } return mSignalProxy->GetSignalImplForTargetThread(); } PromiseWorkerProxy* PromiseProxy() const { MOZ_ASSERT(NS_IsMainThread()); return mPromiseProxy; } Promise* WorkerPromise(WorkerPrivate* aWorkerPrivate) const { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); MOZ_ASSERT(!mIsShutdown); return mPromiseProxy->GetWorkerPromise(); } FetchObserver* GetFetchObserver(WorkerPrivate* aWorkerPrivate) const { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); return mFetchObserver; } void OnResponseAvailableInternal( SafeRefPtr aResponse) override; void OnResponseEnd(FetchDriverObserver::EndReason aReason, JS::Handle aReasonDetails) override; bool NeedOnDataAvailable() override; void OnDataAvailable() override; void Shutdown(WorkerPrivate* aWorkerPrivate) { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); mIsShutdown = true; mPromiseProxy->CleanUp(); mNeedOnDataAvailable = false; mFetchObserver = nullptr; if (mSignalProxy) { mSignalProxy->Shutdown(); } mWorkerRef = nullptr; } bool IsShutdown(WorkerPrivate* aWorkerPrivate) const { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); return mIsShutdown; } private: WorkerFetchResolver(PromiseWorkerProxy* aProxy, AbortSignalProxy* aSignalProxy, FetchObserver* aObserver) : mPromiseProxy(aProxy), mSignalProxy(aSignalProxy), mFetchObserver(aObserver), mIsShutdown(false), mNeedOnDataAvailable(!!aObserver) { MOZ_ASSERT(!NS_IsMainThread()); MOZ_ASSERT(mPromiseProxy); } ~WorkerFetchResolver() = default; virtual void FlushConsoleReport() override; }; void FetchDriverObserver::OnResponseAvailable( SafeRefPtr aResponse) { MOZ_ASSERT(!mGotResponseAvailable); mGotResponseAvailable = true; OnResponseAvailableInternal(std::move(aResponse)); } class MainThreadFetchResolver final : public FetchDriverObserver { RefPtr mPromise; RefPtr mResponse; RefPtr mFetchObserver; RefPtr mSignalImpl; const bool mMozErrors; nsCOMPtr mLoadGroup; NS_DECL_OWNINGTHREAD public: MainThreadFetchResolver(Promise* aPromise, FetchObserver* aObserver, AbortSignalImpl* aSignalImpl, bool aMozErrors) : mPromise(aPromise), mFetchObserver(aObserver), mSignalImpl(aSignalImpl), mMozErrors(aMozErrors) {} void OnResponseAvailableInternal( SafeRefPtr aResponse) override; void SetLoadGroup(nsILoadGroup* aLoadGroup) { mLoadGroup = aLoadGroup; } void OnResponseEnd(FetchDriverObserver::EndReason aReason, JS::Handle aReasonDetails) override { if (aReason == eAborted) { if (!aReasonDetails.isUndefined()) { mPromise->MaybeReject(aReasonDetails); } else { mPromise->MaybeReject(NS_ERROR_DOM_ABORT_ERR); } } mFetchObserver = nullptr; FlushConsoleReport(); } bool NeedOnDataAvailable() override; void OnDataAvailable() override; private: ~MainThreadFetchResolver(); void FlushConsoleReport() override { mReporter->FlushConsoleReports(mLoadGroup); } }; class MainThreadFetchRunnable : public Runnable { RefPtr mResolver; const ClientInfo mClientInfo; const Maybe mController; nsCOMPtr mCSPEventListener; SafeRefPtr mRequest; UniquePtr mOriginStack; public: MainThreadFetchRunnable(WorkerFetchResolver* aResolver, const ClientInfo& aClientInfo, const Maybe& aController, nsICSPEventListener* aCSPEventListener, SafeRefPtr aRequest, UniquePtr&& aOriginStack) : Runnable("dom::MainThreadFetchRunnable"), mResolver(aResolver), mClientInfo(aClientInfo), mController(aController), mCSPEventListener(aCSPEventListener), mRequest(std::move(aRequest)), mOriginStack(std::move(aOriginStack)) { MOZ_ASSERT(mResolver); } NS_IMETHOD Run() override { AssertIsOnMainThread(); RefPtr fetch; RefPtr proxy = mResolver->PromiseProxy(); { // Acquire the proxy mutex while getting data from the WorkerPrivate... MutexAutoLock lock(proxy->Lock()); if (proxy->CleanedUp()) { NS_WARNING("Aborting Fetch because worker already shut down"); return NS_OK; } WorkerPrivate* workerPrivate = proxy->GetWorkerPrivate(); MOZ_ASSERT(workerPrivate); nsCOMPtr principal = workerPrivate->GetPrincipal(); MOZ_ASSERT(principal); nsCOMPtr loadGroup = workerPrivate->GetLoadGroup(); MOZ_ASSERT(loadGroup); // We don't track if a worker is spawned from a tracking script for now, // so pass false as the last argument to FetchDriver(). fetch = new FetchDriver(mRequest.clonePtr(), principal, loadGroup, workerPrivate->MainThreadEventTarget(), workerPrivate->CookieJarSettings(), workerPrivate->GetPerformanceStorage(), false); nsAutoCString spec; if (proxy->GetWorkerPrivate()->GetBaseURI()) { proxy->GetWorkerPrivate()->GetBaseURI()->GetAsciiSpec(spec); } fetch->SetWorkerScript(spec); fetch->SetClientInfo(mClientInfo); fetch->SetController(mController); fetch->SetCSPEventListener(mCSPEventListener); } fetch->SetOriginStack(std::move(mOriginStack)); RefPtr signalImpl = mResolver->GetAbortSignalForMainThread(); // ...but release it before calling Fetch, because mResolver's callback can // be called synchronously and they want the mutex, too. return fetch->Fetch(signalImpl, mResolver); } }; already_AddRefed FetchRequest(nsIGlobalObject* aGlobal, const RequestOrUTF8String& aInput, const RequestInit& aInit, CallerType aCallerType, ErrorResult& aRv) { RefPtr p = Promise::Create(aGlobal, aRv); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } MOZ_ASSERT(aGlobal); // Double check that we have chrome privileges if the Request's content // policy type has been overridden. MOZ_ASSERT_IF(aInput.IsRequest() && aInput.GetAsRequest().IsContentPolicyTypeOverridden(), aCallerType == CallerType::System); AutoJSAPI jsapi; if (!jsapi.Init(aGlobal)) { aRv.Throw(NS_ERROR_NOT_AVAILABLE); return nullptr; } JSContext* cx = jsapi.cx(); JS::Rooted jsGlobal(cx, aGlobal->GetGlobalJSObject()); GlobalObject global(cx, jsGlobal); SafeRefPtr request = Request::Constructor(global, aInput, aInit, aRv); if (aRv.Failed()) { return nullptr; } SafeRefPtr r = request->GetInternalRequest(); // Restore information of InterceptedHttpChannel if they are passed with the // Request. Since Request::Constructor would not copy these members. if (aInput.IsRequest()) { RefPtr inputReq = &aInput.GetAsRequest(); SafeRefPtr inputInReq = inputReq->GetInternalRequest(); if (inputInReq->GetInterceptionTriggeringPrincipalInfo()) { r->SetInterceptionContentPolicyType( inputInReq->InterceptionContentPolicyType()); r->SetInterceptionTriggeringPrincipalInfo( MakeUnique( *(inputInReq->GetInterceptionTriggeringPrincipalInfo().get()))); if (!inputInReq->InterceptionRedirectChain().IsEmpty()) { r->SetInterceptionRedirectChain( inputInReq->InterceptionRedirectChain()); } r->SetInterceptionFromThirdParty( inputInReq->InterceptionFromThirdParty()); } } RefPtr signalImpl = request->GetSignalImpl(); if (signalImpl && signalImpl->Aborted()) { // Already aborted signal rejects immediately. JS::Rooted reason(cx, signalImpl->RawReason()); if (reason.get().isUndefined()) { aRv.Throw(NS_ERROR_DOM_ABORT_ERR); return nullptr; } p->MaybeReject(reason); return p.forget(); } JS::Realm* realm = JS::GetCurrentRealmOrNull(cx); if (realm && JS::GetDebuggerObservesWasm(realm)) { r->SetSkipWasmCaching(); } RefPtr observer; if (aInit.mObserve.WasPassed()) { observer = new FetchObserver(aGlobal, signalImpl); aInit.mObserve.Value().HandleEvent(*observer); } if (NS_IsMainThread()) { nsCOMPtr window = do_QueryInterface(aGlobal); nsCOMPtr doc; nsCOMPtr loadGroup; nsCOMPtr cookieJarSettings; nsIPrincipal* principal; bool isTrackingFetch = false; if (window) { doc = window->GetExtantDoc(); if (!doc) { aRv.Throw(NS_ERROR_FAILURE); return nullptr; } principal = doc->NodePrincipal(); loadGroup = doc->GetDocumentLoadGroup(); cookieJarSettings = doc->CookieJarSettings(); isTrackingFetch = doc->IsScriptTracking(cx); } else { principal = aGlobal->PrincipalOrNull(); if (NS_WARN_IF(!principal)) { aRv.Throw(NS_ERROR_FAILURE); return nullptr; } cookieJarSettings = mozilla::net::CookieJarSettings::Create(principal); } if (!loadGroup) { nsresult rv = NS_NewLoadGroup(getter_AddRefs(loadGroup), principal); if (NS_WARN_IF(NS_FAILED(rv))) { aRv.Throw(rv); return nullptr; } } RefPtr resolver = new MainThreadFetchResolver( p, observer, signalImpl, request->MozErrors()); RefPtr fetch = new FetchDriver( std::move(r), principal, loadGroup, aGlobal->SerialEventTarget(), cookieJarSettings, nullptr, // PerformanceStorage isTrackingFetch); fetch->SetDocument(doc); resolver->SetLoadGroup(loadGroup); aRv = fetch->Fetch(signalImpl, resolver); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } } else { WorkerPrivate* worker = GetCurrentThreadWorkerPrivate(); MOZ_ASSERT(worker); if (worker->IsServiceWorker()) { r->SetSkipServiceWorker(); } // PFetch gives no benefit for the fetch in the parent process. // Dispatch fetch to the parent process main thread directly for that case. // For child process, dispatch fetch op to the parent. if (StaticPrefs::dom_workers_pFetch_enabled() && !XRE_IsParentProcess()) { RefPtr actor = FetchChild::Create(worker, p, signalImpl, observer); if (!actor) { NS_WARNING("Could not keep the worker alive."); aRv.Throw(NS_ERROR_DOM_ABORT_ERR); return nullptr; } Maybe clientInfo(worker->GlobalScope()->GetClientInfo()); if (clientInfo.isNothing()) { aRv.Throw(NS_ERROR_DOM_INVALID_STATE_ERR); return nullptr; } auto* backgroundChild = mozilla::ipc::BackgroundChild::GetOrCreateForCurrentThread(); Unused << NS_WARN_IF(!backgroundChild->SendPFetchConstructor(actor)); FetchOpArgs ipcArgs; ipcArgs.request() = IPCInternalRequest(); r->ToIPCInternalRequest(&(ipcArgs.request()), backgroundChild); ipcArgs.principalInfo() = worker->GetPrincipalInfo(); ipcArgs.clientInfo() = clientInfo.ref().ToIPC(); if (worker->GetBaseURI()) { worker->GetBaseURI()->GetAsciiSpec(ipcArgs.workerScript()); } if (worker->GlobalScope()->GetController().isSome()) { ipcArgs.controller() = Some(worker->GlobalScope()->GetController().ref().ToIPC()); } if (worker->CookieJarSettings()) { ipcArgs.cookieJarSettings() = Some(worker->CookieJarSettingsArgs()); } if (worker->CSPEventListener()) { ipcArgs.hasCSPEventListener() = true; actor->SetCSPEventListener(worker->CSPEventListener()); } else { ipcArgs.hasCSPEventListener() = false; } ipcArgs.associatedBrowsingContextID() = worker->AssociatedBrowsingContextID(); if (worker->IsWatchedByDevTools()) { UniquePtr stack; stack = GetCurrentStackForNetMonitor(cx); actor->SetOriginStack(std::move(stack)); } ipcArgs.isThirdPartyContext() = worker->IsThirdPartyContext(); actor->DoFetchOp(ipcArgs); return p.forget(); } RefPtr resolver = WorkerFetchResolver::Create(worker, p, signalImpl, observer); if (!resolver) { NS_WARNING("Could not keep the worker alive."); aRv.Throw(NS_ERROR_DOM_ABORT_ERR); return nullptr; } Maybe clientInfo(worker->GlobalScope()->GetClientInfo()); if (clientInfo.isNothing()) { aRv.Throw(NS_ERROR_DOM_INVALID_STATE_ERR); return nullptr; } UniquePtr stack; if (worker->IsWatchedByDevTools()) { stack = GetCurrentStackForNetMonitor(cx); } RefPtr run = new MainThreadFetchRunnable( resolver, clientInfo.ref(), worker->GlobalScope()->GetController(), worker->CSPEventListener(), std::move(r), std::move(stack)); worker->DispatchToMainThread(run.forget()); } return p.forget(); } class ResolveFetchPromise : public Runnable { public: ResolveFetchPromise(Promise* aPromise, Response* aResponse) : Runnable("ResolveFetchPromise"), mPromise(aPromise), mResponse(aResponse) {} NS_IMETHOD Run() override { mPromise->MaybeResolve(mResponse); return NS_OK; } RefPtr mPromise; RefPtr mResponse; }; void MainThreadFetchResolver::OnResponseAvailableInternal( SafeRefPtr aResponse) { NS_ASSERT_OWNINGTHREAD(MainThreadFetchResolver); AssertIsOnMainThread(); if (aResponse->Type() != ResponseType::Error) { nsCOMPtr go = mPromise->GetParentObject(); nsCOMPtr inner = do_QueryInterface(go); // Notify the document when a fetch completes successfully. This is // used by the password manager as a hint to observe DOM mutations. // Call this prior to setting state to Complete so we can set up the // observer before mutations occurs. Document* doc = inner ? inner->GetExtantDoc() : nullptr; if (doc) { doc->NotifyFetchOrXHRSuccess(); } if (mFetchObserver) { mFetchObserver->SetState(FetchState::Complete); } mResponse = new Response(go, std::move(aResponse), mSignalImpl); // response headers received from the network should be immutable // all response header settings must be done before this point // see Bug 1574174 ErrorResult result; mResponse->Headers_()->SetGuard(HeadersGuardEnum::Immutable, result); MOZ_ASSERT(!result.Failed()); BrowsingContext* bc = inner ? inner->GetBrowsingContext() : nullptr; bc = bc ? bc->Top() : nullptr; if (bc && bc->IsLoading()) { bc->AddDeprioritizedLoadRunner( new ResolveFetchPromise(mPromise, mResponse)); } else { mPromise->MaybeResolve(mResponse); } } else { if (mFetchObserver) { mFetchObserver->SetState(FetchState::Errored); } if (mMozErrors) { mPromise->MaybeReject(aResponse->GetErrorCode()); return; } mPromise->MaybeRejectWithTypeError(); } } bool MainThreadFetchResolver::NeedOnDataAvailable() { NS_ASSERT_OWNINGTHREAD(MainThreadFetchResolver); return !!mFetchObserver; } void MainThreadFetchResolver::OnDataAvailable() { NS_ASSERT_OWNINGTHREAD(MainThreadFetchResolver); AssertIsOnMainThread(); if (!mFetchObserver) { return; } if (mFetchObserver->State() == FetchState::Requesting) { mFetchObserver->SetState(FetchState::Responding); } } MainThreadFetchResolver::~MainThreadFetchResolver() { NS_ASSERT_OWNINGTHREAD(MainThreadFetchResolver); } class WorkerFetchResponseRunnable final : public MainThreadWorkerRunnable { RefPtr mResolver; // Passed from main thread to worker thread after being initialized. SafeRefPtr mInternalResponse; public: WorkerFetchResponseRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver, SafeRefPtr aResponse) : MainThreadWorkerRunnable("WorkerFetchResponseRunnable"), mResolver(aResolver), mInternalResponse(std::move(aResponse)) { MOZ_ASSERT(mResolver); } bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); if (mResolver->IsShutdown(aWorkerPrivate)) { return true; } RefPtr promise = mResolver->WorkerPromise(aWorkerPrivate); // Once Worker had already started shutdown, workerPromise would be nullptr if (!promise) { return true; } RefPtr fetchObserver = mResolver->GetFetchObserver(aWorkerPrivate); if (mInternalResponse->Type() != ResponseType::Error) { if (fetchObserver) { fetchObserver->SetState(FetchState::Complete); } RefPtr global = aWorkerPrivate->GlobalScope(); RefPtr response = new Response(global, mInternalResponse.clonePtr(), mResolver->GetAbortSignalForTargetThread()); // response headers received from the network should be immutable, // all response header settings must be done before this point // see Bug 1574174 ErrorResult result; response->Headers_()->SetGuard(HeadersGuardEnum::Immutable, result); MOZ_ASSERT(!result.Failed()); promise->MaybeResolve(response); } else { if (fetchObserver) { fetchObserver->SetState(FetchState::Errored); } promise->MaybeRejectWithTypeError(); } return true; } }; class WorkerDataAvailableRunnable final : public MainThreadWorkerRunnable { RefPtr mResolver; public: WorkerDataAvailableRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver) : MainThreadWorkerRunnable("WorkerDataAvailableRunnable"), mResolver(aResolver) {} bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { MOZ_ASSERT(aWorkerPrivate); aWorkerPrivate->AssertIsOnWorkerThread(); RefPtr fetchObserver = mResolver->GetFetchObserver(aWorkerPrivate); if (fetchObserver && fetchObserver->State() == FetchState::Requesting) { fetchObserver->SetState(FetchState::Responding); } return true; } }; class WorkerFetchResponseEndBase { protected: RefPtr mResolver; public: explicit WorkerFetchResponseEndBase(WorkerFetchResolver* aResolver) : mResolver(aResolver) { MOZ_ASSERT(aResolver); } void WorkerRunInternal(WorkerPrivate* aWorkerPrivate) { mResolver->Shutdown(aWorkerPrivate); } }; class WorkerFetchResponseEndRunnable final : public MainThreadWorkerRunnable, public WorkerFetchResponseEndBase { FetchDriverObserver::EndReason mReason; public: WorkerFetchResponseEndRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver, FetchDriverObserver::EndReason aReason) : MainThreadWorkerRunnable("WorkerFetchResponseEndRunnable"), WorkerFetchResponseEndBase(aResolver), mReason(aReason) {} bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { if (mResolver->IsShutdown(aWorkerPrivate)) { return true; } if (mReason == FetchDriverObserver::eAborted) { mResolver->WorkerPromise(aWorkerPrivate) ->MaybeReject(NS_ERROR_DOM_ABORT_ERR); } WorkerRunInternal(aWorkerPrivate); return true; } nsresult Cancel() override { return Run(); } }; class WorkerFetchResponseEndControlRunnable final : public MainThreadWorkerControlRunnable, public WorkerFetchResponseEndBase { public: WorkerFetchResponseEndControlRunnable(WorkerPrivate* aWorkerPrivate, WorkerFetchResolver* aResolver) : MainThreadWorkerControlRunnable( "WorkerFetchResponseEndControlRunnable"), WorkerFetchResponseEndBase(aResolver) {} bool WorkerRun(JSContext* aCx, WorkerPrivate* aWorkerPrivate) override { WorkerRunInternal(aWorkerPrivate); return true; } // Control runnable cancel already calls Run(). }; void WorkerFetchResolver::OnResponseAvailableInternal( SafeRefPtr aResponse) { AssertIsOnMainThread(); MutexAutoLock lock(mPromiseProxy->Lock()); if (mPromiseProxy->CleanedUp()) { return; } RefPtr r = new WorkerFetchResponseRunnable( mPromiseProxy->GetWorkerPrivate(), this, std::move(aResponse)); if (!r->Dispatch(mPromiseProxy->GetWorkerPrivate())) { NS_WARNING("Could not dispatch fetch response"); } } bool WorkerFetchResolver::NeedOnDataAvailable() { AssertIsOnMainThread(); return mNeedOnDataAvailable; } void WorkerFetchResolver::OnDataAvailable() { AssertIsOnMainThread(); MutexAutoLock lock(mPromiseProxy->Lock()); if (mPromiseProxy->CleanedUp()) { return; } RefPtr r = new WorkerDataAvailableRunnable(mPromiseProxy->GetWorkerPrivate(), this); Unused << r->Dispatch(mPromiseProxy->GetWorkerPrivate()); } void WorkerFetchResolver::OnResponseEnd(FetchDriverObserver::EndReason aReason, JS::Handle aReasonDetails) { AssertIsOnMainThread(); MutexAutoLock lock(mPromiseProxy->Lock()); if (mPromiseProxy->CleanedUp()) { return; } FlushConsoleReport(); Unused << aReasonDetails; RefPtr r = new WorkerFetchResponseEndRunnable( mPromiseProxy->GetWorkerPrivate(), this, aReason); if (!r->Dispatch(mPromiseProxy->GetWorkerPrivate())) { RefPtr cr = new WorkerFetchResponseEndControlRunnable( mPromiseProxy->GetWorkerPrivate(), this); // This can fail if the worker thread is canceled or killed causing // the PromiseWorkerProxy to give up its WorkerRef immediately, // allowing the worker thread to become Dead. if (!cr->Dispatch(mPromiseProxy->GetWorkerPrivate())) { NS_WARNING("Failed to dispatch WorkerFetchResponseEndControlRunnable"); } } } void WorkerFetchResolver::FlushConsoleReport() { AssertIsOnMainThread(); MOZ_ASSERT(mPromiseProxy); if (!mReporter) { return; } WorkerPrivate* worker = mPromiseProxy->GetWorkerPrivate(); if (!worker) { mReporter->FlushReportsToConsole(0); return; } if (worker->IsServiceWorker()) { // Flush to service worker mReporter->FlushReportsToConsoleForServiceWorkerScope( worker->ServiceWorkerScope()); return; } if (worker->IsSharedWorker()) { // Flush to shared worker worker->GetRemoteWorkerController()->FlushReportsOnMainThread(mReporter); return; } // Flush to dedicated worker mReporter->FlushConsoleReports(worker->GetLoadGroup()); } nsresult ExtractByteStreamFromBody(const fetch::OwningBodyInit& aBodyInit, nsIInputStream** aStream, nsCString& aContentTypeWithCharset, uint64_t& aContentLength) { MOZ_ASSERT(aStream); nsAutoCString charset; aContentTypeWithCharset.SetIsVoid(true); if (aBodyInit.IsArrayBuffer()) { BodyExtractor body(&aBodyInit.GetAsArrayBuffer()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsArrayBufferView()) { BodyExtractor body( &aBodyInit.GetAsArrayBufferView()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsBlob()) { Blob& blob = aBodyInit.GetAsBlob(); BodyExtractor body(&blob); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsFormData()) { FormData& formData = aBodyInit.GetAsFormData(); BodyExtractor body(&formData); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsUSVString()) { BodyExtractor body(&aBodyInit.GetAsUSVString()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsURLSearchParams()) { URLSearchParams& usp = aBodyInit.GetAsURLSearchParams(); BodyExtractor body(&usp); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } MOZ_ASSERT_UNREACHABLE("Should never reach here"); return NS_ERROR_FAILURE; } nsresult ExtractByteStreamFromBody(const fetch::BodyInit& aBodyInit, nsIInputStream** aStream, nsCString& aContentTypeWithCharset, uint64_t& aContentLength) { MOZ_ASSERT(aStream); MOZ_ASSERT(!*aStream); nsAutoCString charset; aContentTypeWithCharset.SetIsVoid(true); if (aBodyInit.IsArrayBuffer()) { BodyExtractor body(&aBodyInit.GetAsArrayBuffer()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsArrayBufferView()) { BodyExtractor body( &aBodyInit.GetAsArrayBufferView()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsBlob()) { BodyExtractor body(&aBodyInit.GetAsBlob()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsFormData()) { BodyExtractor body(&aBodyInit.GetAsFormData()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsUSVString()) { BodyExtractor body(&aBodyInit.GetAsUSVString()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsURLSearchParams()) { BodyExtractor body( &aBodyInit.GetAsURLSearchParams()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } MOZ_ASSERT_UNREACHABLE("Should never reach here"); return NS_ERROR_FAILURE; } nsresult ExtractByteStreamFromBody(const fetch::ResponseBodyInit& aBodyInit, nsIInputStream** aStream, nsCString& aContentTypeWithCharset, uint64_t& aContentLength) { MOZ_ASSERT(aStream); MOZ_ASSERT(!*aStream); // ReadableStreams should be handled by // BodyExtractorReadableStream::GetAsStream. MOZ_ASSERT(!aBodyInit.IsReadableStream()); nsAutoCString charset; aContentTypeWithCharset.SetIsVoid(true); if (aBodyInit.IsArrayBuffer()) { BodyExtractor body(&aBodyInit.GetAsArrayBuffer()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsArrayBufferView()) { BodyExtractor body( &aBodyInit.GetAsArrayBufferView()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsBlob()) { BodyExtractor body(&aBodyInit.GetAsBlob()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsFormData()) { BodyExtractor body(&aBodyInit.GetAsFormData()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsUSVString()) { BodyExtractor body(&aBodyInit.GetAsUSVString()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } if (aBodyInit.IsURLSearchParams()) { BodyExtractor body( &aBodyInit.GetAsURLSearchParams()); return body.GetAsStream(aStream, &aContentLength, aContentTypeWithCharset, charset); } MOZ_ASSERT_UNREACHABLE("Should never reach here"); return NS_ERROR_FAILURE; } NS_IMPL_CYCLE_COLLECTION(FetchBodyBase, mReadableStreamBody) NS_IMPL_CYCLE_COLLECTING_ADDREF(FetchBodyBase) NS_IMPL_CYCLE_COLLECTING_RELEASE(FetchBodyBase) NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(FetchBodyBase) NS_INTERFACE_MAP_ENTRY(nsISupports) NS_INTERFACE_MAP_END template FetchBody::FetchBody(nsIGlobalObject* aOwner) : mOwner(aOwner), mBodyUsed(false) { MOZ_ASSERT(aOwner); if (!NS_IsMainThread()) { WorkerPrivate* wp = GetCurrentThreadWorkerPrivate(); MOZ_ASSERT(wp); mMainThreadEventTarget = wp->MainThreadEventTarget(); } else { mMainThreadEventTarget = GetMainThreadSerialEventTarget(); } MOZ_ASSERT(mMainThreadEventTarget); } template FetchBody::FetchBody(nsIGlobalObject* aOwner); template FetchBody::FetchBody(nsIGlobalObject* aOwner); template FetchBody::~FetchBody() { Unfollow(); } template FetchBody::~FetchBody(); template FetchBody::~FetchBody(); template bool FetchBody::BodyUsed() const { if (mBodyUsed) { return true; } // If this stream is disturbed, return true. if (mReadableStreamBody) { return mReadableStreamBody->Disturbed(); } return false; } template bool FetchBody::BodyUsed() const; template bool FetchBody::BodyUsed() const; template void FetchBody::SetBodyUsed(JSContext* aCx, ErrorResult& aRv) { MOZ_ASSERT(aCx); MOZ_ASSERT(mOwner->SerialEventTarget()->IsOnCurrentThread()); MOZ_DIAGNOSTIC_ASSERT(!BodyUsed(), "Consuming already used body?"); if (BodyUsed()) { return; } mBodyUsed = true; // If we already have a ReadableStreamBody and it has been created by DOM, we // have to lock it now because it can have been shared with other objects. if (mReadableStreamBody) { if (mFetchStreamReader) { // Having FetchStreamReader means there's no nsIInputStream underlying it MOZ_ASSERT(!mReadableStreamBody->MaybeGetInputStreamIfUnread()); mFetchStreamReader->StartConsuming(aCx, mReadableStreamBody, aRv); return; } // We should have nsIInputStream at this point as long as it's still // readable MOZ_ASSERT_IF( mReadableStreamBody->State() == ReadableStream::ReaderState::Readable, mReadableStreamBody->MaybeGetInputStreamIfUnread()); LockStream(aCx, mReadableStreamBody, aRv); } } template void FetchBody::SetBodyUsed(JSContext* aCx, ErrorResult& aRv); template void FetchBody::SetBodyUsed(JSContext* aCx, ErrorResult& aRv); template already_AddRefed FetchBody::ConsumeBody( JSContext* aCx, BodyConsumer::ConsumeType aType, ErrorResult& aRv) { aRv.MightThrowJSException(); RefPtr signalImpl = DerivedClass()->GetSignalImplToConsumeBody(); if (signalImpl && signalImpl->Aborted()) { JS::Rooted abortReason(aCx, signalImpl->RawReason()); if (abortReason.get().isUndefined()) { aRv.Throw(NS_ERROR_DOM_ABORT_ERR); return nullptr; } nsCOMPtr go = DerivedClass()->GetParentObject(); RefPtr promise = Promise::Create(go, aRv); promise->MaybeReject(abortReason); return promise.forget(); } if (BodyUsed()) { aRv.ThrowTypeError(); return nullptr; } nsAutoCString mimeType; nsAutoCString mixedCaseMimeType; DerivedClass()->GetMimeType(mimeType, mixedCaseMimeType); // Null bodies are a special-case in the fetch spec. The Body mix-in can only // be "disturbed" or "locked" if its associated "body" is non-null. // Additionally, the Body min-in's "consume body" algorithm explicitly creates // a fresh empty ReadableStream object in step 2. This means that `bodyUsed` // will never return true for a null body. // // To this end, we create a fresh (empty) body every time a request is made // and consume its body here, without marking this FetchBody consumed via // SetBodyUsed. nsCOMPtr bodyStream; DerivedClass()->GetBody(getter_AddRefs(bodyStream)); if (!bodyStream) { RefPtr emptyBody = EmptyBody::Create(DerivedClass()->GetParentObject(), DerivedClass()->GetPrincipalInfo().get(), signalImpl, mimeType, mixedCaseMimeType, aRv); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } return emptyBody->ConsumeBody(aCx, aType, aRv); } SetBodyUsed(aCx, aRv); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } nsCOMPtr global = DerivedClass()->GetParentObject(); MutableBlobStorage::MutableBlobStorageType blobStorageType = MutableBlobStorage::eOnlyInMemory; const mozilla::UniquePtr& principalInfo = DerivedClass()->GetPrincipalInfo(); // We support temporary file for blobs only if the principal is known and // it's system or content not in private Browsing. if (principalInfo && (principalInfo->type() == mozilla::ipc::PrincipalInfo::TSystemPrincipalInfo || (principalInfo->type() == mozilla::ipc::PrincipalInfo::TContentPrincipalInfo && principalInfo->get_ContentPrincipalInfo().attrs().mPrivateBrowsingId == 0))) { blobStorageType = MutableBlobStorage::eCouldBeInTemporaryFile; } RefPtr promise = BodyConsumer::Create( global, mMainThreadEventTarget, bodyStream, signalImpl, aType, BodyBlobURISpec(), BodyLocalPath(), mimeType, mixedCaseMimeType, blobStorageType, aRv); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } return promise.forget(); } template already_AddRefed FetchBody::ConsumeBody( JSContext* aCx, BodyConsumer::ConsumeType aType, ErrorResult& aRv); template already_AddRefed FetchBody::ConsumeBody( JSContext* aCx, BodyConsumer::ConsumeType aType, ErrorResult& aRv); template already_AddRefed FetchBody::ConsumeBody( JSContext* aCx, BodyConsumer::ConsumeType aType, ErrorResult& aRv); template void FetchBody::GetMimeType(nsACString& aMimeType, nsACString& aMixedCaseMimeType) { // Extract mime type. ErrorResult result; nsCString contentTypeValues; MOZ_ASSERT(DerivedClass()->GetInternalHeaders()); DerivedClass()->GetInternalHeaders()->Get("Content-Type"_ns, contentTypeValues, result); MOZ_ALWAYS_TRUE(!result.Failed()); // HTTP ABNF states Content-Type may have only one value. // This is from the "parse a header value" of the fetch spec. if (!contentTypeValues.IsVoid() && contentTypeValues.Find(",") == -1) { // Convert from a bytestring to a UTF8 CString. CopyLatin1toUTF8(contentTypeValues, aMimeType); aMixedCaseMimeType = aMimeType; ToLowerCase(aMimeType); } } template void FetchBody::GetMimeType(nsACString& aMimeType, nsACString& aMixedCaseMimeType); template void FetchBody::GetMimeType(nsACString& aMimeType, nsACString& aMixedCaseMimeType); template const nsACString& FetchBody::BodyBlobURISpec() const { return DerivedClass()->BodyBlobURISpec(); } template const nsACString& FetchBody::BodyBlobURISpec() const; template const nsACString& FetchBody::BodyBlobURISpec() const; template const nsACString& FetchBody::BodyBlobURISpec() const; template const nsAString& FetchBody::BodyLocalPath() const { return DerivedClass()->BodyLocalPath(); } template const nsAString& FetchBody::BodyLocalPath() const; template const nsAString& FetchBody::BodyLocalPath() const; template const nsAString& FetchBody::BodyLocalPath() const; template void FetchBody::SetReadableStreamBody(JSContext* aCx, ReadableStream* aBody) { MOZ_ASSERT(!mReadableStreamBody); MOZ_ASSERT(aBody); mReadableStreamBody = aBody; RefPtr signalImpl = DerivedClass()->GetSignalImpl(); if (!signalImpl) { return; } bool aborted = signalImpl->Aborted(); if (aborted) { IgnoredErrorResult result; JS::Rooted abortReason(aCx, signalImpl->RawReason()); AbortStream(aCx, mReadableStreamBody, result, abortReason); if (NS_WARN_IF(result.Failed())) { return; } } else if (!IsFollowing()) { Follow(signalImpl); } } template void FetchBody::SetReadableStreamBody(JSContext* aCx, ReadableStream* aBody); template void FetchBody::SetReadableStreamBody(JSContext* aCx, ReadableStream* aBody); template already_AddRefed FetchBody::GetBody(JSContext* aCx, ErrorResult& aRv) { if (mReadableStreamBody) { return do_AddRef(mReadableStreamBody); } nsCOMPtr inputStream; DerivedClass()->GetBody(getter_AddRefs(inputStream)); if (!inputStream) { return nullptr; } // The spec immediately creates ReadableStream on Response/Request constructor // via https://fetch.spec.whatwg.org/#concept-bodyinit-extract, but Gecko // creates nsIInputStream there instead and creates ReadableStream only when // .body is accessed. Thus we only follow step 4 of it here. // // Step 4: Otherwise, set stream to a new ReadableStream object, and set up // stream with byte reading support. auto algorithms = MakeRefPtr(*inputStream); RefPtr body = ReadableStream::CreateByteNative( aCx, DerivedClass()->GetParentObject(), *algorithms, Nothing(), aRv); if (aRv.Failed()) { return nullptr; } mReadableStreamBody = body; // If the body has been already consumed, we lock the stream. if (BodyUsed()) { LockStream(aCx, body, aRv); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } } RefPtr signalImpl = DerivedClass()->GetSignalImpl(); if (signalImpl) { if (signalImpl->Aborted()) { JS::Rooted abortReason(aCx, signalImpl->RawReason()); AbortStream(aCx, body, aRv, abortReason); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } } else if (!IsFollowing()) { Follow(signalImpl); } } return body.forget(); } template already_AddRefed FetchBody::GetBody( JSContext* aCx, ErrorResult& aRv); template already_AddRefed FetchBody::GetBody( JSContext* aCx, ErrorResult& aRv); template void FetchBody::LockStream(JSContext* aCx, ReadableStream* aStream, ErrorResult& aRv) { // This is native stream, creating a reader will not execute any JS code. RefPtr reader = aStream->GetReader(aRv); if (aRv.Failed()) { return; } } template void FetchBody::LockStream(JSContext* aCx, ReadableStream* aStream, ErrorResult& aRv); template void FetchBody::LockStream(JSContext* aCx, ReadableStream* aStream, ErrorResult& aRv); template void FetchBody::MaybeTeeReadableStreamBody( JSContext* aCx, ReadableStream** aBodyOut, FetchStreamReader** aStreamReader, nsIInputStream** aInputStream, ErrorResult& aRv) { MOZ_DIAGNOSTIC_ASSERT(aStreamReader); MOZ_DIAGNOSTIC_ASSERT(aInputStream); MOZ_DIAGNOSTIC_ASSERT(!BodyUsed()); *aBodyOut = nullptr; *aStreamReader = nullptr; *aInputStream = nullptr; if (!mReadableStreamBody) { return; } // If this is a ReadableStream with an native source, this has been // generated by a Fetch. In this case, Fetch will be able to recreate it // again when GetBody() is called. if (mReadableStreamBody->MaybeGetInputStreamIfUnread()) { *aBodyOut = nullptr; return; } nsTArray > branches; MOZ_KnownLive(mReadableStreamBody)->Tee(aCx, branches, aRv); if (aRv.Failed()) { return; } mReadableStreamBody = branches[0]; branches[1].forget(aBodyOut); aRv = FetchStreamReader::Create(aCx, mOwner, aStreamReader, aInputStream); if (NS_WARN_IF(aRv.Failed())) { return; } } template void FetchBody::MaybeTeeReadableStreamBody( JSContext* aCx, ReadableStream** aBodyOut, FetchStreamReader** aStreamReader, nsIInputStream** aInputStream, ErrorResult& aRv); template void FetchBody::MaybeTeeReadableStreamBody( JSContext* aCx, ReadableStream** aBodyOut, FetchStreamReader** aStreamReader, nsIInputStream** aInputStream, ErrorResult& aRv); template void FetchBody::RunAbortAlgorithm() { if (!mReadableStreamBody) { return; } AutoJSAPI jsapi; if (!jsapi.Init(mOwner)) { return; } JSContext* cx = jsapi.cx(); RefPtr body(mReadableStreamBody); IgnoredErrorResult result; JS::Rooted abortReason(cx); AbortSignalImpl* signalImpl = Signal(); if (signalImpl) { abortReason.set(signalImpl->RawReason()); } AbortStream(cx, body, result, abortReason); } template void FetchBody::RunAbortAlgorithm(); template void FetchBody::RunAbortAlgorithm(); NS_IMPL_ADDREF_INHERITED(EmptyBody, FetchBody) NS_IMPL_RELEASE_INHERITED(EmptyBody, FetchBody) NS_IMPL_CYCLE_COLLECTION_CLASS(EmptyBody) NS_IMPL_CYCLE_COLLECTION_UNLINK_BEGIN_INHERITED(EmptyBody, FetchBody) NS_IMPL_CYCLE_COLLECTION_UNLINK(mOwner) NS_IMPL_CYCLE_COLLECTION_UNLINK(mAbortSignalImpl) NS_IMPL_CYCLE_COLLECTION_UNLINK(mFetchStreamReader) NS_IMPL_CYCLE_COLLECTION_UNLINK_END NS_IMPL_CYCLE_COLLECTION_TRAVERSE_BEGIN_INHERITED(EmptyBody, FetchBody) NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mOwner) NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mAbortSignalImpl) NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mFetchStreamReader) NS_IMPL_CYCLE_COLLECTION_TRAVERSE_END NS_IMPL_CYCLE_COLLECTION_TRACE_BEGIN_INHERITED(EmptyBody, FetchBody) NS_IMPL_CYCLE_COLLECTION_TRACE_END NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(EmptyBody) NS_INTERFACE_MAP_END_INHERITING(FetchBody) EmptyBody::EmptyBody(nsIGlobalObject* aGlobal, mozilla::ipc::PrincipalInfo* aPrincipalInfo, AbortSignalImpl* aAbortSignalImpl, const nsACString& aMimeType, const nsACString& aMixedCaseMimeType, already_AddRefed aBodyStream) : FetchBody(aGlobal), mAbortSignalImpl(aAbortSignalImpl), mMimeType(aMimeType), mMixedCaseMimeType(aMixedCaseMimeType), mBodyStream(std::move(aBodyStream)) { if (aPrincipalInfo) { mPrincipalInfo = MakeUnique(*aPrincipalInfo); } } EmptyBody::~EmptyBody() = default; /* static */ already_AddRefed EmptyBody::Create( nsIGlobalObject* aGlobal, mozilla::ipc::PrincipalInfo* aPrincipalInfo, AbortSignalImpl* aAbortSignalImpl, const nsACString& aMimeType, const nsACString& aMixedCaseMimeType, ErrorResult& aRv) { nsCOMPtr bodyStream; aRv = NS_NewCStringInputStream(getter_AddRefs(bodyStream), ""_ns); if (NS_WARN_IF(aRv.Failed())) { return nullptr; } RefPtr emptyBody = new EmptyBody(aGlobal, aPrincipalInfo, aAbortSignalImpl, aMimeType, aMixedCaseMimeType, bodyStream.forget()); return emptyBody.forget(); } void EmptyBody::GetBody(nsIInputStream** aStream, int64_t* aBodyLength) { MOZ_ASSERT(aStream); if (aBodyLength) { *aBodyLength = 0; } nsCOMPtr bodyStream = mBodyStream; bodyStream.forget(aStream); } } // namespace mozilla::dom