EndemolShineGroup/serverless-test-utils

import AWS from 'aws-sdk';

export default async (topic: string, message: string) => {
  const iot = new AWS.Iot();

  const describeEndpointResponse = await iot.describeEndpoint().promise();
  const IotData = new AWS.IotData({
    endpoint: describeEndpointResponse.endpointAddress,
  });

  const params = {
    payload: new Buffer(message),
    topic,
  };

  return IotData.publish(params).promise();
};