[Fetch API] Reflect spec changes of bodyUsed property

third_party/WebKit/Source/modules/fetch/Request.cpp

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "config.h"
 #include "modules/fetch/Request.h"
 
 #include "bindings/core/v8/Dictionary.h"
 #include "core/dom/Document.h"
 #include "core/dom/ExecutionContext.h"
 #include "core/fetch/FetchUtils.h"
 #include "core/fetch/ResourceLoaderOptions.h"
 #include "core/loader/ThreadableLoader.h"
 #include "modules/fetch/BodyStreamBuffer.h"
+#include "modules/fetch/DataConsumerHandleUtil.h"
 #include "modules/fetch/FetchBlobDataConsumerHandle.h"
 #include "modules/fetch/FetchManager.h"
 #include "modules/fetch/RequestInit.h"
 #include "platform/network/HTTPParsers.h"
 #include "platform/network/ResourceRequest.h"
 #include "platform/weborigin/Referrer.h"
 #include "public/platform/WebURLRequest.h"
 #include "public/platform/modules/serviceworker/WebServiceWorkerRequest.h"
 
 namespace blink {
@@ skipping 18 matching lines @@
     request->setCredentials(original->credentials());
     request->setRedirect(original->redirect());
     request->setIntegrity(original->integrity());
     // FIXME: Set cache mode.
     // TODO(yhirano): Set redirect mode.
     return request;
 }
 
 Request* Request::createRequestWithRequestOrString(ScriptState* scriptState, Request* inputRequest, const String& inputString, RequestInit& init, ExceptionState& exceptionState)
 {
-    BodyStreamBuffer* temporaryBody = nullptr;
-
-    if (inputRequest) {
-        // We check bodyUsed even when the body is null in spite of the
-        // spec. See https://github.com/whatwg/fetch/issues/61 for details.
-        if (inputRequest->bodyUsed()) {
-            exceptionState.throwTypeError("Cannot construct a Request with a Request object that has already been used.");
-            return nullptr;
-        }
-    }
-
     // - "If |input| is a Request object and it is disturbed, throw a
     //   TypeError."
+    if (inputRequest && inputRequest->bodyUsed()) {
+        exceptionState.throwTypeError("Cannot construct a Request with a Request object that has already been used.");
+        return nullptr;
+    }
     // - "Let |temporaryBody| be |input|'s request's body if |input| is a
     //   Request object, and null otherwise."
-    if (inputRequest && inputRequest->hasBody()) {
-        if (inputRequest->bodyUsed()) {
-            exceptionState.throwTypeError("Cannot construct a Request with a Request object that has already been used.");
-            return nullptr;
-        }
-        temporaryBody = inputRequest->bodyBuffer();
-    }
+    BodyStreamBuffer* temporaryBody = inputRequest ? inputRequest->bodyBuffer() : nullptr;
 
     // "Let |request| be |input|'s request, if |input| is a Request object,
     // and a new request otherwise."
 
     RefPtr<SecurityOrigin> origin = scriptState->executionContext()->securityOrigin();
 
     // TODO(yhirano): Implement the following steps:
     // - "Let |window| be client."
     // - "If |request|'s window is an environment settings object and its
     //   origin is same origin with entry settings object's origin, set
@@ skipping 274 matching lines @@
         // "4. Set |r|'s opaque flag."
         r->setOpaque();
     }
 
     // "Set |r|'s MIME type to the result of extracting a MIME type from |r|'s
     // request's header list."
     r->m_request->setMIMEType(r->m_request->headerList()->extractMIMEType());
 
     // "If |input| is a Request object and |input|'s request's body is
     // non-null, run these substeps:"
-    //
-    // We set bodyUsed even when the body is null in spite of the
-    // spec. See https://github.com/whatwg/fetch/issues/61 for details.
-    if (inputRequest) {
+    if (inputRequest && inputRequest->bodyBuffer()) {
         // "Set |input|'s body to an empty byte stream."
-        inputRequest->m_request->setBuffer(nullptr);
+        inputRequest->m_request->setBuffer(new BodyStreamBuffer(createFetchDataConsumerHandleFromWebHandle(createDoneDataConsumerHandle())));
         // "Set |input|'s disturbed flag."
-        inputRequest->setBodyPassed();
+        inputRequest->bodyBuffer()->stream()->setIsDisturbed();
     }
 
     // "Return |r|."
     return r;
 }
 
 Request* Request::create(ScriptState* scriptState, const RequestInfo& input, const Dictionary& init, ExceptionState& exceptionState)
 {
     ASSERT(!input.isNull());
     if (input.isUSVString())
@@ skipping 206 matching lines @@
     return "";
 }
 
 String Request::integrity() const
 {
     return m_request->integrity();
 }
 
 Request* Request::clone(ExceptionState& exceptionState)
 {
-    if (bodyUsed()) {
+    if (isBodyLocked() || bodyUsed()) {
         exceptionState.throwTypeError("Request body is already used");
         return nullptr;
     }
 
     FetchRequestData* request = m_request->clone(executionContext());
     Headers* headers = Headers::create(request->headerList());
     headers->setGuard(m_headers->guard());
     return new Request(executionContext(), request, headers);
 }
 
 FetchRequestData* Request::passRequestData()
 {
     ASSERT(!bodyUsed());
-    setBodyPassed();
-    FetchRequestData* newRequestData = m_request->pass(executionContext());
-    return newRequestData;
+    return m_request->pass(executionContext());
 }
 
 bool Request::hasBody() const
 {
     return bodyBuffer();
 }
 
 void Request::populateWebServiceWorkerRequest(WebServiceWorkerRequest& webRequest) const
 {
     webRequest.setMethod(method());
@@ skipping 18 matching lines @@
 }
 
 DEFINE_TRACE(Request)
 {
     Body::trace(visitor);
     visitor->trace(m_request);
     visitor->trace(m_headers);
 }
 
 } // namespace blink