Sha256: 8290c2dbad9cd3467da44c9afb7dd77b8583dc0b586e98045a99c30e81cc0867
Contents?: true
Size: 1.32 KB
Versions: 26
Compression:
Stored size: 1.32 KB
Contents
import { IncomingMessage } from 'http'
import { PassThrough } from 'stream'
import * as zlib from 'zlib'
import { Logger } from '@open-draft/logger'
const logger = new Logger('http getIncomingMessageBody')
export function getIncomingMessageBody(
response: IncomingMessage
): Promise<string> {
return new Promise((resolve, reject) => {
logger.info('cloning the original response...')
// Pipe the original response to support non-clone
// "response" input. No need to clone the response,
// as we always have access to the full "response" input,
// either a clone or an original one (in tests).
const responseClone = response.pipe(new PassThrough())
const stream =
response.headers['content-encoding'] === 'gzip'
? responseClone.pipe(zlib.createGunzip())
: responseClone
const encoding = response.readableEncoding || 'utf8'
stream.setEncoding(encoding)
logger.info('using encoding:', encoding)
let body = ''
stream.on('data', (responseBody) => {
logger.info('response body read:', responseBody)
body += responseBody
})
stream.once('end', () => {
logger.info('response body end')
resolve(body)
})
stream.once('error', (error) => {
logger.info('error while reading response body:', error)
reject(error)
})
})
}
Version data entries
26 entries across 26 versions & 1 rubygems