diff --git a/packages/data-center/src/provider/affine/affine.ts b/packages/data-center/src/provider/affine/affine.ts index acc1ce0cfb..1b69259258 100644 --- a/packages/data-center/src/provider/affine/affine.ts +++ b/packages/data-center/src/provider/affine/affine.ts @@ -19,6 +19,12 @@ import { token } from './apis/token.js'; import { WebsocketClient } from './channel'; import { SyncMode } from '../../workspace-unit'; +type ChannelMessage = { + ws_list: Workspace[]; + ws_details: Record; + metadata: Record; +}; + export interface AffineProviderConstructorParams extends ProviderConstructorParams { apis?: Apis; @@ -88,17 +94,12 @@ export class AffineProvider extends BaseProvider { } ); } - this._channel.on('message', this.handlerAffineListMessage); + this._channel.on('message', (msg: ChannelMessage) => { + this.handlerAffineListMessage(msg); + }); } - private handlerAffineListMessage({ - ws_details, - metadata, - }: { - ws_list: Workspace[]; - ws_details: Record; - metadata: Record; - }) { + private handlerAffineListMessage({ ws_details, metadata }: ChannelMessage) { this._logger('receive server message'); Object.entries(ws_details).forEach(([id, detail]) => { const { name, avatar } = metadata[id];