luulam/AFFiNE
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

feat: block remove event

Browse Source
This commit is contained in:
DarkSky
2022-08-08 18:39:30 +08:00
parent 4f0232cbbf
commit eb2ad57c5a
1 changed files with 24 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
libs/datasource/jwt/src/block/abstract.ts
View File

@@ -19,8 +19,8 @@ declare const JWT_DEV: boolean;
const logger = getLogger('BlockDB:block'); const logger = getLogger('BlockDB:block');
const logger_debug = getLogger('debug:BlockDB:block'); const logger_debug = getLogger('debug:BlockDB:block');
const GET_BLOCK = Symbol('GET_BLOCK'); const _GET_BLOCK = Symbol('GET_BLOCK');
const SET_PARENT = Symbol('SET_PARENT'); const _SET_PARENT = Symbol('SET_PARENT');
export class AbstractBlock< export class AbstractBlock<
B extends BlockInstance<C>, B extends BlockInstance<C>,
@@ -47,6 +47,13 @@ export class AbstractBlock<
this._parentListener = new Map(); this._parentListener = new Map();
this._parent = parent; this._parent = parent;
JWT_DEV && logger_debug(`init: exists ${this._id}`); JWT_DEV && logger_debug(`init: exists ${this._id}`);
if (parent) {
parent.addChildrenListener(this._id, states => {
if (states.get(this._id) === 'delete') {
this._emitParent(parent._id, 'delete');
}
});
}
} }
public get root() { public get root() {
@@ -176,18 +183,27 @@ export class AbstractBlock<
return this.#block.creator; return this.#block.creator;
} }
[GET_BLOCK]() { [_GET_BLOCK]() {
return this.#block; return this.#block;
} }
[SET_PARENT](parent: AbstractBlock<B, C>) { private _emitParent(
this._parent = parent; parentId: string,
const states: Map<string, 'update'> = new Map([[parent.id, 'update']]); type: 'update' | 'delete' = 'update'
) {
const states: Map<string, 'update' | 'delete'> = new Map([
[parentId, type],
]);
for (const listener of this._parentListener.values()) { for (const listener of this._parentListener.values()) {
listener(states); listener(states);
} }
} }
[_SET_PARENT](parent: AbstractBlock<B, C>) {
this._parent = parent;
this._emitParent(parent.id);
}
/** /**
* Get document index tags * Get document index tags
*/ */
@@ -258,8 +274,8 @@ export class AbstractBlock<
throw new Error('insertChildren: binary not allow insert children'); throw new Error('insertChildren: binary not allow insert children');
} }
this.#block.insertChildren(block[GET_BLOCK](), position); this.#block.insertChildren(block[_GET_BLOCK](), position);
block[SET_PARENT](this); block[_SET_PARENT](this);
} }
public hasChildren(id: string): boolean { public hasChildren(id: string): boolean {