[gzip buffer async] #zip #gzip

zip.js

import { pipeline } from 'node:stream/promises'
import zlib from 'node:zlib'

/**
 * gzip
 *
 * @param {Buffer | string} data
 */
export async function gzip(data) {
  /** @type {Buffer} */
  const result = await new Promise((resolve, reject) => {
    zlib.gzip(data, (err, res) => {
      if (err) reject(err)
      else resolve(res)
    })
  })

  return result
}

/**
 * ungzip
 *
 * @param {Buffer | string} data
 */
export async function gunzip(data) {
  /** @type {Buffer} */
  const result = await new Promise((resolve, reject) => {
    zlib.gunzip(data, (err, res) => {
      if (err) reject(err)
      else resolve(res)
    })
  })

  return result
}

/**
 * ungzip stream to buffer
 *
 * @param {import('stream').Readable} stream
 * @returns
 */
export async function gunzipStreamToBuffer(stream) {
  /** @type {Buffer[]} */
  const chunks = []

  await pipeline(stream, zlib.createGunzip(), async function* (src) {
    for await (const chunk of src) {
      chunks.push(chunk)
    }
  })

  return Buffer.concat(chunks)
}