Sha256: d70c11570c91179c84fdf9f74ebd85291d99d2e2d591ca1695669bc8e13dcee1
Contents?: true
Size: 1.63 KB
Versions: 26
Compression:
Stored size: 1.63 KB
Contents
import { it, expect } from 'vitest'
import { IncomingMessage } from 'http'
import { Socket } from 'net'
import * as zlib from 'zlib'
import { getIncomingMessageBody } from './getIncomingMessageBody'
it('returns utf8 string given a utf8 response body', async () => {
const utfBuffer = Buffer.from('one')
const message = new IncomingMessage(new Socket())
const pendingResponseBody = getIncomingMessageBody(message)
message.emit('data', utfBuffer)
message.emit('end')
expect(await pendingResponseBody).toEqual('one')
})
it('returns utf8 string given a gzipped response body', async () => {
const utfBuffer = zlib.gzipSync(Buffer.from('two'))
const message = new IncomingMessage(new Socket())
message.headers = {
'content-encoding': 'gzip',
}
const pendingResponseBody = getIncomingMessageBody(message)
message.emit('data', utfBuffer)
message.emit('end')
expect(await pendingResponseBody).toEqual('two')
})
it('returns utf8 string given a gzipped response body with incorrect "content-lenght"', async () => {
const utfBuffer = zlib.gzipSync(Buffer.from('three'))
const message = new IncomingMessage(new Socket())
message.headers = {
'content-encoding': 'gzip',
'content-length': '500',
}
const pendingResponseBody = getIncomingMessageBody(message)
message.emit('data', utfBuffer)
message.emit('end')
expect(await pendingResponseBody).toEqual('three')
})
it('returns empty string given an empty body', async () => {
const message = new IncomingMessage(new Socket())
const pendingResponseBody = getIncomingMessageBody(message)
message.emit('end')
expect(await pendingResponseBody).toEqual('')
})
Version data entries
26 entries across 26 versions & 1 rubygems