Use Google Cloud IoT Core instead of CloudMQTT

Author: dtinth

README.md

@@ -22,7 +22,7 @@ It is written in TypeScript and runs on [Google Cloud Run](https://cloud.google.
 
 ![home automation](./images/home_automation.png)
 
-I have a Raspberry Pi set up which can [control lights](https://github.com/dtinth/hue.sh), [air conditioner](https://medium.com/@dtinth/remotely-turning-on-my-air-conditioner-through-google-assistant-1a1441471e9d), and [smart plugs](https://ifttt.com/services/kasa). It receives commands via [CloudMQTT](https://www.cloudmqtt.com/) and performs the action, then reports back to automatron via [its API](#cli-api).
+I have a Raspberry Pi set up which can [control lights](https://github.com/dtinth/hue.sh), [air conditioner](https://medium.com/@dtinth/remotely-turning-on-my-air-conditioner-through-google-assistant-1a1441471e9d), and [smart plugs](https://ifttt.com/services/kasa). It receives commands via [Google Cloud IoT Core](https://cloud.google.com/iot-core/), performs the action, and then reports back to automatron via [its API](#cli-api).
 
 ### expense tracking
 

src/BotSecrets.ts

@@ -25,4 +25,6 @@ export interface BotSecrets {
   SLACK_WEBHOOK_URL: string
   /** My user ID, so that the bot receives commands from me only */
   SLACK_USER_ID: string
+  /** Google Cloud IoT Core device path to send */
+  CLOUD_IOT_CORE_DEVICE_PATH: string
 }

src/HomeAutomation.ts

@@ -1,33 +1,32 @@
-import mqtt from 'mqtt'
+import * as iot from '@google-cloud/iot'
 import { AutomatronContext } from './types'
 
+const iotClient = new iot.v1.DeviceManagerClient()
+
 export async function sendHomeCommand(
   context: AutomatronContext,
   cmd: string | string[]
 ) {
-  var client = await getMQTTClient(context)
-  if (Array.isArray(cmd)) {
-    cmd.forEach(c => client.publish('home', c))
-  } else {
-    client.publish('home', cmd)
-  }
-}
-
-async function getMQTTClient(context: AutomatronContext) {
-  const unsafeGlobal = global as any
-  if (unsafeGlobal.automatronMqttPromise) {
-    return unsafeGlobal.automatronMqttPromise
-  }
-  const promise = new Promise((resolve, reject) => {
-    var client = mqtt.connect(context.secrets.MQTT_URL)
-    client.on('connect', function() {
-      resolve(client)
-    })
-    client.on('error', function(error) {
-      reject(error)
-      unsafeGlobal.automatronMqttPromise = null
+  const cmds = Array.isArray(cmd) ? cmd : [cmd]
+  const formattedName = context.secrets.CLOUD_IOT_CORE_DEVICE_PATH
+  return Promise.all(
+    cmds.map(async (command) => {
+      const id =
+        new Date().toJSON() +
+        Math.floor(Math.random() * 10000)
+          .toString()
+          .padStart(2, '0')
+      const commandMessage = JSON.stringify({
+        id: id,
+        topic: 'home',
+        data: command,
+      })
+      const binaryData = Buffer.from(commandMessage)
+      const request = {
+        name: formattedName,
+        binaryData: binaryData,
+      }
+      await iotClient.sendCommandToDevice(request)
     })
-  })
-  unsafeGlobal.automatronMqttPromise = promise
-  return promise
+  )
 }