init mqtt stuff

mqtt/main.py

@@ -0,0 +1,30 @@
+import paho.mqtt.client as mqtt
+
+
+
+# The callback for when the client receives a CONNACK response from the server.
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result code " + str(rc))
+
+    # Subscribing in on_connect() means that if we lose the connection and
+    # reconnect then subscriptions will be renewed.
+    client.subscribe("control/lights/set")
+
+
+# The callback for when a PUBLISH message is received from the server.
+def on_message(client, userdata, msg):
+    print(msg.topic + " " + str(msg.payload))
+
+
+client = mqtt.Client()
+client.on_connect = on_connect
+client.on_message = on_message
+client.username_pw_set("homeassistant", password="password")
+
+client.connect("pepe.private", 1883, 60)
+
+# Blocking call that processes network traffic, dispatches callbacks and
+# handles reconnecting.
+# Other loop*() functions are available that give a threaded interface and a
+# manual interface.
+client.loop_forever()

mqtt/requirements.txt

@@ -0,0 +1 @@
+paho-mqtt

mqtt/shell.nix

@@ -0,0 +1,20 @@
+{ pkgs ? import <nixpkgs> { } }:
+let
+
+  myPython = pkgs.python3.withPackages (python-packages:
+    with python-packages; [
+        paho-mqtt
+    ]);
+
+  startServer = pkgs.writers.writeBashBin "start-server" ''
+    ${myPython}/bin/python ./main.py
+  '';
+
+in pkgs.mkShell {
+
+  buildInputs = with pkgs; [
+    myPython
+    startServer
+  ];
+
+}