Редизайн на основе текущей ветки мейнстрима + новые устройства.

[rtl-433.git] / src / devices / current_cost.c

diff --git a/src/devices/current_cost.c b/src/devices/current_cost.c
new file mode 100644 (file)
index 0000000..c3e0637
--- /dev/null
+++ b/src/devices/current_cost.c
@@ -0,0 +1,76 @@
+#include "rtl_433.h"
+#include "pulse_demod.h"
+#include "util.h"
+#include "data.h"
+
+static int current_cost_callback(bitbuffer_t *bitbuffer) {
+    bitbuffer_invert(bitbuffer);
+    bitrow_t *bb = bitbuffer->bb;
+    uint8_t *b = bb[0];
+
+    char time_str[LOCAL_TIME_BUFLEN];
+    data_t *data;
+    local_time_str(0, time_str);
+
+    uint8_t init_pattern[] = {
+      0b11001100, //8
+      0b11001100, //16
+      0b11001100, //24
+      0b11001110, //32
+      0b10010001, //40
+      0b01011101, //45 (! last 3 bits is not init)
+    };
+    unsigned int start_pos = bitbuffer_search(bitbuffer, 0, 0, init_pattern, 45);
+
+    if(start_pos == bitbuffer->bits_per_row[0]){
+        return 0;
+    }
+    start_pos += 45;
+
+    bitbuffer_t packet_bits = {0};
+
+    start_pos = bitbuffer_manchester_decode(bitbuffer, 0, start_pos, &packet_bits, 0);
+
+    uint8_t *packet = packet_bits.bb[0];
+    // Read data
+    if(packet_bits.bits_per_row[0] >= 56 && ((packet[0] & 0xf0) == 0) ){
+                   uint16_t device_id = (packet[0] & 0x0f) << 8 | packet[1];
+
+        uint16_t watt0 = (packet[2] & 0x7F) << 8 | packet[3] ;
+        uint16_t watt1 = (packet[4] & 0x7F) << 8 | packet[5] ;
+        uint16_t watt2 = (packet[6] & 0x7F) << 8 | packet[7] ;
+        data = data_make("time",          "",       DATA_STRING, time_str,
+                "model",         "",              DATA_STRING, "CurrentCost TX", //TODO: it may have different CC Model ? any ref ?
+                //"rc",            "Rolling Code",  DATA_INT, rc, //TODO: add rolling code b[1] ? test needed
+                                                               "dev_id",       "Device Id",     DATA_FORMAT, "%d", DATA_INT, device_id,
+                "power0",       "Power 0",       DATA_FORMAT, "%d W", DATA_INT, watt0,
+                "power1",       "Power 1",       DATA_FORMAT, "%d W", DATA_INT, watt1,
+                "power2",       "Power 2",       DATA_FORMAT, "%d W", DATA_INT, watt2,
+                //"battery",       "Battery",       DATA_STRING, battery_low ? "LOW" : "OK", //TODO is there some low battery indicator ?
+                NULL);
+        data_acquired_handler(data);
+        return 1;
+    }
+    return 0;
+}
+
+static char *output_fields[] = {
+    "time",
+    "model",
+    "rc",
+    "power0",
+    "power1",
+    "power2",
+    NULL
+};
+
+r_device current_cost = {
+    .name           = "CurrentCost Current Sensor",
+    .modulation     = FSK_PULSE_PCM,
+    .short_limit    = 250,
+    .long_limit     = 250, // NRZ
+    .reset_limit    = 8000,
+    .json_callback  = &current_cost_callback,
+    .disabled       = 0,
+    .fields         = output_fields,
+};