import { IoTClient } from '@google-cloud/iot';

const iotClient = new IoTClient();

async function connectToCloudIoT() {
  try {
    const registryId = 'my-registry';
    const deviceId = 'my-device';

    const parentName = iotClient.registryPath(process.env.PROJECT_ID, region, registryId);
    const device = {
      id: deviceId,
    };

    const [response] = await iotClient.createDevice({ parent: parentName, device });
    console.log('Created device:', response);
  } catch (err) {
    console.error('Could not create device:', err);
  }
}

async function publishMessage() {
  try {
    const formattedName = iotClient.devicePath(process.env.PROJECT_ID, region, registryId, deviceId);
    const data = Buffer.from('Hello, Cloud IoT Core!', 'base64');
    const message = { binaryData: data };

    const response = await iotClient.publishMessage({ name: formattedName, binaryData: message });
    console.log('Message published:', response);
  } catch (err) {
    console.error('Could not publish message:', err);
  }
}

connectToCloudIoT();
publishMessage();