esp8266_milight_hub/lib/MiLight/MiLightUdpServer.cpp

#include <MiLightUdpServer.h>

MiLightUdpServer::MiLightUdpServer(MiLightClient*& client, uint16_t port, uint16_t deviceId)
  : client(client), 
    port(port),
    deviceId(deviceId),
    lastGroup(0)
{ }

MiLightUdpServer::~MiLightUdpServer() {
  stop();
}

void MiLightUdpServer::begin() {
  socket.begin(this->port);
}

void MiLightUdpServer::stop() {
  socket.stop();
}

void MiLightUdpServer::handleClient() {
  const size_t packetSize = socket.parsePacket();
  
  if (packetSize) {
    if (packetSize >= 2 && packetSize <= 3) {
      socket.read(packetBuffer, packetSize);
      
#ifdef MILIGHT_UDP_DEBUG
      Serial.print("Handling command: ");
      Serial.print(String(packetBuffer[0], HEX));
      Serial.print(" ");
      Serial.println(String(packetBuffer[1], HEX));
#endif
      
      handleCommand(packetBuffer[0], packetBuffer[1]);
    } else {
      Serial.print("Error, unexpected packet length (should always be 2-3, was: ");
      Serial.println(packetSize);
    }
  }
}

void MiLightUdpServer::handleCommand(uint8_t command, uint8_t commandArg) {
  if (command >= UDP_RGBW_GROUP_1_ON && command <= UDP_RGBW_GROUP_4_OFF) {
    const MiLightStatus status = (command % 2) == 1 ? ON : OFF;
    const uint8_t groupId = (command - UDP_RGBW_GROUP_1_ON + 2)/2;
    
    client->updateStatus(RGBW, deviceId, groupId, status);
    
    this->lastGroup = groupId;
  } else if (command >= UDP_RGBW_GROUP_ALL_WHITE && command <= UDP_RGBW_GROUP_4_WHITE) {
    const uint8_t groupId = (command - UDP_RGBW_GROUP_ALL_WHITE)/2;
    client->updateColorWhite(deviceId, groupId);
    this->lastGroup = groupId;
  } else if (uint8_t cctGroup = cctCommandIdToGroup(command)) {
    client->updateStatus(
      CCT,
      deviceId,
      cctGroup,
      cctCommandToStatus(command)
    );
    this->lastGroup = cctGroup;
  }
  else {
    switch (command) {
      case UDP_RGBW_ALL_ON:
        client->allOn(RGBW, deviceId);
        break;
      
      case UDP_RGBW_ALL_OFF:
        client->allOff(RGBW, deviceId);
        break;
      
      case UDP_RGBW_COLOR:
        // UDP color is shifted by 0xC8 from 2.4 GHz color, and the spectrum is
        // flipped (R->B->G instead of R->G->B)
        client->updateColorRaw(deviceId, this->lastGroup, 0xFF-(commandArg + 0x35));
        break;
        
      case UDP_RGBW_DISCO_MODE:
        pressButton(this->lastGroup, RGBW_DISCO_MODE);
        break;
        
      case UDP_RGBW_SPEED_DOWN:
        pressButton(this->lastGroup, RGBW_SPEED_DOWN);
        break;
        
      case UDP_RGBW_SPEED_UP:
        pressButton(this->lastGroup, RGBW_SPEED_UP);
        break;
        
      case UDP_RGBW_BRIGHTNESS:
        // map [2, 27] --> [0, 100]
        client->updateBrightness(
          deviceId, 
          this->lastGroup, 
          round(((commandArg - 2) / 25.0)*100)
        );
        break;
        
      case UDP_CCT_BRIGHTNESS_DOWN:
        client->decreaseCctBrightness(deviceId, this->lastGroup);
        break;
        
      case UDP_CCT_BRIGHTNESS_UP:
        client->increaseCctBrightness(deviceId, this->lastGroup);
        break;
        
      case UDP_CCT_TEMPERATURE_DOWN:
        client->decreaseTemperature(deviceId, this->lastGroup);
        break;
        
      case UDP_CCT_TEMPERATURE_UP:
        client->increaseTemperature(deviceId, this->lastGroup);
        break;
        
      default:
        Serial.print("MiLightUdpServer - Unhandled command: ");
        Serial.println(command);
    }
  }
}

void MiLightUdpServer::pressButton(uint8_t group, uint8_t button) {
  client->writeRgbw(deviceId, 0, 0, group, button);
}  

uint8_t MiLightUdpServer::cctCommandIdToGroup(uint8_t command) {
  switch (command) {
    case UDP_CCT_GROUP_1_ON:
    case UDP_CCT_GROUP_1_OFF:
      return 1;
    case UDP_CCT_GROUP_2_ON:
    case UDP_CCT_GROUP_2_OFF:
      return 2;
    case UDP_CCT_GROUP_3_ON:
    case UDP_CCT_GROUP_3_OFF:
      return 3;
    case UDP_CCT_GROUP_4_ON:
    case UDP_CCT_GROUP_4_OFF:
      return 4;
  }
  
  return 0;
}  
  
MiLightStatus MiLightUdpServer::cctCommandToStatus(uint8_t command) {
  switch (command) {
    case UDP_CCT_GROUP_1_ON:
    case UDP_CCT_GROUP_2_ON:
    case UDP_CCT_GROUP_3_ON:
    case UDP_CCT_GROUP_4_ON:
      return ON;
    case UDP_CCT_GROUP_1_OFF:
    case UDP_CCT_GROUP_2_OFF:
    case UDP_CCT_GROUP_3_OFF:
    case UDP_CCT_GROUP_4_OFF:
      return OFF;
  }
}