toeverything/AFFiNE
1
1
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2024-12-28 12:32:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

feat: add a time out

Browse Source
This commit is contained in:
MingLiang Wang 2023-01-10 21:35:22 +08:00
parent 7e60b750d1
commit 412d5205c8
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -16,6 +16,7 @@ import { getApis } from './apis/index.js';
import type { Apis, WorkspaceDetail, Callback } from './apis';
import { setDefaultAvatar } from '../utils.js';
import { MessageCode } from '../../message';
import { blob } from 'stream/consumers';
export interface AffineProviderConstructorParams
extends ProviderConstructorParams {
@ -348,9 +349,10 @@ export class AffineProvider extends BaseProvider {
assert(to.room, 'Blocksuite Workspace without room(workspaceId).');
const ws = this._getWebsocketProvider(to);
applyUpdate(to.doc, encodeStateAsUpdate(from.doc));
// TODO: upload blobs and make sure doc is synced
await new Promise<void>((resolve, reject) => {
ws.once('synced', () => {
resolve();
setTimeout(() => resolve(), 1000);
});
ws.once('lost-connection', () => reject());
ws.once('connection-error', () => reject());