【Flutter × ESP32】AWS Device Shadow・MQTT経由でおやすみモードの時間設定を同期

// device_shadow.go
package clocky_be

import (
	"encoding/json"

	"github.com/EarEEG-dev/clocky_be/types"
)

type DeviceConfig struct {
	TalkFrequency           int                  `json:"talk_frequency"`
	BirthDate               types.NullDate       `json:"birth_date"`
	PhraseType              types.NullString     `json:"phrase_type"`
	TalkStartTime           types.NullHourMinute `json:"talk_start_time"`
	TalkEndTime             types.NullHourMinute `json:"talk_end_time"`
	WeatherAnnouncementTime types.NullHourMinute `json:"weather_announcement_time"`
	WorkStartTime           types.NullHourMinute `json:"work_start_time"`
	WorkEndTime             types.NullHourMinute `json:"work_end_time"`
	SleepTransitionTime     types.NullInt64      `json:"sleep_transition_time"` // 追加したフィールド
	Volume                  int                  `json:"volume"`
}

// ... 他の構造体と関数 ...

func UserToDeviceConfig(user *User) DeviceConfig {
	return DeviceConfig{
		TalkFrequency:           int(user.TalkFrequency.Int64),
		BirthDate:               user.BirthDate,
		PhraseType:              user.PhraseType,
		TalkStartTime:           user.TalkStartTime,
		TalkEndTime:             user.TalkEndTime,
		WeatherAnnouncementTime: user.WeatherAnnouncementTime,
		WorkStartTime:           user.WorkStartTime,
		WorkEndTime:             user.WorkEndTime,
		SleepTransitionTime:     user.SleepTransitionTime, // 新しいフィールドの値を設定
		Volume:                  int(user.Volume.Int64),
	}
}

// ... 他の関数 ...

// src/json/device_config.h
#pragma once

#include "ArduinoJson.h"
#include "tl/expected.hpp"
#include "json/types.h"

struct DeviceConfig {
  std::optional<int> talk_frequency;
  std::optional<Time> weather_announcement_time;
  std::optional<Date> birth_date;
  std::optional<String> phrase_type;
  std::optional<Time> talk_start_time;
  std::optional<Time> talk_end_time;
  std::optional<Time> work_start_time;
  std::optional<Time> work_end_time;
  std::optional<int> sleep_transition_time;  // 追加されたフィールド
  std::optional<int> volume;
};

std::optional<DeviceConfig> readDeviceConfig(const JsonVariant &json, const char *key);

void writeDeviceConfig(const DeviceConfig &config, JsonObject &obj);

String serializeDeviceConfig(const DeviceConfig &config);

tl::expected<DeviceConfig, String> deserializeDeviceConfig(const String &payload);

bool isDeviceConfigChanged(const DeviceConfig &config1, const DeviceConfig &config2);

void updateDeviceConfig(std::optional<DeviceConfig> &reportConfig, std::optional<DeviceConfig> &desiredConfig);

// src/json/device_config.cpp

#include "device_config.h"
#include "json_utils.h"

struct DeviceConfig {
  // ... 他のフィールド ...
  std::optional<int> sleep_transition_time; // 追加されたフィールド
  // ... 他のフィールド ...
};

std::optional<DeviceConfig> readDeviceConfig(const JsonVariant &json, const char *key) {
  if (json.containsKey(key)) {
    DeviceConfig state;
    // ... 他のフィールドの読み取り ...
    state.sleep_transition_time = read<int>(json[key], "sleep_transition_time"); // 追加
    return state;
  }
  return std::nullopt;
}

void writeDeviceConfig(const DeviceConfig &config, JsonObject &obj) {
  // ... 他のフィールドの書き込み ...
  writeOpt(obj, "sleep_transition_time", config.sleep_transition_time); // 追加
}

// ... 他の関数 ...

bool isDeviceConfigChanged(const DeviceConfig &config1, const DeviceConfig &config2) {
  // ... 他のフィールドの比較 ...
  if (config1.sleep_transition_time != config2.sleep_transition_time) { // 追加
    return true;
  }
  // ... 他のフィールドの比較 ...
}

void updateDeviceConfig(std::optional<DeviceConfig> &reportConfig, std::optional<DeviceConfig> &desiredConfig) {
  // ... 他のフィールドの更新 ...
  if (desiredConfig->sleep_transition_time) { // 追加
    reportConfig->sleep_transition_time = desiredConfig->sleep_transition_time.value();
  }
  // ... 他のフィールドの更新 ...
}

// ... 他の関数 ...

// sync_device_shadow.cpp

// TopicごとにHandlerを呼び出す
  this->client->onMessage([this](const String &topic, const String &payload) {
    if (topic == topicGetAccepted) {
      if (auto result = handleShadowGetAccepted(payload); !result) {
        Serial.println(result.error().c_str());
      }
    } else if (topic == topicUpdateDelta) {
      if (auto result = handleShadowUpdateDelta(payload); !result) {
        Serial.println(result.error().c_str());
      }
    }
  });

// デバイスシャドウの更新があった場合に呼ばれる
tl::expected<void, String> SyncDeviceShadow::handleShadowUpdateDelta(const String &payload) {
  auto resultDelta = deserializeSubscribeShadowUpdateDelta(payload);
  if (!resultDelta) {
    return tl::make_unexpected("can not deserialize delta shadow: " + resultDelta.error());
  }
  // 現在の設定
  const auto currentConfig = this->shadow.reported->config;
  // 更新された設定
  const auto updatedConfig = resultDelta->state->config;

  // コールバック
  const auto callbackResult = this->updateCallback(currentConfig, updatedConfig);
  if (!callbackResult) {
    return tl::make_unexpected("can not update config: " + callbackResult.error());
  }
  // 更新された設定を反映
  updateDeviceConfig(this->shadow.reported->config, resultDelta->state->config);
  if (const bool isReported = report(); !isReported) {
    return tl::make_unexpected("can not report state: " + resultDelta.error());
  }
  return {};
}

// main.cpp
auto const config = syncDeviceShadow->getConfig();

  // 設定した時刻の範囲外なら後続のアクションをスキップ
  if (!isWithinTalkTime(config->talk_start_time, config->talk_end_time, now_tm)) {
    // 設定した時刻の範囲外なら後続のアクションをスキップ
    Serial.println("out of talk time");
    return {};
  }

flutter: Request updateUser: {"sleep_transition_time":30}

published message to topic: $aws/things/test_002/shadow/update

MQTTPubSubClient::onMessage: $aws/things/test_002/shadow/update/delta {"version":1080,"timestamp":1707014021,"state":{...}}

device config changed

MQTTPubSubClient::publish: $aws/things/test_002/shadow/update {"state":{...}}