<!doctype html>
<html>
  <head>
    <meta charset="utf-8">
    <title>Response clone</title>
    <meta name="help" href="https://fetch.spec.whatwg.org/#response">
    <meta name="author" title="Canon Research France" href="https://www.crf.canon.fr">
    <script src="/resources/testharness.js"></script>
    <script src="/resources/testharnessreport.js"></script>
  </head>
  <body>
    <script src="../resources/utils.js"></script>
    <script>
      var defaultValues = { "type" : "default",
                            "url" : "",
                            "ok" : true,
                            "status" : 200,
                            "statusText" : "OK"
      };

      var response = new Response();
      var clonedResponse = response.clone();
      test(function() {
        for (var attributeName in defaultValues) {
            var expectedValue = defaultValues[attributeName];
            assert_equals(clonedResponse[attributeName], expectedValue,
              "Expect default response." + attributeName + " is " + expectedValue);
        }
      }, "Check Response's clone with default values, without body");

      var body = "This is response body";
      var headersInit = { "name" : "value" };
      var responseInit  = { "status" : 200,
                            "statusText" : "GOOD",
                            "headers" : headersInit
      };
      var response = new Response(body, responseInit);
      var clonedResponse = response.clone();
      test(function() {
        assert_equals(clonedResponse.status, responseInit["status"],
          "Expect response.status is " + responseInit["status"]);
        assert_equals(clonedResponse.statusText, responseInit["statusText"],
          "Expect response.statusText is " + responseInit["statusText"]);
        assert_equals(clonedResponse.headers.get("name"), "value",
          "Expect response.headers has name:value header");
      }, "Check Response's clone has the expected attribute values");

      promise_test(function(test) {
        return validateStreamFromString(response.body.getReader(), body);
      }, "Check orginal response's body after cloning");

      promise_test(function(test) {
        return validateStreamFromString(clonedResponse.body.getReader(), body);
      }, "Check cloned response's body");

      promise_test(function(test) {
        var disturbedResponse = new Response("data");
        return disturbedResponse.text().then(function() {
            assert_true(disturbedResponse.bodyUsed, "response is disturbed");
            assert_throws(new TypeError() , function() { disturbedResponse.clone(); },
              "Expect TypeError exception");
        });
      }, "Cannot clone a disturbed response");

    promise_test(function(t) {
        var clone;
        var result;
        var response;
        return fetch('../resources/trickle.py?count=2&delay=100').then(function(res) {
            clone = res.clone();
            response = res;
            return clone.arrayBuffer();
        }).then(function(r) {
            assert_equals(r.byteLength, 26);
            result = r;
            return response.arrayBuffer();
        }).then(function(r) {
            assert_array_equals(r, result, "cloned responses should provide the same data");
        });
     }, 'Cloned responses should provide the same data');

    promise_test(function(t) {
        var clone;
        return fetch('../resources/trickle.py?count=2&delay=100').then(function(res) {
            clone = res.clone();
            res.body.cancel();
            assert_true(res.bodyUsed);
            assert_false(clone.bodyUsed);
            return clone.arrayBuffer();
        }).then(function(r) {
            assert_equals(r.byteLength, 26);
            assert_true(clone.bodyUsed);
        });
    }, 'Cancelling stream should not affect cloned one');

function testReadableStreamClone(initialBuffer, bufferType)
{
    promise_test(function(test) {
        var response = new Response(new ReadableStream({start : function(controller) {
            controller.enqueue(initialBuffer);
            controller.close();
        }}));

        var clone = response.clone();
        var stream1 = response.body;
        var stream2 = clone.body;

        var buffer;
        return stream1.getReader().read().then(function(data) {
            assert_false(data.done);
            assert_true(data.value === initialBuffer, "Buffer of being-cloned response stream is the same as the original buffer");
            return stream2.getReader().read();
        }).then(function(data) {
            assert_false(data.done);
            assert_array_equals(data.value, initialBuffer, "Cloned buffer chunks have the same content");
            assert_equals(Object.getPrototypeOf(data.value), Object.getPrototypeOf(initialBuffer), "Cloned buffers have the same type");
            if (ReadableStreamTee.length > 1) {
              // ReadableStreamTee supports cloning for stream2
              assert_true(data.value !== initialBuffer, "Buffer of cloned response stream is a clone of the original buffer");
            }
        });
    }, "Check response clone use structureClone for teed ReadableStreams (" + bufferType  + "chunk)");
}

var arrayBuffer = new ArrayBuffer(16);
testReadableStreamClone(new Int8Array(arrayBuffer, 1), "Int8Array");
testReadableStreamClone(new Int16Array(arrayBuffer, 2, 2), "Int16Array");
testReadableStreamClone(new Int32Array(arrayBuffer), "Int32Array");
testReadableStreamClone(arrayBuffer, "ArrayBuffer");
testReadableStreamClone(new Uint8Array(arrayBuffer), "Uint8Array");
testReadableStreamClone(new Uint8ClampedArray(arrayBuffer), "Uint8ClampedArray");
testReadableStreamClone(new Uint16Array(arrayBuffer, 2), "Uint16Array");
testReadableStreamClone(new Uint32Array(arrayBuffer), "Uint32Array");
testReadableStreamClone(new Float32Array(arrayBuffer), "Float32Array");
testReadableStreamClone(new Float64Array(arrayBuffer), "Float64Array");
testReadableStreamClone(new DataView(arrayBuffer, 2, 8), "DataView");
    </script>
  </body>
</html>