Browse Source
Merge branch 'dev' into light
Conflicts: code/espurna/config/general.h code/espurna/config/hardware.h code/espurna/hardware.ino code/html/custom.css code/html/custom.jsfastled
Xose Pérez
7 years ago
14 changed files with 578 additions and 23 deletions
Split View
Diff Options
-
+1 -0code/espurna/config/arduino.h
-
+1 -1code/espurna/config/debug.h
-
+14 -2code/espurna/config/general.h
-
+25 -0code/espurna/config/hardware.h
-
+12 -3code/espurna/espurna.ino
-
+8 -0code/espurna/hardware.ino
-
+2 -3code/espurna/mqtt.ino
-
+26 -9code/espurna/relay.ino
-
+307 -0code/espurna/rfbridge.ino
-
+31 -2code/espurna/web.ino
-
+21 -3code/html/custom.css
-
+60 -0code/html/custom.js
-
+49 -0code/html/index.html
-
+21 -0code/platformio.ini
+ 1
- 0
code/espurna/config/arduino.h
View File
+ 1
- 1
code/espurna/config/debug.h
View File
+ 14
- 2
code/espurna/config/general.h
View File
+ 25
- 0
code/espurna/config/hardware.h
View File
+ 12
- 3
code/espurna/espurna.ino
View File
+ 8
- 0
code/espurna/hardware.ino
View File
+ 2
- 3
code/espurna/mqtt.ino
View File
+ 26
- 9
code/espurna/relay.ino
View File
+ 307
- 0
code/espurna/rfbridge.ino
View File
| @ -0,0 +1,307 @@ | |||
| /* | |||
| ITEAD RF BRIDGE MODULE | |||
| Copyright (C) 2017 by Xose Pérez <xose dot perez at gmail dot com> | |||
| */ | |||
| #ifdef SONOFF_RFBRIDGE | |||
| // ----------------------------------------------------------------------------- | |||
| // DEFINITIONS | |||
| // ----------------------------------------------------------------------------- | |||
| #define RF_MESSAGE_SIZE 9 | |||
| #define RF_CODE_START 0xAA | |||
| #define RF_CODE_ACK 0xA0 | |||
| #define RF_CODE_LEARN 0xA1 | |||
| #define RF_CODE_LEARN_KO 0xA2 | |||
| #define RF_CODE_LEARN_OK 0xA3 | |||
| #define RF_CODE_RFIN 0xA4 | |||
| #define RF_CODE_RFOUT 0xA5 | |||
| #define RF_CODE_STOP 0x55 | |||
| // ----------------------------------------------------------------------------- | |||
| // GLOBALS TO THE MODULE | |||
| // ----------------------------------------------------------------------------- | |||
| unsigned char _uartbuf[RF_MESSAGE_SIZE+3] = {0}; | |||
| unsigned char _uartpos = 0; | |||
| unsigned char _learnId = 0; | |||
| bool _learnStatus = true; | |||
| bool _rfbin = false; | |||
| // ----------------------------------------------------------------------------- | |||
| // PRIVATES | |||
| // ----------------------------------------------------------------------------- | |||
| void _rfbAck() { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Sending ACK\n")); | |||
| Serial.println(); | |||
| Serial.write(RF_CODE_START); | |||
| Serial.write(RF_CODE_ACK); | |||
| Serial.write(RF_CODE_STOP); | |||
| Serial.flush(); | |||
| Serial.println(); | |||
| } | |||
| void _rfbLearn() { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Sending LEARN\n")); | |||
| Serial.println(); | |||
| Serial.write(RF_CODE_START); | |||
| Serial.write(RF_CODE_LEARN); | |||
| Serial.write(RF_CODE_STOP); | |||
| Serial.flush(); | |||
| Serial.println(); | |||
| char wsb[100]; | |||
| sprintf_P(wsb, PSTR("{\"action\": \"rfbLearn\", \"data\":{\"id\": %d, \"status\": %d}}"), _learnId, _learnStatus ? 1 : 0); | |||
| wsSend(wsb); | |||
| } | |||
| void _rfbSend(byte * message) { | |||
| Serial.println(); | |||
| Serial.write(RF_CODE_START); | |||
| Serial.write(RF_CODE_RFOUT); | |||
| for (unsigned char j=0; j<RF_MESSAGE_SIZE; j++) { | |||
| Serial.write(message[j]); | |||
| } | |||
| Serial.write(RF_CODE_STOP); | |||
| Serial.flush(); | |||
| Serial.println(); | |||
| } | |||
| void _rfbSend(byte * message, int times) { | |||
| char buffer[RF_MESSAGE_SIZE]; | |||
| _rfbToChar(message, buffer); | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Sending MESSAGE '%s' %d time(s)\n"), buffer, times); | |||
| for (int i=0; i<times; i++) { | |||
| if (i>0) { | |||
| unsigned long start = millis(); | |||
| while (millis() - start < RF_SEND_DELAY) delay(1); | |||
| } | |||
| _rfbSend(message); | |||
| } | |||
| } | |||
| void _rfbDecode() { | |||
| byte action = _uartbuf[0]; | |||
| char buffer[RF_MESSAGE_SIZE * 2 + 1] = {0}; | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Action 0x%02X\n"), action); | |||
| if (action == RF_CODE_LEARN_KO) { | |||
| _rfbAck(); | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Learn timeout\n")); | |||
| wsSend("{\"action\": \"rfbTimeout\"}"); | |||
| } | |||
| if (action == RF_CODE_LEARN_OK || action == RF_CODE_RFIN) { | |||
| _rfbToChar(&_uartbuf[1], buffer); | |||
| mqttSend(MQTT_TOPIC_RFIN, buffer); | |||
| _rfbAck(); | |||
| } | |||
| if (action == RF_CODE_LEARN_OK) { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Learn success\n")); | |||
| rfbStore(_learnId, _learnStatus, buffer); | |||
| // Websocket update | |||
| char wsb[100]; | |||
| sprintf_P(wsb, PSTR("{\"rfb\":[{\"id\": %d, \"status\": %d, \"data\": \"%s\"}]}"), _learnId, _learnStatus ? 1 : 0, buffer); | |||
| wsSend(wsb); | |||
| } | |||
| if (action == RF_CODE_RFIN) { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Forward message '%s'\n"), buffer); | |||
| // Look for the code | |||
| unsigned char id, status; | |||
| bool found = false; | |||
| for (id=0; id<relayCount(); id++) { | |||
| for (status=0; status<2; status++) { | |||
| String code = rfbRetrieve(id, status == 1); | |||
| if (code.length()) { | |||
| if (code.endsWith(&buffer[12])) { | |||
| found = true; | |||
| break; | |||
| } | |||
| } | |||
| } | |||
| if (found) break; | |||
| } | |||
| if (found) { | |||
| _rfbin = true; | |||
| relayStatus(id, status == 1); | |||
| } | |||
| } | |||
| } | |||
| void _rfbReceive() { | |||
| static bool receiving = false; | |||
| while (Serial.available()) { | |||
| yield(); | |||
| byte c = Serial.read(); | |||
| //DEBUG_MSG_P(PSTR("[RFBRIDGE] Received 0x%02X\n"), c); | |||
| if (receiving) { | |||
| if (c == RF_CODE_STOP) { | |||
| _rfbDecode(); | |||
| receiving = false; | |||
| } else { | |||
| _uartbuf[_uartpos++] = c; | |||
| } | |||
| } else if (c == RF_CODE_START) { | |||
| _uartpos = 0; | |||
| receiving = true; | |||
| } | |||
| } | |||
| } | |||
| bool _rfbCompare(const char * code1, const char * code2) { | |||
| return strcmp(&code1[12], &code2[12]) == 0; | |||
| } | |||
| bool _rfbSameOnOff(unsigned char id) { | |||
| return _rfbCompare(rfbRetrieve(id, true).c_str(), rfbRetrieve(id, false).c_str()); | |||
| } | |||
| /* | |||
| From an hexa char array ("A220EE...") to a byte array (half the size) | |||
| */ | |||
| bool _rfbToArray(const char * in, byte * out) { | |||
| if (strlen(in) != RF_MESSAGE_SIZE * 2) return false; | |||
| char tmp[3] = {0}; | |||
| for (unsigned char p = 0; p<RF_MESSAGE_SIZE; p++) { | |||
| memcpy(tmp, &in[p*2], 2); | |||
| out[p] = strtol(tmp, NULL, 16); | |||
| } | |||
| return true; | |||
| } | |||
| /* | |||
| From a byte array to an hexa char array ("A220EE...", double the size) | |||
| */ | |||
| bool _rfbToChar(byte * in, char * out) { | |||
| for (unsigned char p = 0; p<RF_MESSAGE_SIZE; p++) { | |||
| sprintf(&out[p*2], "%02X", in[p]); | |||
| } | |||
| return true; | |||
| } | |||
| void _rfbMqttCallback(unsigned int type, const char * topic, const char * payload) { | |||
| if (type == MQTT_CONNECT_EVENT) { | |||
| char buffer[strlen(MQTT_TOPIC_RFLEARN) + 3]; | |||
| sprintf(buffer, "%s/+", MQTT_TOPIC_RFLEARN); | |||
| mqttSubscribe(buffer); | |||
| mqttSubscribe(MQTT_TOPIC_RFOUT); | |||
| } | |||
| if (type == MQTT_MESSAGE_EVENT) { | |||
| // Match topic | |||
| String t = mqttSubtopic((char *) topic); | |||
| // Check if should go into learn mode | |||
| if (t.startsWith(MQTT_TOPIC_RFLEARN)) { | |||
| _learnId = t.substring(strlen(MQTT_TOPIC_RFLEARN)+1).toInt(); | |||
| if (_learnId >= relayCount()) { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Wrong learnID (%d)\n"), _learnId); | |||
| return; | |||
| } | |||
| _learnStatus = (char)payload[0] != '0'; | |||
| _rfbLearn(); | |||
| } | |||
| if (t.equals(MQTT_TOPIC_RFOUT)) { | |||
| byte message[RF_MESSAGE_SIZE]; | |||
| if (_rfbToArray(payload, message)) { | |||
| _rfbSend(message, 1); | |||
| } | |||
| } | |||
| } | |||
| } | |||
| // ----------------------------------------------------------------------------- | |||
| // PUBLIC | |||
| // ----------------------------------------------------------------------------- | |||
| void rfbStore(unsigned char id, bool status, const char * code) { | |||
| DEBUG_MSG_P(PSTR("[RFBRIDGE] Storing %d-%s => '%s'\n"), id, status ? "ON" : "OFF", code); | |||
| char key[8] = {0}; | |||
| sprintf(key, "rfb%d%s", id, status ? "on" : "off"); | |||
| setSetting(key, code); | |||
| } | |||
| String rfbRetrieve(unsigned char id, bool status) { | |||
| char key[8] = {0}; | |||
| sprintf(key, "rfb%d%s", id, status ? "on" : "off"); | |||
| return getSetting(key); | |||
| } | |||
| void rfbStatus(unsigned char id, bool status) { | |||
| String value = rfbRetrieve(id, status); | |||
| if (value.length() > 0) { | |||
| bool same = _rfbSameOnOff(id); | |||
| byte message[RF_MESSAGE_SIZE]; | |||
| _rfbToArray(value.c_str(), message); | |||
| unsigned char times = RF_SEND_TIMES; | |||
| if (same) times = _rfbin ? 0 : 1; | |||
| _rfbSend(message, times); | |||
| } | |||
| } | |||
| void rfbLearn(unsigned char id, bool status) { | |||
| _learnId = id; | |||
| _learnStatus = status; | |||
| _rfbLearn(); | |||
| } | |||
| void rfbForget(unsigned char id, bool status) { | |||
| char key[8] = {0}; | |||
| sprintf(key, "rfb%d%s", id, status ? "on" : "off"); | |||
| delSetting(key); | |||
| // Websocket update | |||
| char wsb[100]; | |||
| sprintf_P(wsb, PSTR("{\"rfb\":[{\"id\": %d, \"status\": %d, \"data\": \"\"}]}"), id, status ? 1 : 0); | |||
| wsSend(wsb); | |||
| } | |||
| // ----------------------------------------------------------------------------- | |||
| // SETUP & LOOP | |||
| // ----------------------------------------------------------------------------- | |||
| void rfbSetup() { | |||
| mqttRegister(_rfbMqttCallback); | |||
| } | |||
| void rfbLoop() { | |||
| _rfbReceive(); | |||
| } | |||
| #endif | |||