Просмотр исходного кода

add static function(deleteAllByPageActionType)

yohei0125 3 лет назад
Родитель
Сommit
53f80e533e
1 измененных файлов с 5 добавлено и 4 удалено
  1. 5 4
      packages/app/src/server/models/page-operation.ts

+ 5 - 4
packages/app/src/server/models/page-operation.ts

@@ -52,6 +52,7 @@ export type PageOperationDocumentHasId = PageOperationDocument & { _id: ObjectId
 export interface PageOperationModel extends Model<PageOperationDocument> {
 export interface PageOperationModel extends Model<PageOperationDocument> {
   findByIdAndUpdatePageActionStage(pageOpId: ObjectIdLike, stage: PageActionStage): Promise<PageOperationDocumentHasId | null>
   findByIdAndUpdatePageActionStage(pageOpId: ObjectIdLike, stage: PageActionStage): Promise<PageOperationDocumentHasId | null>
   findMainOps(filter?: FilterQuery<PageOperationDocument>, projection?: any, options?: QueryOptions): Promise<PageOperationDocumentHasId[]>
   findMainOps(filter?: FilterQuery<PageOperationDocument>, projection?: any, options?: QueryOptions): Promise<PageOperationDocumentHasId[]>
+  deleteAllByPageActionType(deleteTypeList: PageActionType[]): Promise<void>
 }
 }
 
 
 const pageSchemaForResuming = new Schema<IPageForResuming>({
 const pageSchemaForResuming = new Schema<IPageForResuming>({
@@ -120,11 +121,11 @@ schema.statics.findMainOps = async function(
   );
   );
 };
 };
 
 
-schema.statics.clearAll = async function(
-    typesToExclude: PageActionType[],
+schema.statics.deleteAllByPageActionType = async function(
+    deleteTypeList: PageActionType[],
 ): Promise<void> {
 ): Promise<void> {
-  await this.deleteMany({ actionType: { $nin: typesToExclude } });
-  logger.info(`Deleted all PageOperation documents except actionType: ${typesToExclude}`);
+  await this.deleteMany({ actionType: { $in: deleteTypeList } });
+  logger.info(`Deleted all PageOperation documents except actionType: ${deleteTypeList}`);
 };
 };
 
 
 export default getOrCreateModel<PageOperationDocument, PageOperationModel>('PageOperation', schema);
 export default getOrCreateModel<PageOperationDocument, PageOperationModel>('PageOperation', schema);