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>

1 files changed, 102 insertions, 0 deletions

diff --git a/test/utils/esm-wrapper.mjs b/test/utils/esm-wrapper.mjs
new file mode 100644
index 0000000..51f8572
--- /dev/null
+++ b/test/utils/esm-wrapper.mjs
@@ -0,0 +1,102 @@
+import { createServer } from 'http'
+import tap from 'tap'
+import {
+  Agent,
+  Client,
+  errors,
+  pipeline,
+  Pool,
+  request,
+  connect,
+  upgrade,
+  setGlobalDispatcher,
+  getGlobalDispatcher,
+  stream
+} from '../../index.js'
+
+const { test } = tap
+
+test('imported Client works with basic GET', (t) => {
+  t.plan(10)
+
+  const server = createServer((req, res) => {
+    t.equal('/', req.url)
+    t.equal('GET', req.method)
+    t.equal(`localhost:${server.address().port}`, req.headers.host)
+    t.equal(undefined, req.headers.foo)
+    t.equal('bar', req.headers.bar)
+    t.equal(undefined, req.headers['content-length'])
+    res.setHeader('Content-Type', 'text/plain')
+    res.end('hello')
+  })
+
+  t.teardown(server.close.bind(server))
+
+  const reqHeaders = {
+    foo: undefined,
+    bar: 'bar'
+  }
+
+  server.listen(0, () => {
+    const client = new Client(`http://localhost:${server.address().port}`)
+    t.teardown(client.close.bind(client))
+
+    client.request({
+      path: '/',
+      method: 'GET',
+      headers: reqHeaders
+    }, (err, data) => {
+      t.error(err)
+      const { statusCode, headers, body } = data
+      t.equal(statusCode, 200)
+      t.equal(headers['content-type'], 'text/plain')
+      const bufs = []
+      body.on('data', (buf) => {
+        bufs.push(buf)
+      })
+      body.on('end', () => {
+        t.equal('hello', Buffer.concat(bufs).toString('utf8'))
+      })
+    })
+  })
+})
+
+test('imported errors work with request args validation', (t) => {
+  t.plan(2)
+
+  const client = new Client('http://localhost:5000')
+
+  client.request(null, (err) => {
+    t.type(err, errors.InvalidArgumentError)
+  })
+
+  try {
+    client.request(null, 'asd')
+  } catch (err) {
+    t.type(err, errors.InvalidArgumentError)
+  }
+})
+
+test('imported errors work with request args validation promise', (t) => {
+  t.plan(1)
+
+  const client = new Client('http://localhost:5000')
+
+  client.request(null).catch((err) => {
+    t.type(err, errors.InvalidArgumentError)
+  })
+})
+
+test('named exports', (t) => {
+  t.equal(typeof Client, 'function')
+  t.equal(typeof Pool, 'function')
+  t.equal(typeof Agent, 'function')
+  t.equal(typeof request, 'function')
+  t.equal(typeof stream, 'function')
+  t.equal(typeof pipeline, 'function')
+  t.equal(typeof connect, 'function')
+  t.equal(typeof upgrade, 'function')
+  t.equal(typeof setGlobalDispatcher, 'function')
+  t.equal(typeof getGlobalDispatcher, 'function')
+  t.end()
+})