|
@@ -429,7 +429,6 @@ class PageService {
|
|
|
|
|
|
|
|
try {
|
|
try {
|
|
|
await Page.bulkWrite(updatePathOperations);
|
|
await Page.bulkWrite(updatePathOperations);
|
|
|
- await PageRedirect.bulkWrite(insertPageRedirectOperations);
|
|
|
|
|
}
|
|
}
|
|
|
catch (err) {
|
|
catch (err) {
|
|
|
if (err.code !== 11000) {
|
|
if (err.code !== 11000) {
|
|
@@ -437,6 +436,15 @@ class PageService {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ try {
|
|
|
|
|
+ await PageRedirect.bulkWrite(insertPageRedirectOperations);
|
|
|
|
|
+ }
|
|
|
|
|
+ catch (err) {
|
|
|
|
|
+ if (err.code !== 11000) {
|
|
|
|
|
+ throw Error(`Failed to create PageRedirect documents: ${err}`);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
this.pageEvent.emit('updateMany', pages, user);
|
|
this.pageEvent.emit('updateMany', pages, user);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -474,7 +482,6 @@ class PageService {
|
|
|
|
|
|
|
|
try {
|
|
try {
|
|
|
await unorderedBulkOp.execute();
|
|
await unorderedBulkOp.execute();
|
|
|
- await PageRedirect.bulkWrite(insertPageRedirectOperations);
|
|
|
|
|
}
|
|
}
|
|
|
catch (err) {
|
|
catch (err) {
|
|
|
if (err.code !== 11000) {
|
|
if (err.code !== 11000) {
|
|
@@ -482,6 +489,15 @@ class PageService {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ try {
|
|
|
|
|
+ await PageRedirect.bulkWrite(insertPageRedirectOperations);
|
|
|
|
|
+ }
|
|
|
|
|
+ catch (err) {
|
|
|
|
|
+ if (err.code !== 11000) {
|
|
|
|
|
+ throw Error(`Failed to create PageRedirect documents: ${err}`);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
this.pageEvent.emit('updateMany', pages, user);
|
|
this.pageEvent.emit('updateMany', pages, user);
|
|
|
}
|
|
}
|
|
|
|
|
|