diff --git a/packages/backend/server/src/utils/doc.ts b/packages/backend/server/src/utils/doc.ts index 1cb275596d..1754d280a6 100644 --- a/packages/backend/server/src/utils/doc.ts +++ b/packages/backend/server/src/utils/doc.ts @@ -2,6 +2,7 @@ import { registerEnumType } from '@nestjs/graphql'; export enum DocVariant { Workspace = 'workspace', + Page = 'page', Space = 'space', Settings = 'settings', Unknown = 'unknown', 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 = 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 => {