From ec42d10f7b9747eaa19a8fb0e0c76f9d7455496a Mon Sep 17 00:00:00 2001
From: Sebastian Malton <sebastian@malton.name>
Date: Fri, 9 Dec 2022 11:48:40 -0500
Subject: [PATCH] Fix cluster state sync

Signed-off-by: Sebastian Malton <sebastian@malton.name>
---
 .../state-sync/main/setup-sync.injectable.ts  | 36 +++++++++++--------
 1 file changed, 22 insertions(+), 14 deletions(-)

diff --git a/src/features/cluster/state-sync/main/setup-sync.injectable.ts b/src/features/cluster/state-sync/main/setup-sync.injectable.ts
index bdff0e348f..9b0e13249d 100644
--- a/src/features/cluster/state-sync/main/setup-sync.injectable.ts
+++ b/src/features/cluster/state-sync/main/setup-sync.injectable.ts
@@ -3,33 +3,41 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 import { getInjectable } from "@ogre-tools/injectable";
-import { reaction } from "mobx";
+import { isEqual } from "lodash";
+import { autorun } from "mobx";
 import clusterStoreInjectable from "../../../../common/cluster-store/cluster-store.injectable";
+import type { ClusterId, ClusterState } from "../../../../common/cluster-types";
 import { beforeApplicationIsLoadingInjectionToken } from "../../../../main/start-main-application/runnable-tokens/before-application-is-loading-injection-token";
 import initClusterStoreInjectable from "../../store/main/init.injectable";
 import emitClusterStateUpdateInjectable from "./emit-update.injectable";
 
 const setupClusterStateBroadcastingInjectable = getInjectable({
   id: "setup-cluster-state-broadcasting",
-  instantiate: (di) => {
-    const emitClusterStateUpdate = di.inject(emitClusterStateUpdateInjectable);
-    const clusterStore = di.inject(clusterStoreInjectable);
+  instantiate: (di) => ({
+    id: "setup-cluster-state-broadcasting",
+    run: () => {
+      const emitClusterStateUpdate = di.inject(emitClusterStateUpdateInjectable);
+      const clusterStore = di.inject(clusterStoreInjectable);
+      const prevStates = new Map<ClusterId, ClusterState>();
+
+      autorun(() => {
+        for (const cluster of clusterStore.clusters.values()) {
+          const prevState = prevStates.get(cluster.id);
+          const curState = cluster.getState();
+
+          if (!prevState || !isEqual(prevState, curState)) {
+            prevStates.set(cluster.id, curState);
 
-    return {
-      id: "setup-cluster-state-broadcasting",
-      run: () => {
-        reaction(() => clusterStore.connectedClustersList, () => {
-          for (const cluster of clusterStore.clusters.values()) {
             emitClusterStateUpdate({
               clusterId: cluster.id,
               state: cluster.getState(),
             });
           }
-        });
-      },
-      runAfter: di.inject(initClusterStoreInjectable),
-    };
-  },
+        }
+      });
+    },
+    runAfter: di.inject(initClusterStoreInjectable),
+  }),
   injectionToken: beforeApplicationIsLoadingInjectionToken,
 });