Browse Source

adjust method

yusuketk 7 years ago
parent
commit
cbde5a65f3
1 changed files with 12 additions and 14 deletions
  1. 12 14
      src/server/models/page-tag-relation.js

+ 12 - 14
src/server/models/page-tag-relation.js

@@ -35,21 +35,19 @@ class PageTagRelation {
    * remove all invalid relations that has reference to unlinked document
    * remove all invalid relations that has reference to unlinked document
    */
    */
   static removeAllInvalidRelations() {
   static removeAllInvalidRelations() {
-    return this.find()
-      .then(relations => {
-        // filter invalid documents
-        return relations.filter(relation => {
-          return relation.relatedTag == null || relation.relatedPage == null;
-        });
-      })
-      .then(invalidRelations => {
-        const ids = invalidRelations.map(relation => relation._id);
-        return this.deleteMany({
-          _id: {
-            $in: ids
-          }
-        });
+    const self = this;
+    self.find(function(err, relations) {
+      // filter invalid documents
+      const invalidRelations = relations.filter(function(relation) {
+        return relation.relatedTag == null || relation.relatedPage == null;
       });
       });
+      const ids = invalidRelations.map(relation => relation._id);
+      self.deleteMany({
+        _id: {
+          $in: ids
+        }
+      });
+    });
   }
   }
 }
 }