iotClient.ts

import { DynamoDBClient } from '@aws-sdk/client-dynamodb';
import { IoTDataPlaneClient, PublishCommand } from '@aws-sdk/client-iot-data-plane';
import { TextEncoder } from 'util';

export const dynamoClient = new DynamoDBClient({});
export const iotClient = new IoTDataPlaneClient({});

export const sendCommand = async (args: { id: string; command: string }) => {
  const enc = new TextEncoder();
  const publishCommand = new PublishCommand({
    topic: `${args.id}/commands`,
    qos: 1,
    retain: false,
    payload: enc.encode(args.command),
  });
  return await iotClient.send(publishCommand);
};