Azure IoT Device HTTP Transport

import { Client, Message } from 'azure-iot-device';
import { Http } from 'azure-iot-device-http';

// Replace with your actual IoT Hub device connection string.
// You can find this in the Azure portal under your IoT Hub -> Devices -> [Your Device] -> Connection string (primary key).
const connectionString: string = process.env.IOTHUB_DEVICE_CONNECTION_STRING || 'HostName=YOUR_HUB.azure-devices.net;DeviceId=YOUR_DEVICE_ID;SharedAccessKey=YOUR_KEY';

if (connectionString.includes('YOUR_HUB')) {
  console.warn('Please replace the placeholder connection string with your actual IoT Hub device connection string.');
  process.exit(1);
}

const client = Client.fromConnectionString(connectionString, Http);

const connectCallback = (err?: Error): void => {
  if (err) {
    console.error(`Could not connect: ${err.message}`);
  } else {
    console.log('Client connected');
    const message = new Message('some data from my device via HTTP');
    console.log('Sending message:', message.getData());
    client.sendEvent(message, (sendErr?: Error) => {
      if (sendErr) {
        console.error(`Error sending message: ${sendErr.toString()}`);
      } else {
        console.log('Message sent successfully');
      }
    });

    client.on('message', (msg: Message) => {
      console.log('Received message from IoT Hub:', msg.getData().toString());
      client.complete(msg, (completeErr?: Error) => {
        if (completeErr) {
          console.error(`Error completing message: ${completeErr.toString()}`);
        } else {
          console.log('Message completed');
        }
      });
    });

    client.on('error', (error: Error) => {
        console.error(`Client error: ${error.message}`);
    });

    client.on('disconnect', (transportError: Error) => {
        console.warn(`Client disconnected: ${transportError?.message || 'Unknown reason'}`);
    });
  }
};

client.open(connectCallback);

// Keep the process alive for a bit to allow messages to be received
setInterval(() => {}, 1000 * 60 * 60); // Keep alive for 1 hour or until process is killed