summaryrefslogtreecommitdiffstats
path: root/test/client-post.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-post.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-post.js')
-rw-r--r--test/client-post.js73
1 files changed, 73 insertions, 0 deletions
diff --git a/test/client-post.js b/test/client-post.js
new file mode 100644
index 0000000..363b43c
--- /dev/null
+++ b/test/client-post.js
@@ -0,0 +1,73 @@
+'use strict'
+
+const { test } = require('tap')
+const { Client } = require('..')
+const { createServer } = require('http')
+const { Blob } = require('buffer')
+
+test('request post blob', { skip: !Blob }, (t) => {
+ t.plan(4)
+
+ const server = createServer(async (req, res) => {
+ t.equal(req.headers['content-type'], 'application/json')
+ let str = ''
+ for await (const chunk of req) {
+ str += chunk
+ }
+ t.equal(str, 'asd')
+ res.end()
+ })
+ t.teardown(server.close.bind(server))
+
+ server.listen(0, () => {
+ const client = new Client(`http://localhost:${server.address().port}`)
+ t.teardown(client.destroy.bind(client))
+
+ client.request({
+ path: '/',
+ method: 'GET',
+ body: new Blob(['asd'], {
+ type: 'application/json'
+ })
+ }, (err, data) => {
+ t.error(err)
+ data.body.resume().on('end', () => {
+ t.pass()
+ })
+ })
+ })
+})
+
+test('request post arrayBuffer', { skip: !Blob }, (t) => {
+ t.plan(3)
+
+ const server = createServer(async (req, res) => {
+ let str = ''
+ for await (const chunk of req) {
+ str += chunk
+ }
+ t.equal(str, 'asd')
+ res.end()
+ })
+ t.teardown(server.close.bind(server))
+
+ server.listen(0, () => {
+ const client = new Client(`http://localhost:${server.address().port}`)
+ t.teardown(client.destroy.bind(client))
+
+ const buf = Buffer.from('asd')
+ const dst = new ArrayBuffer(buf.byteLength)
+ buf.copy(new Uint8Array(dst))
+
+ client.request({
+ path: '/',
+ method: 'GET',
+ body: dst
+ }, (err, data) => {
+ t.error(err)
+ data.body.resume().on('end', () => {
+ t.pass()
+ })
+ })
+ })
+})