1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
|
// META: global=window,worker
// META: script=../resources/utils.js
// META: script=/common/utils.js
// META: script=/common/get-host-info.sub.js
function testUpload(desc, url, method, createBody, expectedBody) {
const requestInit = {method};
promise_test(function(test){
const body = createBody();
if (body) {
requestInit["body"] = body;
requestInit.duplex = "half";
}
return fetch(url, requestInit).then(function(resp) {
return resp.text().then((text)=> {
assert_equals(text, expectedBody);
});
});
}, desc);
}
function testUploadFailure(desc, url, method, createBody) {
const requestInit = {method};
promise_test(t => {
const body = createBody();
if (body) {
requestInit["body"] = body;
}
return promise_rejects_js(t, TypeError, fetch(url, requestInit));
}, desc);
}
const url = RESOURCES_DIR + "echo-content.py"
testUpload("Fetch with PUT with body", url,
"PUT",
() => "Request's body",
"Request's body");
testUpload("Fetch with POST with text body", url,
"POST",
() => "Request's body",
"Request's body");
testUpload("Fetch with POST with URLSearchParams body", url,
"POST",
() => new URLSearchParams("name=value"),
"name=value");
testUpload("Fetch with POST with Blob body", url,
"POST",
() => new Blob(["Test"]),
"Test");
testUpload("Fetch with POST with ArrayBuffer body", url,
"POST",
() => new ArrayBuffer(4),
"\0\0\0\0");
testUpload("Fetch with POST with Uint8Array body", url,
"POST",
() => new Uint8Array(4),
"\0\0\0\0");
testUpload("Fetch with POST with Int8Array body", url,
"POST",
() => new Int8Array(4),
"\0\0\0\0");
testUpload("Fetch with POST with Float32Array body", url,
"POST",
() => new Float32Array(1),
"\0\0\0\0");
testUpload("Fetch with POST with Float64Array body", url,
"POST",
() => new Float64Array(1),
"\0\0\0\0\0\0\0\0");
testUpload("Fetch with POST with DataView body", url,
"POST",
() => new DataView(new ArrayBuffer(8), 0, 4),
"\0\0\0\0");
testUpload("Fetch with POST with Blob body with mime type", url,
"POST",
() => new Blob(["Test"], { type: "text/maybe" }),
"Test");
testUploadFailure("Fetch with POST with ReadableStream containing String", url,
"POST",
() => {
return new ReadableStream({start: controller => {
controller.enqueue("Test");
controller.close();
}})
});
testUploadFailure("Fetch with POST with ReadableStream containing null", url,
"POST",
() => {
return new ReadableStream({start: controller => {
controller.enqueue(null);
controller.close();
}})
});
testUploadFailure("Fetch with POST with ReadableStream containing number", url,
"POST",
() => {
return new ReadableStream({start: controller => {
controller.enqueue(99);
controller.close();
}})
});
testUploadFailure("Fetch with POST with ReadableStream containing ArrayBuffer", url,
"POST",
() => {
return new ReadableStream({start: controller => {
controller.enqueue(new ArrayBuffer());
controller.close();
}})
});
testUploadFailure("Fetch with POST with ReadableStream containing Blob", url,
"POST",
() => {
return new ReadableStream({start: controller => {
controller.enqueue(new Blob());
controller.close();
}})
});
promise_test(async (test) => {
const resp = await fetch(
"/fetch/connection-pool/resources/network-partition-key.py?"
+ `status=421&uuid=${token()}&partition_id=${get_host_info().ORIGIN}`
+ `&dispatch=check_partition&addcounter=true`,
{method: "POST", body: "foobar"});
assert_equals(resp.status, 421);
const text = await resp.text();
assert_equals(text, "ok. Request was sent 2 times. 2 connections were created.");
}, "Fetch with POST with text body on 421 response should be retried once on new connection.");
promise_test(async (test) => {
const body = new ReadableStream({start: c => c.close()});
await promise_rejects_js(test, TypeError, fetch('/', {method: 'POST', body}));
}, "Streaming upload shouldn't work on Http/1.1.");
|
