summaryrefslogtreecommitdiffstats
path: root/test/client-idempotent-body.js
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
commit0b6210cd37b68b94252cb798598b12974a20e1c1 (patch)
treee371686554a877842d95aa94f100bee552ff2a8e /test/client-idempotent-body.js
parentInitial commit. (diff)
downloadnode-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.tar.xz
node-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.zip
Adding upstream version 5.28.2+dfsg1+~cs23.11.12.3.upstream/5.28.2+dfsg1+_cs23.11.12.3upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'test/client-idempotent-body.js')
-rw-r--r--test/client-idempotent-body.js43
1 files changed, 43 insertions, 0 deletions
diff --git a/test/client-idempotent-body.js b/test/client-idempotent-body.js
new file mode 100644
index 0000000..99e5371
--- /dev/null
+++ b/test/client-idempotent-body.js
@@ -0,0 +1,43 @@
+'use strict'
+
+const { test } = require('tap')
+const { Client } = require('..')
+const { createServer } = require('http')
+
+test('idempotent retry', (t) => {
+ t.plan(11)
+
+ const body = 'world'
+ const server = createServer((req, res) => {
+ let buf = ''
+ req.on('data', data => {
+ buf += data
+ }).on('end', () => {
+ t.strictSame(buf, body)
+ res.end()
+ })
+ })
+ t.teardown(server.close.bind(server))
+
+ server.listen(0, () => {
+ const client = new Client(`http://localhost:${server.address().port}`, {
+ pipelining: 2
+ })
+ t.teardown(client.close.bind(client))
+
+ const _err = new Error()
+
+ for (let n = 0; n < 4; ++n) {
+ client.stream({
+ path: '/',
+ method: 'PUT',
+ idempotent: true,
+ body
+ }, () => {
+ throw _err
+ }, (err) => {
+ t.equal(err, _err)
+ })
+ }
+ })
+})