From c94bcb6896375fedc4debfc5bccbb05733d7fe83 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Joakim=20S=C3=B8rensen?= Date: Fri, 26 Feb 2021 13:47:48 +0100 Subject: [PATCH] Subscribe to message instead of event (#8443) --- src/data/supervisor/supervisor.ts | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/src/data/supervisor/supervisor.ts b/src/data/supervisor/supervisor.ts index 1dbaecef2c..c884c79e0a 100644 --- a/src/data/supervisor/supervisor.ts +++ b/src/data/supervisor/supervisor.ts @@ -75,15 +75,11 @@ async function processEvent( event: SupervisorEvent, key: string ) { - if ( - !event.data || - event.data.event !== "supervisor-update" || - event.data.update_key !== key - ) { + if (event.event !== "supervisor-update" || event.update_key !== key) { return; } - if (Object.keys(event.data.data).length === 0) { + if (Object.keys(event.data).length === 0) { const data = await supervisorApiWsRequest(conn, { endpoint: supervisorStore[key], }); @@ -98,7 +94,7 @@ async function processEvent( store.setState({ ...state, - ...event.data.data, + ...event.data, }); } @@ -107,9 +103,11 @@ const subscribeSupervisorEventUpdates = ( store: Store, key: string ) => - conn.subscribeEvents( + conn.subscribeMessage( (event) => processEvent(conn, store, event as SupervisorEvent, key), - "supervisor_event" + { + type: "supervisor/subscribe", + } ); export const getSupervisorEventCollection = (