Update Gyver433.h

README.md

@@ -51,11 +51,12 @@ Gyver433_xx<пин, буфер, CRC> xx;
 
 // === ДЕФАЙНЫ-НАСТРОЙКИ ===
 // вызывать перед подключением библиотеки
-#define G433_FAST         // [TX] короткая синхронизация для зелёных модулей
+#define G433_FAST           // [TX] короткая синхронизация для зелёных модулей
-#define G433_MEDIUM       // [TX] средняя синхронизация при отправке на SYN480R ЧАЩЕ 400мс (активно по умолчанию)
+#define G433_MEDIUM         // [TX] средняя синхронизация при отправке на SYN480R ЧАЩЕ 400мс (активно по умолчанию)
-#define G433_SLOW         // [TX] длинная синхронизация при отправке на SYN480R РЕЖЕ 400мс
+#define G433_SLOW           // [TX] длинная синхронизация при отправке на SYN480R РЕЖЕ 400мс
-#define G433_MANCHESTER   // [должно быть одинаково на RX и TX] интерфейс Manchester Coding для экспериментов =) 
+#define G433_MANCHESTER     // [должно быть одинаково на RX и TX] интерфейс Manchester Coding для экспериментов =) 
-#define G433_SPEED 1000   // [должно быть одинаково на RX и TX] скорость 100-8000 бит/с, по умолч. 2000 бит/с 
+#define G433_SPEED 1000     // [должно быть одинаково на RX и TX] скорость 100-8000 бит/с, по умолч. 2000 бит/с 
+#define G433_RSSI_COUNT 10  // [RX] количество успешно принятых пакетов для расчёта RSSI (по умолч. 10)
 ```
 
 <a id="usage"></a>
@@ -74,6 +75,7 @@ bool readData(T &data);     // прочитает буфер в любой ти
 uint16_t getSize();         // получить размер принятых данных
 uint16_t gotData();         // вернёт количество успешно принятых в tickISR() байт (см. пример isr_rx)
 uint8_t buffer[];           // доступ к буферу для отладки
+uint8_t getRSSI();          // получить качество приёма (процент успешных передач)
 
 // ============= CRC =============
 // можно использовать встроенные функции для генерации байта CRC для ручной упаковки пакетов
@@ -84,7 +86,7 @@ uint8_t G433_crc_xor(uint8_t *buffer, uint8_t size);    // ручной CRC XOR
 <a id="example"></a>
 ## Примеры
 Остальные примеры смотри в **examples**!
-![Logo](/doc/scheme.jpg)
+![scheme](/doc/scheme.jpg)
 ### Отправка
 ```cpp
 #include <Gyver433.h>
@@ -151,6 +153,7 @@ void loop() {
 - v1.0
 - v1.1 - оптимизация, новый интерфейс, поддержка дешёвых синих модулей, работа в прерывании
 - v1.2 - улучшение качества связи, оптимизация работы в прерывании
+- v1.3 - добавлен вывод RSSI
 
 <a id="feedback"></a>
 ## Баги и обратная связь

examples/demo_rx/demo_rx.ino

@@ -31,6 +31,9 @@ void loop() {
     // принятые данные доступны в .buffer
     // и имеют размер .size
     Serial.write(rx.buffer, rx.size);
-    Serial.println();
+
+    // выведем также качество связи
+    Serial.print(", RSSI: ");
+    Serial.println(rx.getRSSI());
   }
 }

examples/raw_tx/raw_tx.ino

@@ -19,7 +19,7 @@ void loop() {
   if (++count >= 100) count = 0;
 
   // отправка данных типа byte*
-  tx.write(data, sizeof(data));
+  tx.write((byte*)data, sizeof(data));
 
   // отправка 10 раз в сек
   delay(100);

keywords.txt

@@ -26,6 +26,7 @@ getSize	KEYWORD2
 gotData	KEYWORD2
 G433_crc8	KEYWORD2
 G433_crc_xor	KEYWORD2
+getRSSI	KEYWORD2
 
 #######################################
 # Constants (LITERAL1)

library.properties

@@ -1,5 +1,5 @@
 name=Gyver433
-version=1.2
+version=1.3
 author=AlexGyver <alex@alexgyver.ru>
 maintainer=AlexGyver <alex@alexgyver.ru>
 sentence=Simple library for 433 MHz radio

src/Gyver433.h

@@ -18,6 +18,7 @@
     v1.0 - релиз
     v1.1 - оптимизация, новый интерфейс, поддержка дешёвых синих модулей, работа в прерывании
     v1.2 - улучшение качества связи, оптимизация работы в прерывании
+    v1.3 - добавлен вывод RSSI
 */
 
 #ifndef Gyver433_h
@@ -34,6 +35,10 @@ uint8_t G433_crc_xor(uint8_t *buffer, uint8_t size);    // ручной CRC XOR
 #define G433_SPEED 2000
 #endif
 
+#ifndef G433_RSSI_COUNT
+#define G433_RSSI_COUNT 10
+#endif
+
 // тайминги интерфейса
 #define FRAME_TIME (1000000ul / G433_SPEED) // время фрейма (либо HIGH)
 #define HALF_FRAME (FRAME_TIME / 2)         // полфрейма (либо LOW)
@@ -55,9 +60,9 @@ uint8_t G433_crc_xor(uint8_t *buffer, uint8_t size);    // ручной CRC XOR
 #endif
 
 // режимы CRC
-#define G433_CRC8 0
+#define G433_NOCRC 0
-#define G433_XOR 1
+#define G433_CRC8 1
-#define G433_NOCRC 2
+#define G433_XOR 2
 
 // количество синхроимпульсов
 #if defined(G433_FAST)
@@ -83,7 +88,8 @@ public:
     
     // отправка, блокирующая. Кушает любой тип данных
     template <typename T>
-    void sendData(T &data) {
+    bool sendData(T &data) {
+        if (sizeof(T) > TX_BUF) return 0;
         const uint8_t *ptr = (const uint8_t*) &data;
         for (uint16_t i = 0; i < sizeof(T); i++) buffer[i] = *ptr++;
         if (CRC_MODE == G433_CRC8) {
@@ -95,6 +101,7 @@ public:
         } else {
             write(buffer, sizeof(T));
         }
+        return 1;
     }
     
     // отправка сырого набора байтов
@@ -137,7 +144,7 @@ public:
     }
     
     // доступ к буферу
-    uint8_t buffer[TX_BUF];
+    uint8_t buffer[TX_BUF + !!CRC_MODE];
     
 private:    
 };
@@ -186,18 +193,31 @@ public:
     uint16_t gotData() {
         if (parse == 2 && millis() - tmr2 >= 10) {              // фрейм не закрыт
             parse = size = 0;                                   // приём окончен   
-            if (byteCount > 1) {                                // если что то приняли
+            if (byteCount > (1 + !!CRC_MODE)) {                 // если что то приняли
-                if (CRC_MODE == G433_CRC8) {                    // CRC8 
+                if (!bitCount) {                                // байт закрыт
-                    if (!G433_crc8(buffer, byteCount)) size = byteCount - 2;
+                    if (CRC_MODE == G433_CRC8) {                // CRC8 
-                } else if (CRC_MODE == G433_XOR) {              // CRC XOR
+                        if (!G433_crc8(buffer, byteCount)) size = byteCount - 2;
-                    if (!G433_crc_xor(buffer, byteCount)) size = byteCount - 2;
+                    } else if (CRC_MODE == G433_XOR) {          // CRC XOR
-                } else size = byteCount - 1;                    // без CRC
+                        if (!G433_crc_xor(buffer, byteCount)) size = byteCount - 2;
+                    } else size = byteCount - 1;                // без CRC
+                }
+                // расчёт RSSI
+                if (!size) errCount++;
+                if (++rcCount >= G433_RSSI_COUNT) {
+                    RSSI = 100 - errCount * 100 / G433_RSSI_COUNT;
+                    errCount = rcCount = 0;
+                }
             }
             return size;
         }
         return 0;
     }
     
+    // получить качество приёма (процент успешных передач)
+    uint8_t getRSSI() {
+        return RSSI;
+    }
+    
     // получить размер принятых данных
     uint16_t getSize() {
         return size;
@@ -207,7 +227,7 @@ public:
     uint16_t size = 0;
     
     // доступ к буферу
-    uint8_t buffer[RX_BUF];
+    uint8_t buffer[RX_BUF + !!CRC_MODE];
     
 private:
     bool pinChanged() {
@@ -268,6 +288,7 @@ private:
     uint8_t parse = 0;
     uint32_t tmr = 0, tmr2 = 0;
     uint8_t bitCount = 0, byteCount = 0;
+    uint8_t errCount = 0, rcCount = 0, RSSI = 0;
 };
 
 // ===== CRC =====