From 7e516236f5e1c8c19f13dd112baa1a3f087dce0c Mon Sep 17 00:00:00 2001
From: forehalo <forehalo@gmail.com>
Date: Thu, 2 Nov 2023 18:24:00 +0800
Subject: [PATCH] fix(workspace): remove awareness states cache

---
 .../frontend/workspace/src/affine/index.ts    | 23 -------------------
 1 file changed, 23 deletions(-)

diff --git a/packages/frontend/workspace/src/affine/index.ts b/packages/frontend/workspace/src/affine/index.ts
index c5d5796d65..7cb2099e47 100644
--- a/packages/frontend/workspace/src/affine/index.ts
+++ b/packages/frontend/workspace/src/affine/index.ts
@@ -1,5 +1,4 @@
 import { DebugLogger } from '@affine/debug';
-import { isEqual } from 'lodash-es';
 import type { Socket } from 'socket.io-client';
 import { Manager } from 'socket.io-client';
 import {
@@ -191,23 +190,6 @@ function setupAffineAwareness(
   rootDoc: Doc,
   awareness: Awareness
 ) {
-  let lastAwarenessState: Map<number, any> = new Map();
-  // can't compare on update binary because the protocol will encode clock in it but the state is still the same
-  const compareAwarenessState = (clients: number[]) => {
-    const newAwarenessState = new Map();
-    clients.forEach(client => {
-      newAwarenessState.set(client, awareness.states.get(client));
-    });
-
-    const equal = isEqual(lastAwarenessState, newAwarenessState);
-
-    if (!equal) {
-      lastAwarenessState = newAwarenessState;
-    }
-
-    return equal;
-  };
-
   const awarenessBroadcast = ({
     workspaceId,
     awarenessUpdate,
@@ -235,11 +217,6 @@ function setupAffineAwareness(
       ...cur,
     ]);
 
-    // hit the last awareness update cache, skip
-    if (compareAwarenessState(changedClients)) {
-      return;
-    }
-
     const update = encodeAwarenessUpdate(awareness, changedClients);
     uint8ArrayToBase64(update)
       .then(encodedUpdate => {