From 09882a66a42794b24e3d02fab7de8d53fead8ee6 Mon Sep 17 00:00:00 2001
From: Matt Hadden <forceh2010@gmail.com>
Date: Thu, 5 Dec 2024 14:09:07 -0500
Subject: [PATCH] refactor(amqp): update conditions subtopic

---
 src/lib/eccc/conditions.ts | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/lib/eccc/conditions.ts b/src/lib/eccc/conditions.ts
index 806ba8fa..02db617c 100644
--- a/src/lib/eccc/conditions.ts
+++ b/src/lib/eccc/conditions.ts
@@ -92,7 +92,7 @@ class CurrentConditions {
 
     // hook up the amqp listener
     const { connection, emitter: listener } = listen({
-      amqp_subtopic: `citypage_weather.xml.${config.primaryLocation.province}.#`,
+      amqp_subtopic: `*.WXO-DD.citypage_weather.xml.${config.primaryLocation.province}.#`,
     });
 
     // handle errors and messages
@@ -102,7 +102,7 @@ class CurrentConditions {
         // make sure its relevant to us
         if (!url.includes(`${this._weatherStationID}_e.xml`)) return;
 
-        this.fetchConditions();
+        this.fetchConditions(url);
         logger.log("Received new conditions from AMQP at", date);
       });
 
@@ -112,9 +112,9 @@ class CurrentConditions {
     logger.log("Started AMQP conditions listener");
   }
 
-  private fetchConditions() {
+  private fetchConditions(url: string = this._apiUrl) {
     axios
-      .get(this._apiUrl)
+      .get(url)
       .then((resp) => {
         // parse to weather object
         const weather = new Weather(resp.data);