Jayden/AFFiNE-Mirror
1
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-02-14 13:25:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(workspace): remove awareness states cache

Browse Source
This commit is contained in:
forehalo
2023-11-02 18:24:00 +08:00
parent 15024c6c8a
commit 7e516236f5
1 changed files with 0 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
packages/frontend/workspace/src/affine/index.ts
View File

@@ -1,5 +1,4 @@
import { DebugLogger } from '@affine/debug'; import { DebugLogger } from '@affine/debug';
import { isEqual } from 'lodash-es';
import type { Socket } from 'socket.io-client'; import type { Socket } from 'socket.io-client';
import { Manager } from 'socket.io-client'; import { Manager } from 'socket.io-client';
import { import {
@@ -191,23 +190,6 @@ function setupAffineAwareness(
rootDoc: Doc, rootDoc: Doc,
awareness: Awareness 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 = ({ const awarenessBroadcast = ({
workspaceId, workspaceId,
awarenessUpdate, awarenessUpdate,
@@ -235,11 +217,6 @@ function setupAffineAwareness(
...cur, ...cur,
]); ]);
// hit the last awareness update cache, skip
if (compareAwarenessState(changedClients)) {
return;
}
const update = encodeAwarenessUpdate(awareness, changedClients); const update = encodeAwarenessUpdate(awareness, changedClients);
uint8ArrayToBase64(update) uint8ArrayToBase64(update)
.then(encodedUpdate => { .then(encodedUpdate => {