test.js

import fs from 'fs'
import zlib from 'zlib'
import test from 'ava'
import pEvent from 'p-event'
import m from '.'

const fixture = fs.readFileSync('test.js', 'utf8')

test('get the brotli-compressed size', async (t) => {
  t.true(await m(fixture) < fixture.length)
})

test('brotli compression level', async (t) => {
  t.true(await m(fixture, { params: { [zlib.constants.BROTLI_PARAM_QUALITY]: 6 } }) > await m(fixture))
})

test('sync - get the brotli-compressed size', (t) => {
  t.true(m.sync(fixture) < fixture.length)
})

test('sync - match async version', async (t) => {
  t.is(m.sync(fixture), await m(fixture))
})

test('sync - brotli compression level', (t) => {
  t.true(m.sync(fixture, { params: { [zlib.constants.BROTLI_PARAM_QUALITY]: 6 } }) < m.sync(fixture, { params: { [zlib.constants.BROTLI_PARAM_QUALITY]: 1 } }))
})

test('stream', async (t) => {
  const stream = fs.createReadStream('test.js').pipe(m.stream())
  await pEvent(stream, 'end')
  t.is(stream.brotliSize, m.sync(fixture))
})

test('brotli-size event', async (t) => {
  const stream = fs.createReadStream('test.js').pipe(m.stream())
  const size = await pEvent(stream, 'brotli-size')
  t.is(size, m.sync(fixture))
})

test('passthrough', async (t) => {
  let out = ''

  const stream = fs.createReadStream('test.js')
    .pipe(m.stream())
    .on('data', (buffer) => {
      out += buffer
    })

  await pEvent(stream, 'end')
  t.is(out, fixture)
})

test('file - get the brotli-compressed size', async (t) => {
  t.true(await m.file('test.js') < fixture.length)
})

test('fileSync - get the brotli-compressed size', (t) => {
  t.is(m.fileSync('test.js'), m.sync(fixture))
})

test('file - match async version', async (t) => {
  t.is(await m.file('test.js'), await m(fixture))
})