lifion-aws-event-stream

lifion-aws-event-stream

Node.js parser for binary streams under the application/vnd.amazon.eventstream content-type.

Getting Started

To install the module:

npm install lifion-aws-event-stream --save

The module exports a parse function and a Parser stream. To use the parse function:

const { parse } = require('lifion-aws-event-stream');

const buffer = Buffer.from('000000100000000005c248eb7d98c8ff', 'hex');
console.log(parse(buffer)); // { headers: {}, payload: '' }

To use the Parser stream:

const { Parser } = require('lifion-aws-event-stream');

const parser = new Parser();
parser.on('data', console.log); // { headers: {}, payload: '' }

const buffer = Buffer.from('000000100000000005c248eb7d98c8ff', 'hex');
parser.write(buffer);

Pipe an HTTP response to parse the messages as they arrive:

const got = require('got');
const { Parser } = require('lifion-aws-event-stream');
const { pipeline } = require('stream');

pipeline([
  got('/', …),
  new Parser(),
  new Writable({
    objectMode: true,
    write(data, encoding, callback) {
      console.log(data);
      callback();
    }
  }),
]);

This project's implementation is based on:

• https://github.com/aws/aws-sdk-ruby/tree/master/gems/aws-eventstream
• https://github.com/awslabs/aws-c-event-stream

API Reference

• lifion-aws-event-stream
  • .Parser ⇐ Transform
  • .parse(buffer) ⇒ Object

eventStream.Parser ⇐ Transform

A transform stream that calls parse with the binary data written to it. Can be used to pipe a response stream from an AWS service HTTP request. The stream will emit errors thrown during parse calls.

Kind: static class of lifion-aws-event-stream
Extends: Transform

eventStream.parse(buffer) ⇒ Object

Parses the specified buffer with vnd.amazon.eventstream data into an object.

Kind: static method of lifion-aws-event-stream
Returns: Object - The parsed vnd.amazon.eventstream object.
Throws:

• Error Whenever:
  • The specified buffer has less than 16 bytes. The minimum vnd.amazon.eventstream message should have 4 bytes for the total length of the package, 4 bytes for the length of the headers section, 4 bytes for the checksum of the prelude, and finally 4 more bytes for the checksum of the entire message.
  • The total length as specified in the message doesn't matches the bufffer length.
  • The checksum of the prelude doesn't matches the calculated checksum.
  • The checksum of the message doesn't matches the calculated checksum.
  • The header value type is unknown.

Param	Type	Description
buffer	Buffer	The buffer to parse.

License

MIT

Changelog

v1.0.2 (2019-02-27)

• #47: Update dependency eslint to ^5.14.1
• #46: Update dependency jest-junit to ^6.3.0
• #45: Update dependency lint-staged to ^8.1.4
• #44: Update dependency codecov to ^3.2.0
• #43: Update dependency jest to ^24.1.0
• #42: Update dependency lint-staged to ^8.1.3
• #41: Update dependency eslint to ^5.13.0
• #40: Update dependency prettier to ^1.16.4
• #39: Update dependency jest-junit to ^6.2.1
• #37: Update dependency jest to v24
• #36: Update dependency jest-junit to ^6.1.0
• #35: Update dependency npm-watch to ^0.6.0
• #34: Update dependency prettier to ^1.16.1
• #33: Update dependency eslint to ^5.12.1
• #29: Update dependency husky to ^1.3.1
• #30: Update dependency eslint to ^5.12.0
• #31: Update dependency auto-changelog to ^1.11.0
• #32: Update dependency jest-junit to v6
• #28: Update dependency eslint to ^5.10.0
• #27: Update dependency prettier to ^1.15.3
• #25: Update dependency lint-staged to ^8.1.0
• #24: Update dependency husky to ^1.2.0
• #26: Update dependency npm-watch to ^0.5.0
• b07c2d6: Upgrade eslint-config-lifion
• df0dd03: Merge pull request #38 from lifion/feature/renovate-lint-staged-8.x
• 4439212: Update dependency lint-staged to ^8.1.1
• e41f037: Re-create package-lock.json
• c1592df: Correct the author