Home

Awesome

await-busboy

busboy multipart parser with async/await and koa/co yield support.

NPM version build status Test coverage David deps npm download

forked from https://github.com/cojs/busboy and updated to support async/await

Example

const Koa = require('koa')
const app = new Koa()
const parse = require('await-busboy')

app.use(async (ctx, next) => {
  // the body isn't multipart, we can't parse it
  if (!ctx.request.is('multipart/*')) return await next

  const parts = parse(ctx)

  try {
    let part
    while ((part = await parts)) {
      if (part.length) {
        // arrays are await-busboy fields
        console.log({ key: part[0], value: part[1] })
      } else {
        // otherwise, it's a stream
        part.pipe(someOtherStream)
      }
    }
  } catch (err) {
    return ctx.throw(err)
  }

  ctx.body = 'await-busboy is done parsing the form!'
});

app.listen(3000);

Note that parts will be delievered in the order they are defined in the form. Put your CSRF token first in the form and your larger files last.

If you want await-busboy to automatically handle the fields, set the autoFields: true option. Now all the parts will be streams and a field object and array will automatically be populated.

const Koa = require('koa')
const app = new Koa()
const parse = require('await-busboy')

app.use(async (ctx, next) => {
  const parts = parse(ctx, {
    autoFields: true
  })

  try {
    let part
    while ((part = await parts)) {
      // it's a stream
      part.pipe(fs.createWriteStream('some file.txt'))
    }
  } catch (err) {
    return ctx.throw(err)
  }

  ctx.body = 'and we are done parsing the form!'

  // .field holds all the fields in key/value form
  console.log(parts.field._csrf)

  // .fields holds all the fields in [key, value] form
  console.log(parts.fields[0])
})

Example for csrf check

Use options.checkField hook function(name, val, fieldnameTruncated, valTruncated) can handle fields check.

const parse = require('await-busboy')

app.use(async (ctx, next) => {
  const parts = parse(ctx, {
    checkField: (name, value) => {
      if (name === '_csrf' && !checkCSRF(ctx, value)) {
        const err =  new Error('invalid csrf token')
        err.status = 400
        return err
      }
    }
  })

  let part
  while ((part = await parts)) {
    // ...
  }
})

Example for filename extension check

Use options.checkFile hook function(fieldname, file, filename, encoding, mimetype) can handle filename check.

const parse = require('await-busboy')
const path = require('path')

app.use(async (ctx, next) {
  const parts = parse(ctx, {
    // only allow upload `.jpg` files
    checkFile: function (fieldname, file, filename) {
      if (path.extname(filename) !== '.jpg') {
        const err = new Error('invalid jpg image')
        err.status = 400
        return err
      }
    }
  })

  let part
  while ((part = await parts)) {
    // ...
  }
})

co, koa and yield support

This module is backward compatible with koa, co and yield syntax.

const Koa = require('koa')
const app = new Koa()
const parse = require('await-busboy')

app.use(function* (ctx, next) {
  // the body isn't multipart, we can't parse it
  if (!ctx.request.is('multipart/*')) return yield next

  const parts = parse(ctx)

  try {
    let part
    while ((part = yield parts)) {
      if (part.length) {
        // arrays are await-busboy fields
        console.log({ key: part[0], value: part[1] })
      } else {
        // otherwise, it's a stream
        part.pipe(someOtherStream)
      }
    }
  } catch (err) {
    return ctx.throw(err)
  }

  ctx.body = 'await-busboy is done parsing the form!'
});

API

parts = parse(stream, [options])

const parse = require('await-busboy')
const parts = parse(stream, {
  autoFields: true
})

options are passed to busboy. The only additional option is autoFields.

Note: If busboy events partsLimit, filesLimit, fieldsLimit is emitted, will throw an error.

part = await parts

await the next part. If autoFields: true, this will always be a file stream. Otherwise, it will be a field as an array.

If falsey, then the parser is done.

parts.field{}

If autoFields: true, this object will be populated with key/value pairs.

parts.fields[]

If autoFields: true, this array will be populated with all fields.

Development

Running tests

LICENSE

MIT