From 7fba9080b4aebb84de2f946934933963bd9fa5a6 Mon Sep 17 00:00:00 2001
From: Daniel Kempkens <daniel+git@kempkens.io>
Date: Mon, 15 Jul 2024 13:23:09 +0200
Subject: [PATCH] fix: mqtt connections

---
 lib/weewx_proxy/mqtt.ex | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/lib/weewx_proxy/mqtt.ex b/lib/weewx_proxy/mqtt.ex
index 1868ed6..0dd73f1 100644
--- a/lib/weewx_proxy/mqtt.ex
+++ b/lib/weewx_proxy/mqtt.ex
@@ -38,6 +38,19 @@ defmodule WeewxProxy.Mqtt do
          password: Application.fetch_env!(:weewx_proxy, :mqtt_weewx_password),
          handler: {Tortoise311.Handler.Logger, []}
        ]},
+      {Tortoise311.Connection,
+       [
+         name: WeewxProxy.Mqtt.SdrIngest,
+         client_id: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_client_id),
+         server:
+           {Tortoise311.Transport.Tcp,
+            host: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_host),
+            port: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_port)},
+         user_name: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_user),
+         password: Application.fetch_env!(:weewx_proxy, :mqtt_sdr_password),
+         subscriptions: ["rtl433"],
+         handler: {WeewxProxy.Sdr.Ecowitt, []}
+       ]},
       {Tortoise311.Connection,
        [
          name: WeewxProxy.Mqtt.ModbusIngest,