@aws-sdk/eventstream-codec

Encoding messages

This feature allows you to encode messages into the AWS event stream format. The `marshall` function takes a message object with headers and a body and returns a Buffer of the encoded message.

const { marshall } = require('@aws-sdk/eventstream-codec');
const message = {
  headers: {
    ':message-type': {
      type: 'string',
      value: 'event'
    },
    ':event-type': {
      type: 'string',
      value: 'Records'
    }
  },
  body: Buffer.from('Hello, this is a test message')
};
const encodedMessage = marshall(message);

Decoding messages

This feature enables the decoding of messages from the AWS event stream format. The `unmarshall` function takes a Buffer of an encoded message and returns an object representing the decoded message, including headers and body.

const { unmarshall } = require('@aws-sdk/eventstream-codec');
const encodedMessage = Buffer.from(/* previously encoded message */);
const decodedMessage = unmarshall(encodedMessage);
console.log(decodedMessage);