esp8266_milight_hub/lib/MQTT/BulbStateUpdater.h

/**
 * Enqueues updated bulb states and flushes them at the configured interval.
 */

#include <stddef.h>
#include <MqttClient.h>
#include <CircularBuffer.h>
#include <Settings.h>

#ifndef BULB_STATE_UPDATER
#define BULB_STATE_UPDATER

class BulbStateUpdater {
public:
  BulbStateUpdater(Settings& settings, MqttClient& mqttClient, GroupStateStore& stateStore);

  void enqueueUpdate(BulbId bulbId, GroupState& groupState);
  void loop();
  void enable();
  void disable();

private:
  Settings& settings;
  MqttClient& mqttClient;
  GroupStateStore& stateStore;
  CircularBuffer<BulbId, MILIGHT_MAX_STALE_MQTT_GROUPS> staleGroups;
  unsigned long lastFlush;
  bool enabled;

  inline void flushGroup(BulbId bulbId, GroupState& state);
  inline bool canFlush() const;
};

#endif