前回の投稿「ESP32をGoogle Smart Homeデバイスにする」で、Google Homeデバイスを扱ってみましたが、いまいちしっくりきません。

理解を深めるために、今回は、AWS IoTと連携してみます。
AWS IoTにはシャドウという機能があり、IoTデバイスと相性がよさそうなので、Google HomeデバイスとIoTデバイスの間に、AWS IoTを挟んで連携しやすくしてみます。

AWS IoT Device Shadow
　https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/iot-device-shadows.html

#しくみ

今回実装するのは、node.jsとGoogle Homeデバイスです。
node.jsの役割は、Google Home通信とAWS IoT通信の仲介です。
node.jsには2種類あり、Google HomeからHTTP通信を受け付けてAWS IoTにMQTT Publishするnode.js(express)サーバと、MQTT SubscribeしてAWS IoTからメッセージを受け取ってGoogle Homeに通知するnode.js(MQTT)サーバです。

Google Homeデバイスとして、M5StickCのようなESP32での実装と、node.jsでのバーチャルデバイスとしての実装の2種類を用意しました。

ということで、この投稿は、前回の投稿「ESP32をGoogle Homeデバイスにする」の続きです。

ソースは以下に上げておきました。以前のGitHubに加えています。

poruruba/GoogleHomeDevice
　https://github.com/poruruba/GoogleHomeDevice/tree/master/IoTSmartHome

#流れ

①Google Home Miniに対して「OK Google スイッチをオンにして」と発するか、スマホのGoogle Homeアプリから、スイッチをオンにします。
②Actions on Googleは、node.js(express)に対して、スイッチオンの要求のため、EXECUTEを呼び出します。
③node.js(express)は、スイッチのAWS IoT Thingのシャドウに対して、スイッチをオンにするdesiredとして更新します。
④AWS IoTは、変更要求が来ていることをupdate/deltaで変更差分をMQTT Publishします。
⑤Google Homeデバイスでは、update/deltaをサブスクライブしておき、受信した差分に基づき、デバイスのLED状態を変更します。そして、変更されたことをreportedとしてAWS IoT ThingのシャドウにMQTT Publishします。
⑥AWS IoTは、シャドウの更新を検知すると、変更後の状態をupdate/documentで通知します。
⑦node.js(MQTT)はupdate/documentをサブスクライブしておき、受信された現在のシャドウの状態を、Google HomeにReportStateとして通知します。

参考情報は以下の通りです。

②action.devices.EXECUTE
　https://developers.google.com/assistant/smarthome/reference/intent/execute

③UpdateThingShadow
　https://docs.aws.amazon.com/iot/latest/apireference/API_iotdata_UpdateThingShadow.html
　https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/using-device-shadows.html

④/update/delta
　https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/device-shadow-mqtt.html#update-delta-pub-sub-topic

⑤update
　https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/device-shadow-mqtt.html#update-pub-sub-topic

⑥/updata/documents
　https://docs.aws.amazon.com/ja_jp/iot/latest/developerguide/device-shadow-mqtt.html#update-documents-pub-sub-topic

⑦ReportState
　https://developers.google.com/assistant/smarthome/develop/report-state

#AWS IoT Thingの作成

AWS IoTのWeb管理コンソールを開きます。

AWS IoT Web管理コンソール
　https://ap-northeast-1.console.aws.amazon.com/iot/home?region=ap-northeast-1#/home

左側のナビゲーションより、管理の下のモノを選択し、その後表示される画面の右上の「作成」ボタンを押下します。

手っ取り早く、「単一のモノを作成する」ボタンを押下します。

名前には、適当な識別子を入力します。たとえば、「switch」
属性キーとして、typeでデバイスタイプを指定します。
たとえば、action.devices.types.SWITCH のGoogle Homeデバイスを作りたい場合は、「SWITCH」とします。
デバイスタイプの一覧は以下にあります。
　https://developers.google.com/assistant/smarthome/guides

「次へ」ボタンを押下します。

手っ取り早く、「証明書を作成」ボタンを押下します。

各種証明書やキーをダウンロードし、「有効化」ボタンを一度押下して、「完了」ボタンを押下します。

次に、シャドウを作成します。

Classic Shadowの右側の「・・・」を選択し、表示を選択します。
そうするとシャドウドキュメントが表示されるので、「編集」をクリックします。
以下のように追記します。

{
  "desired": {
    "welcome": "aws-iot",
    "on": false
  },
  "reported": {
    "welcome": "aws-iot",
    "on": false
  }
}

welcomeは削除できないようでそのままにします。
onは、Google Homeデバイスとして保持しておくべき状態です。ちょっとややこしいのですが、これから作るswitchは、以下の機能(Traits)を持っています。

　action.devices.traits.OnOff

このTraitsを持っているデバイスは、状態として以下に上げるSTATESに上げられるStateをGoogle Homeと共有する必要があります。

OnOffのDevices STATE
　https://developers.google.com/assistant/smarthome/traits/onoff#device-states

１つのデバイスに複数の機能(Traits)を持つことができるので、すべてシャドウとして保持しておきます。

例えば、action.devices.traits.LockUnlockとaction.devices.traits.OpenCloseの２つのTraitsをもったaction.devices.types.LOCKというGoogle Homeデバイスを作るとします。

その場合は、属性type=LOCKとし、シャドウは以下のようにします。値は初期値であり何でも良いです。

{
  "desired": {
    "welcome": "aws-iot",
    "openPercent": 0,
    "isLocked": false,
    "isJammed": false
  },
  "reported": {
    "welcome": "aws-iot",
    "openPercent": 0,
    "isLocked": false,
    "isJammed": false
  }
}

(参考)
　https://developers.google.com/assistant/smarthome/traits/openclose#device-states
　https://developers.google.com/assistant/smarthome/traits/lockunlock#device-states

次にモノのグループを作成します。左側のナビゲーションから選択できます。

「モノのグループを作成」ボタンを押下します。

名前は適当に「SmartHome」とでもしておきます。最後に「モノのグループを作成」ボタンを押下します。

続けて、このグループに先ほど作成したモノを登録します。

モノの追加リンクをクリックすれば、モノを選択できます。

最後に、左側ナビゲーションから設定を選択し、表示されるエンドポイントを覚えておきます。

node.js(express)の実装

api/controllers/smarthome/index.js

'use strict';

const AWS = require("aws-sdk");
AWS.config.update({
  region: "ap-northeast-1",
});

const MANUFACTURER_NAME = process.env.MANUFACTURER_NAME || 'MyHome Devices';
const IOT_ENDPOINT = process.env.IOT_ENDPOINT || '【AWS IoTのエンドポイント】';
var iot = new AWS.Iot();
var iotdata = new AWS.IotData({endpoint: IOT_ENDPOINT});

const jwt_decode = require('jwt-decode');
const {smarthome} = require('actions-on-google');
const app = smarthome();

const DEFAULT_USER_ID = process.env.DEFAULT_USER_ID || "user01";
var agentUserId = DEFAULT_USER_ID;

app.onSync(async (body, headers) => {
  console.info('onSync');
  console.log('onSync body', body);

  var decoded = jwt_decode(headers.authorization);
  console.log(decoded);

  var param_list = {
    thingGroupName: "SmartHome"
  };
  var list = await iot.listThingsInThingGroup(param_list).promise();
  var result = {
    requestId: body.requestId,
    payload: {
      agentUserId: agentUserId,
      devices: []
    }
  };

  for( var i = 0 ; i < list.things.length ; i++ ){
    var param_desc = {
      thingName: list.things[i]
    };
    var desc = await iot.describeThing(param_desc).promise();
    var device = {
      id: list.things[i],
      type: 'action.devices.types.' + desc.attributes.type,
      deviceInfo: {
        manufacturer: MANUFACTURER_NAME,
      },
      willReportState: false,
    };
    switch(device.id){
      case 'switch': {
        device.traits = ['action.devices.traits.OnOff'];
        device.name = { name: "スイッチ" };
        break;
      }
      case 'door': {
        device.traits = ['action.devices.traits.LockUnlock', 'action.devices.traits.OpenClose'];
        device.name = { name: "ドア" };
        device.attributes = {
          discreteOnlyOpenClose: false,
        }
        break;
      }
      case 'illumination': {
        device.traits = ['action.devices.traits.Brightness', 'action.devices.traits.OnOff'];
        device.name = { name: "イルミ" };
        break;
      }
      case 'light': {
        device.traits = ['action.devices.traits.OnOff'];
        device.name = { name: "電気" };
        device.attributes = {
          commandOnlyOnOff: true,
        };
        break;
      }
      case 'aircon': {
        device.traits = ['action.devices.traits.OnOff', 'action.devices.traits.TemperatureSetting'];
        device.name = { name: "エアコン" };
        device.attributes = {
          availableThermostatModes: 'off,heat,cool,auto,dry,on',
          thermostatTemperatureUnit: 'C',
          commandOnlyTemperatureSetting: true,
          commandOnlyOnOff: true,
        };
        device.willReportState = false;
        break;
      }
    }
    result.payload.devices.push(device);
  };

  console.log("onSync result", result);
  return result;
});

app.onQuery(async (body, headers) => {
  console.info('onQuery');
  console.log('onQuery body', body);

  var decoded = jwt_decode(headers.authorization);
  console.log(decoded);

  const {requestId} = body;
  const payload = {
    devices: {}
  };

  for( var i = 0 ; i < body.inputs.length ; i++ ){
    if( body.inputs[i].intent == 'action.devices.QUERY' ){
      for( var j = 0 ; j < body.inputs[i].payload.devices.length ; j++ ){
        var device = body.inputs[i].payload.devices[j];
        var params = {
          thingName: device.id
        };
        var shadow = await iotdata.getThingShadow(params).promise();
        shadow = JSON.parse(shadow.payload);
        var state = shadow.state.reported;
        delete state.welcome;
        state.online = true;
        state.status = 'SUCCESS';
        payload.devices[device.id] = state;
      }
    }
  }

  var result = {
    requestId: requestId,
    payload: payload,
  };

  console.log("onQuery result", result);
  return result;
});

app.onExecute(async (body, headers) => {
  console.info('onExecute');
  console.log('onExecute body', body);

  var decoded = jwt_decode(headers.authorization);
  console.log(decoded);
  
  const {requestId} = body;

  // Execution results are grouped by status
  var ret = {
    requestId: requestId,
    payload: {
      commands: [],
    },
  };
  for( var i = 0 ; i < body.inputs.length ; i++ ){
    if( body.inputs[i].intent == "action.devices.EXECUTE" ){
      for( var j = 0 ; j < body.inputs[i].payload.commands.length ; j++ ){
        var result = {
          ids:[],
          status: 'SUCCESS',
        };
        ret.payload.commands.push(result);

        var devices = body.inputs[i].payload.commands[j].devices;
        var execution = body.inputs[i].payload.commands[j].execution;
        for( var k = 0 ; k < execution.length ; k++ ){
          console.log("command", execution[k].command);
          console.log("params", execution[k].params);
          for( var l = 0 ; l < devices.length ; l++ ){
            result.ids.push(devices[l].id);

            var param_get = {
              thingName: devices[l].id
            };
            var current_shadow = await iotdata.getThingShadow(param_get).promise();
            console.log('current_shadow', current_shadow);

            var state = {};
            switch(execution[k].command){
              case 'action.devices.commands.ThermostatSetMode': {
                state.thermostatMode = execution[k].params.thermostatMode;
                break;
              }
              case 'action.devices.commands.OnOff': {
                state.on = execution[k].params.on;
                break;
              }
              case 'action.devices.commands.mute': {
                state.isMuted = execution[k].params.mute;
                break;
              }
              case 'action.devices.commands.setVolume': {
                state.currentVolume = execution[k].params.volumeLevel;
                break;
              }
              case 'action.devices.commands.LockUnlock': {
                state.isLocked = execution[k].params.lock;
                break;
              }
              case 'action.devices.commands.OpenClose': {
                state.openPercent = execution[k].params.openPercent;
                break;
              }
              case 'action.devices.commands.BrightnessAbsolute': {
                state.brightness = execution[k].params.brightness;
                break;
              }
            }

            var shadow = {
              state: {
                desired: state
              }
            };

            var param_update = {
              thingName: devices[l].id,
              payload: JSON.stringify(shadow)
            };
            console.log('updateThingShadow', param_update);
            await iotdata.updateThingShadow(param_update).promise();
          }
        }
      }
    }
  }

  console.log("onExecute result", ret);
  return ret;
});

app.onDisconnect((body, headers) => {
  console.info('onDisconnect');
  console.log('body', body);

  var decoded = jwt_decode(headers.authorization);
  console.log(decoded);

  // Return empty response
  return {};
});

exports.fulfillment = app;

環境に合わせて以下を書き換えてください。
【AWS IoTのエンドポイント】

app.onSync(async (body, headers)
の中の、
　switch(device.id){
のところに、await iot.listThingsInThingGroup()を呼び出して、Google Homeデバイス用に作ったグループ(SmartHome)の配下のモノがリストアップしていますので、今回実装したいGoogle Homeデバイスを記述します。
さきほど、AWS IoT Thingとして登録した「switch」が以下の部分です。

      case 'switch': {
        device.traits = ['action.devices.traits.OnOff'];
        device.name = { name: "スイッチ" };
        break;
      }

devices.traitsのところに、サポートしたい機能(Traits)を指定します。
nameは呼びやすい名前を付けます。
ほかにもありますが、ご参考まで。

　door ： type=LOCK
　illumination ： type=LIGHT
　light ： type=LIGHT
　aircon ： type=AC_UNIT

今回の実装では、以下のTraitsで要求されうるEXECUTE(Command)を実装しておきました。（不完全かと思いますが。。。。）

・action.devices.traits.OnOff
・action.devices.traits.LockUnlock
・action.devices.traits.OpenClose
・action.devices.traits.Brightness
・action.devices.traits.TemperatureSetting

app.onExecute(async (body, headers)
の中で、AWS IoTのupdateの引数に変換して、iotdata.updateThingShadow()を呼び出しています。

app.onQuery(async (body, headers)
は何をしているかというと、iotdata.getThingShadow()を呼び出して各デバイスのAWS IoT Thingシャドウを取得して、その値をonQuery呼び出し元、すなわち、Actions on Googleに戻しています。

node.js(MQTT)の実装

state_reporter/index.js

'use strict';

const AWS = require("aws-sdk");
AWS.config.update({
  region: "ap-northeast-1",
});
var iot = new AWS.Iot();

const mqtt = require('mqtt');
const {smarthome} = require('actions-on-google');

const JWT_FILE_PATH = process.env.JWT_FILE_PATH || '【サービスアカウントキーファイル名】';
const jwt = require(JWT_FILE_PATH);
const app = smarthome({
  jwt: jwt
});

const MQTT_HOST = process.env.MQTT_HOST || '【MQTTブローカのURL】';
var mqttClient  = mqtt.connect(MQTT_HOST);

const DEFAULT_USER_ID = process.env.DEFAULT_USER_ID || "user01";
var agentUserId = DEFAULT_USER_ID;

var requestId = 0;

mqttClient.on('connect', async () => {
  console.log('connected');
  var param_list = {
    thingGroupName: "SmartHome"
  };
  var list = await iot.listThingsInThingGroup(param_list).promise();
  for( var i = 0 ; i < list.things.length ; i++ ){
    console.log( 'waiting: ' + list.things[i]);
    mqttClient.subscribe('$aws/things/' + list.things[i] + '/shadow/update/documents');
  }
});

mqttClient.on('message', async (topic, message) =>{
  try{
    var tps = topic.split('/');
    if( tps.length < 6 )
      return;
    if( tps[0] != '$aws' || tps[1] != 'things' || tps[3] != "shadow" )
      return;
    
    var thing = tps[2];
    var cmd = tps[4];
    var param = tps[5];
    var document = JSON.parse(message.toString());
    console.log(thing, cmd, param, JSON.stringify(document));
    if( cmd != 'update' )
      return;

    await onUpdate(mqttClient, thing, param, document);
  }catch(error){
    console.error(error);
  }
});

async function onUpdate(client, thingName, param, document ){
  if( param != 'documents' )
    return;

  var reported = document.current.state.reported;
  delete reported.welcome;
  await reportState(thingName, reported);
}

async function reportState(id, state){
  console.log("reportstate", state);
  var message = {
    requestId: String(++requestId),
    agentUserId: agentUserId,
    payload: {
      devices: {
        states:{
          [id]: state
        }
      }
    }
  };

  console.log("reportstate", JSON.stringify(message));
  await app.reportState(message);

  return message;
}

【サービスアカウントキーファイル名】は、以前の投稿で作成したものです。
【MQTTブローカのURL】は以下の感じです。

　　mqtt:// MQTTブローカのホスト名:ポート番号

このMQTTブローカは、以下を参考にして立ち上げたものです。
　AWS IoTにMosquittoをブリッジにしてつなぐ

直接、AWS IoTが用意するMQTTブローカに接続する形でもできます。
その場合は、X509証明書をクライアントに指定する必要があります。（クライアントごとに指定するのが面倒なため、Mosquittoを中継用に立てています）

await iot.listThingsInThingGroup()を呼び出して、Google Homeデバイス用に作ったグループ(SmartHome)の配下のモノをサブスクライブ対象としています。
最後に、app.reportState()で、reportedのstateをGoogle Homeにレポートしています。

これで準備ができました。

Google Homeデバイスの実装(Arduino)

IoTSmartHome\IoTGoogleHomeDevice\src\main.cpp

//#define M5CORE2
#define M5STICKC

#ifdef M5CORE2
#include <M5Core2.h>
#include <Fonts/EVA_20px.h>
#endif
#ifdef M5STICKC
#include <M5StickC.h>
#endif

#include <WiFi.h>
#include <ArduinoJson.h>
#include <PubSubClient.h>

const char* wifi_ssid = "【WiFiアクセスポイントのSSID】";
const char* wifi_password = "【WiFiアクセスポイントのパスワード】";

#define DISP_FORE_COLOR   WHITE
#define DISP_BACK_COLOR   BLACK

#define DEVICE_NAME "switch" // ★DEVICEの名前

const char* mqtt_server = "【MQTTブローカのホスト名】"; // MQTTのIPかホスト名
const int mqtt_port = 1883;       // MQTTのポート
const char* topic_notify = "$aws/things/" DEVICE_NAME "/shadow/update/delta"; // 受信用トピック名
const char* topic_report = "$aws/things/" DEVICE_NAME "/shadow/update"; // 送信用トピック名

#ifdef M5CORE2
#define MQTT_CLIENT_NAME  "M5Core2" // MQTTサーバ接続時のクライアント名
#endif
#ifdef M5STICKC
#define MQTT_CLIENT_NAME  "M5StickC" // MQTTサーバ接続時のクライアント名
#endif

WiFiClient wifiClient;
PubSubClient client(wifiClient);

#define MQTT_BUFFER_SIZE  1024 // MQTT送受信のバッファサイズ

// ★DEVICEごとの定義
#define NUM_OF_ATTR   1
#define LED_PIN     GPIO_NUM_10
typedef struct{
  bool on;
} DEVICE_STATUS;
DEVICE_STATUS device_status = { false };

const int capacity_notify = JSON_OBJECT_SIZE(4) + 3*JSON_OBJECT_SIZE(NUM_OF_ATTR);
const int capacity_report = JSON_OBJECT_SIZE(1) + JSON_OBJECT_SIZE(2) + 2*JSON_OBJECT_SIZE(NUM_OF_ATTR);
StaticJsonDocument<capacity_notify> json_notify;
StaticJsonDocument<capacity_report> json_report;
#define BUFFER_SIZE   MQTT_BUFFER_SIZE
char buffer_notify[BUFFER_SIZE];
char buffer_report[BUFFER_SIZE];

bool isPressed = false;

void updateState(){
  json_report.clear();
  JsonObject state = json_report.createNestedObject("state");
  JsonObject desired = state.createNestedObject("desired");
  JsonObject reported = state.createNestedObject("reported");

  // ★DEVICEごとの処理
  {
    desired["on"] = device_status.on;
    reported["on"] = device_status.on;
  }

  serializeJson(json_report, Serial);
  Serial.println("");

  serializeJson(json_report, buffer_report, sizeof(buffer_report));
  client.publish(topic_report, buffer_report);
}

void mqtt_callback(char* topic, byte* payload, unsigned int length) {
  Serial.println("MQTT received");

  // JSONをパース
  DeserializationError err = deserializeJson(json_notify, payload, length);
  if( err ){
    Serial.println("Deserialize error");
    Serial.println(err.c_str());
    return;
  }
  serializeJson(json_notify, Serial);
  Serial.println("");

  // ★DEVICEごとの処理
  {
    if( json_notify["state"].containsKey("on") ){
      device_status.on = json_notify["state"]["on"];
    }
    digitalWrite(LED_PIN, device_status.on ? LOW : HIGH);
  }

  updateState();
}

void wifi_connect(void){
  Serial.println("");
  Serial.print("WiFi Connenting");

  WiFi.begin(wifi_ssid, wifi_password);
  while (WiFi.status() != WL_CONNECTED) {
    Serial.print(".");
    delay(1000);
  }
  Serial.println("");
  Serial.print("Connected : ");
  Serial.println(WiFi.localIP());
  M5.Lcd.println(WiFi.localIP());
}

void setup() {
#ifdef M5CORE2
  M5.begin(true, false, true, true);
  M5.Lcd.setTextSize(2);
#endif
#ifdef M5STICKC
  M5.begin(true, true, true);
  M5.Lcd.setRotation(3);
  M5.Lcd.setTextSize(1);
#endif

  Serial.begin(9600);
  Serial.println("");
  Serial.println("Now Initializing");

  M5.Lcd.fillScreen(DISP_BACK_COLOR);
  M5.Lcd.setTextColor(DISP_FORE_COLOR);

  // ★DEVICEごとの処理
  {
    pinMode(LED_PIN, OUTPUT);
    digitalWrite(LED_PIN, HIGH);
  }

  wifi_connect();

  // バッファサイズの変更
  client.setBufferSize(MQTT_BUFFER_SIZE);
  // MQTTコールバック関数の設定
  client.setCallback(mqtt_callback);
  // MQTTブローカに接続
  client.setServer(mqtt_server, mqtt_port);

  M5.Lcd.println("MQTT Connect");
}

void loop() {
  M5.update();
  client.loop();

  // MQTT未接続の場合、再接続
  while(!client.connected() ){
    Serial.println("Mqtt Reconnecting");
    if( client.connect(MQTT_CLIENT_NAME) ){
      // MQTT Subscribe
      client.subscribe(topic_notify);
      Serial.println("Mqtt Connected and Subscribing");
      break;
    }
    delay(1000);
  }

  if( M5.BtnA.isPressed() ){
    if( !isPressed ){
      isPressed = true;

      Serial.println("BtnA.Released");

      // ★DEVICEごとの処理
      {
        device_status.on = !device_status.on;
        digitalWrite(LED_PIN, device_status.on ? LOW : HIGH);
      }

      updateState();

      delay(100);
    }
  }else if( M5.BtnA.isReleased() ){
    isPressed = false;
  }

  delay(10);
}

以下の部分を環境に合わせて変更します。

【WiFiアクセスポイントのSSID】
【WiFiアクセスポイントのパスワード】
【MQTTブローカのホスト名】

以下の部分は、実装するGoogle Homeデバイスの機能(Traits)に合わせて実装します。

★DEVICEの名前
★DEVICEごとの定義
★DEVICEごとの処理

今回は、「action.devices.traits.OnOff」のみ実装しており、保持すべき状態(シャドウに相当)は、onのみです。
onがtrueとする要求の場合にLEDを点灯させ、falseの場合には消灯させました。

以下のコールバックのところに、/update/deltaが飛んできます。
void mqtt_callback(char* topic, byte* payload, unsigned int length)

待ち受けるMQTTトピック名は、「$aws/things/" DEVICE_NAME "/shadow/update/delta」です。
変更したことの通知先のMQTTトピック名は、「$aws/things/" DEVICE_NAME "/shadow/update」です。

Google Homeデバイスの実装(バーチャルデバイス)

バーチャルデバイスをNode.jsで実装しました。Arduinoで実装していることと同じです。

iotsmarthome\virtual_device\index.js

'use strict';

const mqtt = require('mqtt');
const MQTT_HOST = process.env.MQTT_HOST || '【MQTTブローカのURL】';
var mqttClient  = mqtt.connect(MQTT_HOST);

const DEVICE_LIST = ["door", "light", "aircon", "illumination"]; // バーチャルデバイスで処理するデバイス名

mqttClient.on('connect', function () {
  console.log('connected');
  for( var i = 0 ; i < DEVICE_LIST.length ; i++ ){
    console.log("waiting: " + DEVICE_LIST[i]);
    mqttClient.subscribe('$aws/things/' + DEVICE_LIST[i] + '/shadow/update/delta');
  }
});

mqttClient.on('message', async (topic, message) =>{
  try{
    var tps = topic.split('/');
    if( tps.length < 6 )
      return;
    if( tps[0] != '$aws' || tps[1] != 'things' || tps[3] != "shadow" )
      return;
    
    var thing = tps[2];
    var cmd = tps[4];
    var param = tps[5];
    var document = JSON.parse(message.toString());
    console.log(thing, cmd, param, document);
    if( cmd != 'update' )
      return;

    await onUpdate(mqttClient, thing, param, document);
  }catch(error){
    console.error(error);
  }
});

async function updateDocument(client, thingName, state){
  console.log('updateDocument');
  var topic = "$aws/things/" + thingName + '/shadow/update';
  var message = {
    state: {
      reported: state,
      desired: state
    }
  };
  console.log(JSON.stringify(message));
  client.publish(topic, JSON.stringify(message));
}

async function onUpdate(client, thingName, param, document ){
  if( param != 'delta' )
    return;

  var desired_state = document.state;

  var reported_state;
  if( thingName == 'light' ){
    reported_state = await process_light(thingName, desired_state);
  }else
  if( thingName == 'aircon' ){
    reported_state = await process_aircon(thingName, desired_state);
  }else
{
    reported_state = await process_other (thingName, desired_state);
  }

  await updateDocument(client, thingName, reported_state);
}

async function process_other(thingName, desired_state){
  // それぞれのデバイスのtraitsに合わせて処理
  return desired_state;
}

async function process_light(thingName, desired_state){
  //
  // desired_state.on=trueまたはfalseの場合の処理
  //

  var state = {
    on: desired_state.on
  };
  return state;
}

async function process_aircon(thingName, desired_state){
  if( desired_state.on !== undefined ){
    //
    // desired_state.on=trueまたはfalseの場合の処理
    //

    var state;
    if( desired_state.on ){
      state = {
        on: true,
        thermostatMode: "auto"
      }
    }else{
      state = {
        on: false,
        thermostatMode: "off"
      }
    }

    return state;
  }else
  if( desired_state.thermostatMode !== undefined ){
    //
    // desired_state.thermostatMode=on または off または cool または heat または auto または dry の場合の処理
    //

    var state;
    if( desired_state.thermostatMode == 'off'){
      state = {
        on: false,
        thermostatMode: "off"
      }
    }else{
      state = {
        on: true,
        thermostatMode: desired_state.thermostatMode
      }
    }

    return state;
  }else{
    throw 'unknown desired';
  }
}

(参考) Mosquittoの設定の修正

MosquittoでローカルネットワークとAWS IoTエンドポイントを仲介させていますが、AWS IoTのMQTTトピックも仲介できるように、以下のように変更しています。

/etc/mosquitto/mosquitto.conf

connection awsiot
address 【AWS IoTのエンドポイント】:8883
topic awsiot/# both 0
topic $aws/things/# both 0

最後から2番目がいつも使っているトピック名の接頭辞ですが、最後の1行目を今回のために追加しました。

(参考) AWS IoTにMosquittoをブリッジにしてつなぐ

あと、AWSのSDKのインストールやら権限設定やらの説明がなくてすみません。

以上