Skip to content

Commit 46f9af4

Browse files
authored
Fix events (#3)
* Fix events
1 parent 96436eb commit 46f9af4

File tree

2 files changed

+10
-8
lines changed

2 files changed

+10
-8
lines changed

custom_components/mass_queue/const.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,4 +27,5 @@
2727
DEFAULT_QUEUE_ITEMS_LIMIT = 500
2828
DEFAULT_QUEUE_ITEMS_OFFSET = -1
2929

30-
EVENT_DOMAIN = "mass_queue"
30+
MUSIC_ASSISTANT_EVENT_DOMAIN = "mass_music_assistant"
31+
MASS_QUEUE_EVENT_DOMAIN = "mass_queue"

custom_components/mass_queue/controller.py

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,8 @@
99
DEFAULT_QUEUE_ITEMS_LIMIT,
1010
DEFAULT_QUEUE_ITEMS_OFFSET,
1111
LOGGER,
12-
EVENT_DOMAIN,
12+
MUSIC_ASSISTANT_EVENT_DOMAIN,
13+
MASS_QUEUE_EVENT_DOMAIN
1314
)
1415
from .utils import (
1516
get_queue_id_from_player_data,
@@ -31,8 +32,8 @@ def subscribe_events(self):
3132
return
3233

3334
def send_ha_event(self, event_data):
34-
LOGGER.debug(f'Sending event type {EVENT_DOMAIN}, data {event_data}')
35-
self._hass.bus.async_fire(EVENT_DOMAIN, event_data)
35+
LOGGER.debug(f'Sending event type {MUSIC_ASSISTANT_EVENT_DOMAIN}, data {event_data}')
36+
self._hass.bus.async_fire(MUSIC_ASSISTANT_EVENT_DOMAIN, event_data)
3637
return
3738

3839
def on_queue_update_event(self, event):
@@ -229,8 +230,8 @@ def update(self, player_id: str, queue_id: str):
229230
}
230231
self.send_ha_event(event_data)
231232
def send_ha_event(self, event_data):
232-
LOGGER.debug(f'Sending event type {EVENT_DOMAIN}, data {event_data}')
233-
self._hass.bus.async_fire(EVENT_DOMAIN, event_data)
233+
LOGGER.debug(f'Sending event type {MASS_QUEUE_EVENT_DOMAIN}, data {event_data}')
234+
self._hass.bus.async_fire(MASS_QUEUE_EVENT_DOMAIN, event_data)
234235
return
235236

236237
class Queues():
@@ -282,6 +283,6 @@ def remove(self, queue_id):
282283
self.send_ha_event(event_data)
283284

284285
def send_ha_event(self, event_data):
285-
LOGGER.debug(f'Sending event type {EVENT_DOMAIN}, data {event_data}')
286-
self._hass.bus.async_fire(EVENT_DOMAIN, event_data)
286+
LOGGER.debug(f'Sending event type {MASS_QUEUE_EVENT_DOMAIN}, data {event_data}')
287+
self._hass.bus.async_fire(MASS_QUEUE_EVENT_DOMAIN, event_data)
287288
return

0 commit comments

Comments
 (0)