From 5dd7e295524b72eaa026980f7390c7c8e3020d5d Mon Sep 17 00:00:00 2001
From: mverleun <marco@marcoach.nl>
Date: Sun, 29 Oct 2017 13:47:32 +0100
Subject: [PATCH] Initial release

---
 .gitignore      |  3 ++
 README.md       | 46 ++++++++++++++++++++++++++++
 src/rtl2mqtt.py | 79 +++++++++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 128 insertions(+)
 create mode 100644 .gitignore
 create mode 100755 src/rtl2mqtt.py

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..849d1cc
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,3 @@
+
+*.swp
+src/Dockerfile
diff --git a/README.md b/README.md
index 23baa81..08f6c4b 100644
--- a/README.md
+++ b/README.md
@@ -1 +1,47 @@
 # RTL433 to mqtt
+
+This small script is a cheap and easy way to start with IoT projects.
+By using the great rtl_433 software and a cheap RTL-SDR receiver it will
+listen to all kinds of devices transmitting at the 433,92 Mhz frequency.
+
+Quite likely it will receive information from weatherstations in your area,
+if you don't own one, your neighbours might!
+It will also receive signals from remote controls that are popular to use to
+control the lights.
+
+It's one way. You can receive a lot of information, but you can not send any!
+
+Before you get started you'll have to install some packages.
+
+First install software using the command:
+
+apt-get update && apt-get install -y \
+        rtl-sdr \
+        librtlsdr-dev \
+        librtlsdr0 \
+        git \
+        automake \
+        libtool \
+        cmake
+
+This will install all the software you need to build the latest version of the rtl_433 receiver
+software.
+
+Next download and build the receiver software:
+
+git clone https://github.com/merbanan/rtl_433.git \
+        && cd rtl_433/ \
+        && mkdir build \
+        && cd build \
+        && cmake ../ \
+        && make \
+        && make install
+
+The last step is to install the python MQTT library:
+
+pip3 install paho-mqtt
+
+Once you're done you can connect the RTL-SDR to a USB port and start using the
+python script.
+
+Don't forget to change the settings in the python script. They should match your mqttserver.
diff --git a/src/rtl2mqtt.py b/src/rtl2mqtt.py
new file mode 100755
index 0000000..e542cf8
--- /dev/null
+++ b/src/rtl2mqtt.py
@@ -0,0 +1,79 @@
+#!/usr/bin/env python3
+# -*- coding: UTF-8 -*-
+
+import subprocess
+import sys
+import time
+import paho.mqtt.client as mqtt
+import os
+import json
+
+# Config section
+# Uncomment these lines if your MQTT server requires authentication
+#MQTT_USER="mqtt-user"
+#MQTT_PASS="mqtt-password"
+MQTT_HOST="mqtt.example.com"
+MQTT_PORT=1883
+MQTT_TOPIC="sensors/rtl_433"
+MQTT_QOS=0
+# End config section
+
+rtl_433_cmd = "/usr/local/bin/rtl_433 -G -F json" # linux
+
+# Define MQTT event callbacks
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result code "+str(rc))
+
+def on_disconnect(client, userdata, rc):
+    if rc != 0:
+        print("Unexpected disconnection.")
+
+def on_message(client, obj, msg):
+    print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
+
+def on_publish(client, obj, mid):
+    print("mid: " + str(mid))
+
+def on_subscribe(client, obj, mid, granted_qos):
+    print("Subscribed: " + str(mid) + " " + str(granted_qos))
+
+def on_log(client, obj, level, string):
+    print(string)
+
+# Setup MQTT connection
+
+mqttc = mqtt.Client()
+# Assign event callbacks
+#mqttc.on_message = on_message
+mqttc.on_connect = on_connect
+#mqttc.on_publish = on_publish
+mqttc.on_subscribe = on_subscribe
+mqttc.on_disconnect = on_disconnect
+
+# Uncomment to enable debug messages
+#mqttc.on_log = on_log
+
+# Uncomment the next line if your MQTT server requires authentication
+#mqttc.username_pw_set(MQTT_USER, password=MQTT_PASS)
+mqttc.connect(MQTT_HOST, MQTT_PORT, 60)
+
+mqttc.loop_start()
+
+# Start RTL433 listener
+rtl433_proc = subprocess.Popen(rtl_433_cmd.split(),stdout=subprocess.PIPE,stderr=subprocess.STDOUT,universal_newlines=True)
+
+
+while True:
+    for line in iter(rtl433_proc.stdout.readline, '\n'):
+        if "time" in line:
+            mqttc.publish(MQTT_TOPIC, payload=line,qos=MQTT_QOS)
+            json_dict = json.loads(line)
+            for item in json_dict:
+                value = json_dict[item]
+                if "model" in item:
+                    subtopic=value
+
+            for item in json_dict:
+                value = json_dict[item]
+                if not "model" in item:
+                    mqttc.publish(MQTT_TOPIC+"/"+subtopic+"/"+item, payload=value,qos=MQTT_QOS)