|
|
@@ -1354,19 +1354,21 @@ class PageService {
|
|
|
// TODO: resume
|
|
|
if (isRecursively) {
|
|
|
// no await for deleteCompletelyDescendantsWithStream
|
|
|
- (async() => {
|
|
|
- const deletedDescendantCount = await this.deleteCompletelyDescendantsWithStream(page, user, options, shouldUseV4Process);
|
|
|
-
|
|
|
- // update descendantCount of ancestors'
|
|
|
- if (page.parent != null) {
|
|
|
- await this.updateDescendantCountOfAncestors(page.parent, (deletedDescendantCount + 1) * -1, true);
|
|
|
- }
|
|
|
- })();
|
|
|
+ this.resumableDeleteCompletelyDescendants(page, user, options, shouldUseV4Process);
|
|
|
}
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
+ async resumableDeleteCompletelyDescendants(page, user, options, shouldUseV4Process) {
|
|
|
+ const deletedDescendantCount = await this.deleteCompletelyDescendantsWithStream(page, user, options, shouldUseV4Process);
|
|
|
+
|
|
|
+ // update descendantCount of ancestors'
|
|
|
+ if (page.parent != null) {
|
|
|
+ await this.updateDescendantCountOfAncestors(page.parent, (deletedDescendantCount + 1) * -1, true);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
private async deleteCompletelyV4(page, user, options = {}, isRecursively = false, preventEmitting = false) {
|
|
|
const ids = [page._id];
|
|
|
const paths = [page.path];
|