clean

packages/app/src/server/models/page.js

@@ -419,18 +419,6 @@ module.exports = function(crowi) {
     return saved;
   };
 
-  pageSchema.statics.getPageIdToSeenUsersCount = async function(pageIds) {
-    const results = await this.aggregate()
-      .match({ _id: { $in: pageIds } });
-
-    const idToCountMap = {};
-    results.forEach((result) => {
-      idToCountMap[result.seenUsers] = result.seenUsers.length;
-    });
-
-    return idToCountMap;
-  };
-
   pageSchema.methods.updateSlackChannels = function(slackChannels) {
     this.slackChannels = slackChannels;
 

packages/app/src/server/service/search-delegator/elasticsearch.js

@@ -454,23 +454,6 @@ class ElasticsearchDelegator {
       },
     });
 
-    const appendSeenUsersCountStream = new Transform({
-      objectMode: true,
-      async transform(chunk, encoding, callback) {
-        const pageIds = chunk.map(doc => doc._id);
-
-        const idToSeenUsersCountMap = await Page.getPageIdToSeenUsersCount(pageIds);
-        const idsHavingCount = Object.keys(idToSeenUsersCountMap);
-        chunk
-          .filter(doc => idsHavingCount.includes(doc._id.toString()))
-          .forEach((doc) => {
-            doc.seenUsers = idToSeenUsersCountMap[doc._id.toString()];
-          });
-        this.push(chunk);
-        callback();
-      },
-    });
-
     let count = 0;
     const writeStream = new Writable({
       objectMode: true,
@@ -523,7 +506,6 @@ class ElasticsearchDelegator {
       .pipe(batchStream)
       .pipe(appendBookmarkCountStream)
       .pipe(appendTagNamesStream)
-      .pipe(appendSeenUsersCountStream)
       .pipe(writeStream);
 
     return streamToPromise(writeStream);