toeverything/AFFiNE
1
1
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2024-11-30 05:13:06 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'feat/cloud-sync-saika' into feat/datacenter-dev

Browse Source
This commit is contained in:
DiamondThree 2023-01-11 22:56:18 +08:00
commit d979acbba7
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
packages/data-center/src/provider/affine/affine.ts
View File

@ -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<string, WorkspaceDetail>;
metadata: Record<string, { avatar: string; name: string }>;
};
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<string, WorkspaceDetail>;
metadata: Record<string, { avatar: string; name: string }>;
}) {
private handlerAffineListMessage({ ws_details, metadata }: ChannelMessage) {
this._logger('receive server message');
Object.entries(ws_details).forEach(([id, detail]) => {
const { name, avatar } = metadata[id];