<!doctype html>
<html>
  <head>
    <meta charset="utf-8">
    <title>Request consume</title>
    <meta name="help" href="https://fetch.spec.whatwg.org/#request">
    <meta name="help" href="https://fetch.spec.whatwg.org/#body-mixin">
    <script src="/resources/testharness.js"></script>
    <script src="/resources/testharnessreport.js"></script>
    <script src="/fetch/api/resources/utils.js"></script>
  </head>
  <body>
    <script>
async function getStringFromStream(reader, currentValue) {
    const data = await reader.read();
    if (!data.done) {
        let buffer;
        if (currentValue) {
            const newBuffer = new ArrayBuffer(data.value.length + currentValue.length);
            buffer = new Uint8Array(newBuffer);
            buffer.set(currentValue, 0);
            buffer.set(data.value, currentValue.length);
        } else
            buffer = data.value;
        return getStringFromStream(reader, buffer);
    }
    return (new TextDecoder).decode(currentValue);
}

function createRequestWithBody(body)
{
    return new Request("", {body: body, method: "POST"});
}

promise_test(function(test) {
    var body = "";
    var request = createRequestWithBody("");
    return validateStreamFromString(request.body.getReader(), "");
}, "Read empty text request's body as readableStream");

promise_test(function(test) {
    var request = createRequestWithBody(new Blob([], { "type" : "text/plain" }));
    return validateStreamFromString(request.body.getReader(), "");
}, "Read empty blob request's body as readableStream");

var formData = new FormData();
formData.append("name", "value");
var textData = JSON.stringify("This is request's body");
var blob = new Blob([textData], { "type" : "text/plain" });
var urlSearchParamsData = "name=value";
var urlSearchParams = new URLSearchParams(urlSearchParamsData);

promise_test(function(test) {
    var request = createRequestWithBody(blob);
    return validateStreamFromString(request.body.getReader(), textData);
}, "Read blob request's body as readableStream");

promise_test(function(test) {
    var request = createRequestWithBody(textData);
    return validateStreamFromString(request.body.getReader(), textData);
}, "Read text request's body as readableStream");

promise_test(function(test) {
    var request = createRequestWithBody(urlSearchParams);
    return validateStreamFromString(request.body.getReader(), urlSearchParamsData);
}, "Read URLSearchParams request's body as readableStream");

promise_test(function(test) {
    var arrayBuffer = new ArrayBuffer(textData.length);
    var int8Array = new Int8Array(arrayBuffer);
    for (var cptr = 0; cptr < textData.length; cptr++)
        int8Array[cptr] = textData.charCodeAt(cptr);

    return validateStreamFromString(createRequestWithBody(arrayBuffer).body.getReader(), textData);
}, "Read array buffer request's body as readableStream");

promise_test(async (test) => {
    var request = createRequestWithBody(formData);
    const value = await getStringFromStream(request.body.getReader());

    assert_true(value.includes('name="name"'), "name");
    assert_true(value.includes('value'), "name");
}, "Read form data request's body as readableStream");

promise_test(async (test) => {
    const formData = new FormData();
    const blob = new Blob(["'Hello'"], { "type" : "text/plain" });
    formData.append("blob", blob, "blob.file");
    formData.append("name", "value");

    const request = createRequestWithBody(formData);
    const value = await getStringFromStream(request.body.getReader());

    assert_true(value.includes('name="name"'), "name");
    assert_true(value.includes('value'), "name");

    assert_true(value.includes('name="blob"'), "blob");
    assert_true(value.includes('Hello'), "Hello");
}, "Read form data with blob request's body as readableStream");
    </script>
  </body>
</html>
