Jayden/AFFiNE-Mirror
1
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-02-19 15:26:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): fix journal missing after refresh (#6022)

Browse Source
This commit is contained in:
EYHN
2024-03-05 11:42:09 +00:00
parent c1afdb9bd6
commit 5d8dea084c
2 changed files with 21 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
packages/common/infra/src/workspace/engine/sync/engine.ts
View File

@@ -1,8 +1,10 @@
import { DebugLogger } from '@affine/debug';
import { Slot } from '@blocksuite/global/utils';
import { Observable } from 'rxjs';
import type { Doc } from 'yjs';
import { createIdentifier } from '../../../di';
import { LiveData } from '../../../livedata';
import { SharedPriorityTarget } from '../../../utils/async-queue';
import { MANUALLY_STOP, throwIfAborted } from '../../../utils/throw-if-aborted';
import { SyncEngineStep, SyncPeerStep } from './consts';
@@ -65,6 +67,21 @@ export class SyncEngine {
this._status = s;
this.onStatusChange.emit(s);
}
isRootDocLoaded = LiveData.from(
new Observable(observer => {
observer.next(
this.status.local
? this.status.local.step > SyncPeerStep.LoadingRootDoc
: false
);
this.onStatusChange.on(status => {
observer.next(
status.local ? status.local.step > SyncPeerStep.LoadingRootDoc : false
);
});
}),
false
);
priorityTarget = new SharedPriorityTarget();