diff --git a/weather/local_alerts.js b/weather/local_alerts.js index 548e539..93eab16 100644 --- a/weather/local_alerts.js +++ b/weather/local_alerts.js @@ -4,6 +4,7 @@ const tornadoWatchEvents = ["Tornado Watch"] const severeThunderstormWatchEvents = ["Severe Thunderstorm Watch"] const area = msg.area const mqttTopic = "weather/alerts/" + area +const allTopic = mqttTopic + "/alerts" const tstormTopic = mqttTopic + "/severe_thunderstorm_warning" const tornadoWarnTopic = mqttTopic + "/tornado_warning" const tornadoWatchTopic = mqttTopic + "/tornado_watch" @@ -95,7 +96,8 @@ let severe_thunderstorm_watch = alerts.filter(function(alert) { // If there are any alerts, return them let allAlerts = { - "payload": msg.payload.features + "payload": msg.payload.features, + "topic": allTopic } let tstormMsg = {