/* xdrv_wemohue.ino - wemo and hue support for Sonoff-Tasmota Copyright (C) 2017 Heiko Krupp and Theo Arends This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program. If not, see . */ /*********************************************************************************************\ * Belkin WeMo and Philips Hue bridge emulation \*********************************************************************************************/ #ifdef USE_EMULATION #define UDP_BUFFER_SIZE 200 // Max UDP buffer size needed for M-SEARCH message boolean udpConnected = false; char packetBuffer[UDP_BUFFER_SIZE]; // buffer to hold incoming UDP packet IPAddress ipMulticast(239, 255, 255, 250); // Simple Service Discovery Protocol (SSDP) uint32_t portMulticast = 1900; // Multicast address and port /*********************************************************************************************\ * WeMo UPNP support routines \*********************************************************************************************/ const char WEMO_MSEARCH[] PROGMEM = "HTTP/1.1 200 OK\r\n" "CACHE-CONTROL: max-age=86400\r\n" "DATE: Fri, 15 Apr 2016 04:56:29 GMT\r\n" "EXT:\r\n" "LOCATION: http://{r1}:80/setup.xml\r\n" "OPT: \"http://schemas.upnp.org/upnp/1/0/\"; ns=01\r\n" "01-NLS: b9200ebb-736d-4b93-bf03-835149d13983\r\n" "SERVER: Unspecified, UPnP/1.0, Unspecified\r\n" "ST: urn:Belkin:device:**\r\n" "USN: uuid:{r2}::urn:Belkin:device:**\r\n" "X-User-Agent: redsonic\r\n" "\r\n"; String wemo_serial() { char serial[16]; snprintf_P(serial, sizeof(serial), PSTR("201612K%08X"), ESP.getChipId()); return String(serial); } String wemo_UUID() { char uuid[27]; snprintf_P(uuid, sizeof(uuid), PSTR("Socket-1_0-%s"), wemo_serial().c_str()); return String(uuid); } void wemo_respondToMSearch() { char message[TOPSZ]; char log[LOGSZ]; if (portUDP.beginPacket(portUDP.remoteIP(), portUDP.remotePort())) { String response = FPSTR(WEMO_MSEARCH); response.replace("{r1}", WiFi.localIP().toString()); response.replace("{r2}", wemo_UUID()); portUDP.write(response.c_str()); portUDP.endPacket(); snprintf_P(message, sizeof(message), PSTR("Response sent")); } else { snprintf_P(message, sizeof(message), PSTR("Failed to send response")); } snprintf_P(log, sizeof(log), PSTR("UPnP: Wemo %s to %s:%d"), message, portUDP.remoteIP().toString().c_str(), portUDP.remotePort()); addLog(LOG_LEVEL_DEBUG, log); } /*********************************************************************************************\ * Hue Bridge UPNP support routines * Need to send 3 response packets with varying ST and USN * * Using Espressif Inc Mac Address of 5C:CF:7F:00:00:00 * Philips Lighting is 00:17:88:00:00:00 \*********************************************************************************************/ const char HUE_RESPONSE[] PROGMEM = "HTTP/1.1 200 OK\r\n" "HOST: 239.255.255.250:1900\r\n" "CACHE-CONTROL: max-age=100\r\n" "EXT:\r\n" "LOCATION: http://{r1}:80/description.xml\r\n" "SERVER: FreeRTOS/7.4.2 UPnP/1.0 IpBridge/1.16.0\r\n" "hue-bridgeid: {r2}\r\n"; const char HUE_ST1[] PROGMEM = "ST: upnp:rootdevice\r\n" "USN: uuid:{r3}::upnp:rootdevice\r\n" "\r\n"; const char HUE_ST2[] PROGMEM = "ST: uuid:{r3}\r\n" "USN: uuid:{r3}\r\n" "\r\n"; const char HUE_ST3[] PROGMEM = "ST: urn:schemas-upnp-org:device:Basic:1\r\n" "USN: uuid:{r3}\r\n" "\r\n"; String hue_bridgeid() { String temp = WiFi.macAddress(); temp.replace(":", ""); String bridgeid = temp.substring(0, 6) + "FFFE" + temp.substring(6); return bridgeid; // 5CCF7FFFFE139F3D } String hue_serial() { String serial = WiFi.macAddress(); serial.replace(":", ""); serial.toLowerCase(); return serial; // 5ccf7f139f3d } String hue_UUID() { String uuid = F("f6543a06-da50-11ba-8d8f-"); uuid += hue_serial(); return uuid; // f6543a06-da50-11ba-8d8f-5ccf7f139f3d } void hue_respondToMSearch() { char message[TOPSZ]; char log[LOGSZ]; if (portUDP.beginPacket(portUDP.remoteIP(), portUDP.remotePort())) { String response1 = FPSTR(HUE_RESPONSE); response1.replace("{r1}", WiFi.localIP().toString()); response1.replace("{r2}", hue_bridgeid()); String response = response1; response += FPSTR(HUE_ST1); response.replace("{r3}", hue_UUID()); portUDP.write(response.c_str()); portUDP.endPacket(); //addLog(LOG_LEVEL_DEBUG_MORE, response.c_str()); response = response1; response += FPSTR(HUE_ST2); response.replace("{r3}", hue_UUID()); portUDP.write(response.c_str()); portUDP.endPacket(); //addLog(LOG_LEVEL_DEBUG_MORE, response.c_str()); response = response1; response += FPSTR(HUE_ST3); response.replace("{r3}", hue_UUID()); portUDP.write(response.c_str()); portUDP.endPacket(); //addLog(LOG_LEVEL_DEBUG_MORE, response.c_str()); snprintf_P(message, sizeof(message), PSTR("3 response packets sent")); } else { snprintf_P(message, sizeof(message), PSTR("Failed to send response")); } snprintf_P(log, sizeof(log), PSTR("UPnP: HUE %s to %s:%d"), message, portUDP.remoteIP().toString().c_str(), portUDP.remotePort()); addLog(LOG_LEVEL_DEBUG, log); } /*********************************************************************************************\ * Belkin WeMo and Philips Hue bridge UDP multicast support \*********************************************************************************************/ boolean UDP_Disconnect() { if (udpConnected) { WiFiUDP::stopAll(); addLog_P(LOG_LEVEL_DEBUG, PSTR("UPnP: Multicast disabled")); udpConnected = false; } return udpConnected; } boolean UDP_Connect() { if (!udpConnected) { if (portUDP.beginMulticast(WiFi.localIP(), ipMulticast, portMulticast)) { addLog_P(LOG_LEVEL_INFO, PSTR("UPnP: Multicast (re)joined")); udpConnected = true; } else { addLog_P(LOG_LEVEL_INFO, PSTR("UPnP: Multicast join failed")); udpConnected = false; } } return udpConnected; } void pollUDP() { if (udpConnected) { if (portUDP.parsePacket()) { int len = portUDP.read(packetBuffer, UDP_BUFFER_SIZE -1); if (len > 0) { packetBuffer[len] = 0; } String request = packetBuffer; // addLog_P(LOG_LEVEL_DEBUG_MORE, PSTR("UDP: Packet received")); // addLog_P(LOG_LEVEL_DEBUG_MORE, packetBuffer); if (request.indexOf("M-SEARCH") >= 0) { request.toLowerCase(); request.replace(" ", ""); // addLog_P(LOG_LEVEL_DEBUG_MORE, PSTR("UDP: M-SEARCH Packet received")); // addLog_P(LOG_LEVEL_DEBUG_MORE, request.c_str()); if ((EMUL_WEMO == sysCfg.flag.emulation) && (request.indexOf(F("urn:belkin:device:**")) > 0)) { wemo_respondToMSearch(); } else if ((EMUL_HUE == sysCfg.flag.emulation) && ((request.indexOf(F("st:urn:schemas-upnp-org:device:basic:1")) > 0) || (request.indexOf(F("st:upnp:rootdevice")) > 0) || (request.indexOf(F("st:ssdpsearch:all")) > 0) || (request.indexOf(F("st:ssdp:all")) > 0))) { hue_respondToMSearch(); } } } } } #ifdef USE_WEBSERVER /*********************************************************************************************\ * Wemo web server additions \*********************************************************************************************/ const char WEMO_EVENTSERVICE_XML[] PROGMEM = "" "" "" "SetBinaryState" "" "" "" "BinaryState" "BinaryState" "in" "" "" "" "" "BinaryState" "Boolean" "0" "" "" "level" "string" "0" "" "" "" "\r\n" "\r\n"; const char WEMO_SETUP_XML[] PROGMEM = "" "" "" "urn:Belkin:device:controllee:1" "{x1}" "Belkin International Inc." "Sonoff Socket" "3.1415" "uuid:{x2}" "{x3}" "0" "" "" "urn:Belkin:service:basicevent:1" "urn:Belkin:serviceId:basicevent1" "/upnp/control/basicevent1" "/upnp/event/basicevent1" "/eventservice.xml" "" "" "" "\r\n" "\r\n"; /********************************************************************************************/ void handleUPnPevent() { addLog_P(LOG_LEVEL_DEBUG, PSTR("HTTP: WeMo basic event")); String request = webServer->arg(0); if (request.indexOf(F("State>1 0) { // do_cmnd_power(1, 1); do_cmnd_power(Maxdevice, 1); } if (request.indexOf(F("State>0 0) { // do_cmnd_power(1, 0); do_cmnd_power(Maxdevice, 0); } webServer->send(200, FPSTR(HDR_CTYPE_PLAIN), ""); } void handleUPnPservice() { addLog_P(LOG_LEVEL_DEBUG, PSTR("HTTP: WeMo event service")); webServer->send(200, FPSTR(HDR_CTYPE_PLAIN), FPSTR(WEMO_EVENTSERVICE_XML)); } void handleUPnPsetupWemo() { addLog_P(LOG_LEVEL_DEBUG, PSTR("HTTP: WeMo setup")); String setup_xml = FPSTR(WEMO_SETUP_XML); setup_xml.replace("{x1}", sysCfg.friendlyname[0]); setup_xml.replace("{x2}", wemo_UUID()); setup_xml.replace("{x3}", wemo_serial()); webServer->send(200, FPSTR(HDR_CTYPE_XML), setup_xml); } /*********************************************************************************************\ * Hue web server additions \*********************************************************************************************/ const char HUE_DESCRIPTION_XML[] PROGMEM = "" "" "" "1" "0" "" // "http://{x1}/" "http://{x1}:80/" "" "urn:schemas-upnp-org:device:Basic:1" "Amazon-Echo-HA-Bridge ({x1})" // "Philips hue ({x1})" "Royal Philips Electronics" "Philips hue Personal Wireless Lighting" "Philips hue bridge 2012" "929000226503" "{x3}" "uuid:{x2}" "" "\r\n" "\r\n"; const char HUE_LIGHT_STATUS_JSON[] PROGMEM = "\"on\":{state}," "\"bri\":{b}," "\"hue\":{h}," "\"sat\":{s}," "\"xy\":[0.5, 0.5]," "\"ct\":500," "\"alert\":\"none\"," "\"effect\":\"none\"," "\"colormode\":\"hs\"," "\"reachable\":true"; const char HUE_LIGHTS_STATUS_JSON[] PROGMEM = "\"type\":\"Extended color light\"," "\"name\":\"{j1}\"," "\"modelid\":\"LCT007\"," "\"uniqueid\":\"{j2}\"," "\"swversion\":\"5.50.1.19085\"" "}"; const char HUE_GROUP0_STATUS_JSON[] PROGMEM = "{\"name\":\"Group 0\"," "\"lights\":[{l1}]," "\"type\":\"LightGroup\"," "\"action\":{"; // "\"scene\":\"none\","; const char HUE_CONFIG_RESPONSE_JSON[] PROGMEM = "{\"name\":\"Philips hue\"," "\"mac\":\"{mac}\"," "\"dhcp\":true," "\"ipaddress\":\"{ip}\"," "\"netmask\":\"{mask}\"," "\"gateway\":\"{gw}\"," "\"proxyaddress\":\"none\"," "\"proxyport\":0," "\"bridgeid\":\"{bid}\"," "\"UTC\":\"{dt}\"," "\"whitelist\":{\"{id}\":{" "\"last use date\":\"{dt}\"," "\"create date\":\"{dt}\"," "\"name\":\"Remote\"}}," "\"swversion\":\"01036659\"," "\"apiversion\":\"1.16.0\"," "\"swupdate\":{\"updatestate\":0,\"url\":\"\",\"text\":\"\",\"notify\": false}," "\"linkbutton\":false," "\"portalservices\":false" "}"; const char HUE_LIGHT_RESPONSE_JSON[] PROGMEM = "{\"success\":{\"/lights/{id}/state/{cmd}\":{res}}}"; const char HUE_ERROR_JSON[] PROGMEM = "[{\"error\":{\"type\":901,\"address\":\"/\",\"description\":\"Internal Error\"}}]"; /********************************************************************************************/ String hue_deviceId(uint8_t id) { String deviceid = WiFi.macAddress() + F(":00:11-") + String(id); deviceid.toLowerCase(); return deviceid; // 5c:cf:7f:13:9f:3d:00:11-1 } String hue_userId() { char userid[7]; snprintf_P(userid, sizeof(userid), PSTR("%03x"), ESP.getChipId()); return String(userid); } void handleUPnPsetupHue() { addLog_P(LOG_LEVEL_DEBUG, PSTR("HTTP: Hue Bridge setup")); String description_xml = FPSTR(HUE_DESCRIPTION_XML); description_xml.replace("{x1}", WiFi.localIP().toString()); description_xml.replace("{x2}", hue_UUID()); description_xml.replace("{x3}", hue_serial()); webServer->send(200, FPSTR(HDR_CTYPE_XML), description_xml); } void hue_todo(String *path) { char log[LOGSZ]; snprintf_P(log, sizeof(log), PSTR("HTTP: HUE API not implemented (%s)"),path->c_str()); addLog(LOG_LEVEL_DEBUG_MORE, log); webServer->send(200, FPSTR(HDR_CTYPE_JSON), "{}"); } void hue_config_response(String *response) { *response += FPSTR(HUE_CONFIG_RESPONSE_JSON); response->replace("{mac}", WiFi.macAddress()); response->replace("{ip}", WiFi.localIP().toString()); response->replace("{mask}", WiFi.subnetMask().toString()); response->replace("{gw}", WiFi.gatewayIP().toString()); response->replace("{bid}", hue_bridgeid()); response->replace("{dt}", getUTCDateTime()); response->replace("{id}", hue_userId()); } void hue_config(String *path) { String response = ""; hue_config_response(&response); webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } void hue_light_status(byte device, String *response) { *response += FPSTR(HUE_LIGHT_STATUS_JSON); response->replace("{state}", (power & (0x01 << (device-1))) ? "true" : "false"); if (sfl_flg) { sl_replaceHSB(response); #ifdef USE_WS2812 } else if (pin[GPIO_WS2812] < 99) { ws2812_replaceHSB(response); #endif // USE_WS2812 } else { response->replace("{h}", "0"); response->replace("{s}", "0"); response->replace("{b}", "0"); } } void hue_global_cfg(String *path) { String response; path->remove(0,1); // cut leading / to get response = F("{\"lights\":{\""); for (uint8_t i = 1; i <= Maxdevice; i++) { response += i; response += F("\":{\"state\":{"); hue_light_status(i, &response); response += "},"; response += FPSTR(HUE_LIGHTS_STATUS_JSON); response.replace("{j1}", sysCfg.friendlyname[i-1]); response.replace("{j2}", hue_deviceId(i)); if (i < Maxdevice) { response += ",\""; } } response += F("},\"groups\":{},\"schedules\":{},\"config\":"); hue_config_response(&response); response += "}"; webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } void hue_auth(String *path) { char response[38]; snprintf_P(response, sizeof(response), PSTR("[{\"success\":{\"username\":\"%s\"}}]"), hue_userId().c_str()); webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } void hue_lights(String *path) { /* * http://sonoff/api/username/lights/1/state?1={"on":true,"hue":56100,"sat":254,"bri":254,"alert":"none","transitiontime":40} */ String response; uint8_t device = 1; uint16_t tmp = 0; int16_t pos = 0; float bri = 0; float hue = 0; float sat = 0; float ct = 0; bool resp = false; bool on = false; bool change = false; char id[4]; path->remove(0,path->indexOf("/lights")); // Remove until /lights if (path->endsWith("/lights")) { // Got /lights response = "{\""; for (uint8_t i = 1; i <= Maxdevice; i++) { response += i; response += F("\":{\"state\":{"); hue_light_status(i, &response); response += "},"; response += FPSTR(HUE_LIGHTS_STATUS_JSON); response.replace("{j1}", sysCfg.friendlyname[i-1]); response.replace("{j2}", hue_deviceId(i)); if (i < Maxdevice) { response += ",\""; } } response += "}"; webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } else if (path->endsWith("/state")) { // Got ID/state path->remove(0,8); // Remove /lights/ path->remove(path->indexOf("/state")); // Remove /state device = atoi(path->c_str()); if ((device < 1) || (device > Maxdevice)) { device = 1; } if (1 == webServer->args()) { response = "["; StaticJsonBuffer<400> jsonBuffer; JsonObject &hue_json = jsonBuffer.parseObject(webServer->arg(0)); if (hue_json.containsKey("on")) { response += FPSTR(HUE_LIGHT_RESPONSE_JSON); response.replace("{id}", String(device)); response.replace("{cmd}", "on"); on = hue_json["on"]; switch(on) { case false : do_cmnd_power(device, 0); response.replace("{res}", "false"); break; case true : do_cmnd_power(device, 1); response.replace("{res}", "true"); break; default : response.replace("{res}", (power & (0x01 << (device-1))) ? "true" : "false"); break; } resp = true; } if (sfl_flg) { sl_getHSB(&hue,&sat,&bri); #ifdef USE_WS2812 } else if (pin[GPIO_WS2812] < 99) { ws2812_getHSB(&hue,&sat,&bri); #endif // USE_WS2812 } if (hue_json.containsKey("bri")) { tmp = hue_json["bri"]; bri = (float)tmp / 254.0f; if (resp) { response += ","; } response += FPSTR(HUE_LIGHT_RESPONSE_JSON); response.replace("{id}", String(device)); response.replace("{cmd}", "bri"); response.replace("{res}", String(tmp)); resp = true; change = true; } if (hue_json.containsKey("hue")) { tmp = hue_json["hue"]; hue = (float)tmp / 65535.0f; if (resp) { response += ","; } response += FPSTR(HUE_LIGHT_RESPONSE_JSON); response.replace("{id}", String(device)); response.replace("{cmd}", "hue"); response.replace("{res}", String(tmp)); resp = true; change = true; } if (hue_json.containsKey("sat")) { tmp = hue_json["sat"]; sat = (float)tmp / 254.0f; if (resp) { response += ","; } response += FPSTR(HUE_LIGHT_RESPONSE_JSON); response.replace("{id}", String(device)); response.replace("{cmd}", "sat"); response.replace("{res}", String(tmp)); change = true; } if (hue_json.containsKey("ct")) { // Color temperature 153 (Cold) to 500 (Warm) tmp = hue_json["ct"]; ct = (float)tmp / 500.0f; if (resp) { response += ","; } response += FPSTR(HUE_LIGHT_RESPONSE_JSON); response.replace("{id}", String(device)); response.replace("{cmd}", "ct"); response.replace("{res}", String(tmp)); change = true; } if (change) { if (sfl_flg) { sl_setHSB(hue, sat, bri, ct); #ifdef USE_WS2812 } else if (pin[GPIO_WS2812] < 99) { ws2812_setHSB(hue, sat, bri); #endif // USE_WS2812 } change = false; } response += "]"; if (2 == response.length()) { response = FPSTR(HUE_ERROR_JSON); } } else { response = FPSTR(HUE_ERROR_JSON); } addLog(LOG_LEVEL_DEBUG_MORE, response.c_str()); webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } else if(path->indexOf("/lights/") >= 0) { // Got /lights/ID path->remove(0,8); // Remove /lights/ device = atoi(path->c_str()); if ((device < 1) || (device > Maxdevice)) { device = 1; } response += F("{\"state\":{"); hue_light_status(device, &response); response += "},"; response += FPSTR(HUE_LIGHTS_STATUS_JSON); response.replace("{j1}", sysCfg.friendlyname[device-1]); response.replace("{j2}", hue_deviceId(device)); webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } else { webServer->send(406, FPSTR(HDR_CTYPE_JSON), "{}"); } } void hue_groups(String *path) { /* * http://sonoff/api/username/groups?1={"name":"Woonkamer","lights":[],"type":"Room","class":"Living room"}) */ String response = "{}"; if (path->endsWith("/0")) { response = FPSTR(HUE_GROUP0_STATUS_JSON); String lights = F("\"1\""); for (uint8_t i = 2; i <= Maxdevice; i++) { lights += ",\"" + String(i) + "\""; } response.replace("{l1}", lights); hue_light_status(1, &response); response += F("}}"); } webServer->send(200, FPSTR(HDR_CTYPE_JSON), response); } void handle_hue_api(String *path) { /* HUE API uses /api// syntax. The userid is created by the echo device and * on original HUE the pressed button allows for creation of this user. We simply ignore the * user part and allow every caller as with Web or WeMo. * * (c) Heiko Krupp, 2017 */ char log[LOGSZ]; uint8_t args = 0; path->remove(0, 4); // remove /api uint16_t apilen = path->length(); snprintf_P(log, sizeof(log), PSTR("HTTP: Hue API (%s)"), path->c_str()); addLog(LOG_LEVEL_DEBUG_MORE, log); for (args = 0; args < webServer->args(); args++) { String json = webServer->arg(args); snprintf_P(log, sizeof(log), PSTR("HTTP: Hue POST args (%s)"), json.c_str()); addLog(LOG_LEVEL_DEBUG_MORE, log); } if (path->endsWith("/invalid/")) {} // Just ignore else if (!apilen) hue_auth(path); // New HUE App setup else if (path->endsWith("/")) hue_auth(path); // New HUE App setup else if (path->endsWith("/config")) hue_config(path); else if (path->indexOf("/lights") >= 0) hue_lights(path); else if (path->indexOf("/groups") >= 0) hue_groups(path); else if (path->endsWith("/schedules")) hue_todo(path); else if (path->endsWith("/sensors")) hue_todo(path); else if (path->endsWith("/scenes")) hue_todo(path); else if (path->endsWith("/rules")) hue_todo(path); else hue_global_cfg(path); } #endif // USE_WEBSERVER #endif // USE_EMULATION