weseek__growi/apps/app/src/server/models/obsolete-page.js

import { GroupType, Origin } from '@growi/core';
import {
  pagePathUtils,
  pathUtils,
  templateChecker,
} from '@growi/core/dist/utils';
import { isUserPage } from '@growi/core/dist/utils/page-path-utils';
import { removeHeadingSlash } from '@growi/core/dist/utils/path-utils';
import { differenceInYears } from 'date-fns/differenceInYears';
import escapeStringRegexp from 'escape-string-regexp';

import { Comment } from '~/features/comment/server/models/comment';
import ExternalUserGroup from '~/features/external-user-group/server/models/external-user-group';
import ExternalUserGroupRelation from '~/features/external-user-group/server/models/external-user-group-relation';
import loggerFactory from '~/utils/logger';

import { configManager } from '../service/config-manager';
import { USER_FIELDS_EXCEPT_CONFIDENTIAL } from './user/conts';
import UserGroup from './user-group';
import UserGroupRelation from './user-group-relation';

const logger = loggerFactory('growi:models:page');

const nodePath = require('path');

const mongoose = require('mongoose');
const urljoin = require('url-join');

const { isTopPage, isTrashPage } = pagePathUtils;
const { checkTemplatePath } = templateChecker;

const GRANT_PUBLIC = 1;
const GRANT_RESTRICTED = 2;
const GRANT_SPECIFIED = 3;
const GRANT_OWNER = 4;
const GRANT_USER_GROUP = 5;
const PAGE_GRANT_ERROR = 1;
const STATUS_PUBLISHED = 'published';
const STATUS_DELETED = 'deleted';

// schema definition has moved to page.ts
const pageSchema = {
  statics: {},
  methods: {},
};

/**
 * return an array of ancestors paths that is extracted from specified pagePath
 * e.g.
 *  when `pagePath` is `/foo/bar/baz`,
 *  this method returns [`/foo/bar/baz`, `/foo/bar`, `/foo`, `/`]
 *
 * @param {string} pagePath
 * @return {string[]} ancestors paths
 */
export const extractToAncestorsPaths = (pagePath) => {
  const ancestorsPaths = [];

  let parentPath;
  while (parentPath !== '/') {
    parentPath = nodePath.dirname(parentPath || pagePath);
    ancestorsPaths.push(parentPath);
  }

  return ancestorsPaths;
};

/**
 * populate page (Query or Document) to show revision
 * @param {any} page Query or Document
 * @param {string} userPublicFields string to set to select
 * @param {boolean} shouldExcludeBody boolean indicating whether to include 'revision.body' or not
 */
export const populateDataToShowRevision = (
  page,
  userPublicFields,
  shouldExcludeBody = false,
) => {
  // biome-ignore lint/plugin: populating is the purpose of this method
  return page.populate([
    { path: 'lastUpdateUser', select: userPublicFields },
    { path: 'creator', select: userPublicFields },
    { path: 'deleteUser', select: userPublicFields },
    { path: 'grantedGroups.item' },
    {
      path: 'revision',
      select: shouldExcludeBody ? '-body' : undefined,
      populate: {
        path: 'author',
        select: userPublicFields,
      },
    },
  ]);
};

/** @param {import('~/server/crowi').default | null} crowi Crowi instance */
export const getPageSchema = (crowi) => {
  let pageEvent;

  // init event
  if (crowi != null) {
    pageEvent = crowi.events.page;
    pageEvent.on('create', pageEvent.onCreate);
    pageEvent.on('update', pageEvent.onUpdate);
    pageEvent.on('createMany', pageEvent.onCreateMany);
    pageEvent.on('addSeenUsers', pageEvent.onAddSeenUsers);
  }

  function validateCrowi() {
    if (crowi == null) {
      throw new Error(
        '"crowi" is null. Init User model with "crowi" argument first.',
      );
    }
  }

  pageSchema.methods.isDeleted = function () {
    return isTrashPage(this.path);
  };

  pageSchema.methods.isPublic = function () {
    if (!this.grant || this.grant === GRANT_PUBLIC) {
      return true;
    }

    return false;
  };

  pageSchema.methods.isTopPage = function () {
    return isTopPage(this.path);
  };

  pageSchema.methods.isTemplate = function () {
    return checkTemplatePath(this.path);
  };

  pageSchema.methods.isLatestRevision = function () {
    // populate されていなくて判断できない
    if (!this.latestRevision || !this.revision) {
      return true;
    }

    // comparing ObjectId with string
    // biome-ignore lint/suspicious/noDoubleEquals: ignore
    return this.latestRevision == this.revision._id.toString();
  };

  pageSchema.methods.findRelatedTagsById = async function () {
    const PageTagRelation = mongoose.model('PageTagRelation');
    // biome-ignore lint/plugin: allow populate for backward compatibility
    const relations = await PageTagRelation.find({
      relatedPage: this._id,
    }).populate('relatedTag');
    return relations.map((relation) => {
      return relation.relatedTag.name;
    });
  };

  pageSchema.methods.isUpdatable = async function (previousRevision, origin) {
    // biome-ignore lint/plugin: allow populate for backward compatibility
    const populatedPageDataWithRevisionOrigin = await this.populate(
      'revision',
      'origin',
    );
    const latestRevisionOrigin =
      populatedPageDataWithRevisionOrigin.revision.origin;
    const ignoreLatestRevision =
      origin === Origin.Editor &&
      (latestRevisionOrigin === Origin.Editor ||
        latestRevisionOrigin === Origin.View);
    if (ignoreLatestRevision) {
      return true;
    }

    const revision = this.latestRevision || this.revision._id;
    // comparing ObjectId with string
    // biome-ignore lint/suspicious/noDoubleEquals: ignore
    if (revision != previousRevision) {
      return false;
    }
    return true;
  };

  pageSchema.methods.isLiked = function (user) {
    if (user == null || user._id == null) {
      return false;
    }

    return this.liker.some((likedUserId) => {
      return likedUserId.toString() === user._id.toString();
    });
  };

  pageSchema.methods.like = function (userData) {
    return new Promise((resolve, reject) => {
      const added = this.liker.addToSet(userData._id);
      if (added.length > 0) {
        this.save((err, data) => {
          if (err) {
            return reject(err);
          }
          logger.debug('liker updated!', added);
          return resolve(data);
        });
      } else {
        logger.debug('liker not updated');
        return reject(new Error('Already liked'));
      }
    });
  };

  pageSchema.methods.unlike = function (userData, callback) {
    return new Promise((resolve, reject) => {
      const beforeCount = this.liker.length;
      this.liker.pull(userData._id);
      if (this.liker.length !== beforeCount) {
        this.save((err, data) => {
          if (err) {
            return reject(err);
          }
          return resolve(data);
        });
      } else {
        logger.debug('liker not updated');
        return reject(new Error('Already unliked'));
      }
    });
  };

  pageSchema.methods.isSeenUser = function (userData) {
    return this.seenUsers.includes(userData._id);
  };

  pageSchema.methods.seen = async function (userData) {
    if (this.isSeenUser(userData)) {
      logger.debug('seenUsers not updated');
      return this;
    }

    if (!userData || !userData._id) {
      throw new Error('User data is not valid');
    }

    const added = this.seenUsers.addToSet(userData._id);
    const saved = await this.save();

    logger.debug('seenUsers updated!', added);
    pageEvent.emit('addSeenUsers', saved);

    return saved;
  };

  pageSchema.methods.updateSlackChannels = function (slackChannels) {
    this.slackChannels = slackChannels;

    return this.save();
  };

  pageSchema.methods.initLatestRevisionField = function (revisionId) {
    this.latestRevision = this.revision;
    if (revisionId != null) {
      this.revision = revisionId;
    }
  };

  pageSchema.methods.populateDataToShowRevision = async function (
    shouldExcludeBody,
  ) {
    validateCrowi();

    return await populateDataToShowRevision(
      this,
      USER_FIELDS_EXCEPT_CONFIDENTIAL,
      shouldExcludeBody,
    );
  };

  pageSchema.methods.populateDataToMakePresentation = async function (
    revisionId,
  ) {
    this.latestRevision = this.revision;
    if (revisionId != null) {
      this.revision = revisionId;
    }
    // biome-ignore lint/plugin: populating is the purpose of this method
    return await this.populate('revision');
  };

  pageSchema.methods.applyScope = function (user, grant, grantUserGroupIds) {
    // Reset
    this.grantedUsers = [];
    this.grantedGroups = [];

    this.grant = grant || GRANT_PUBLIC;

    if (grant === GRANT_OWNER) {
      this.grantedUsers.push(user?._id ?? user);
    }

    if (grant === GRANT_USER_GROUP) {
      this.grantedGroups = grantUserGroupIds;
    }
  };

  pageSchema.methods.getContentAge = function () {
    return differenceInYears(new Date(), this.updatedAt);
  };

  pageSchema.statics.updateCommentCount = function (pageId) {
    validateCrowi();
    return Comment.countCommentByPageId(pageId).then((count) => {
      this.update({ _id: pageId }, { commentCount: count }, {}, (err, data) => {
        if (err) {
          logger.debug('Update commentCount Error', err);
          throw err;
        }

        return data;
      });
    });
  };

  pageSchema.statics.getDeletedPageName = (path) => {
    return `/trash/${removeHeadingSlash(path)}`;
  };

  pageSchema.statics.getRevertDeletedPageName = (path) =>
    path.replace('/trash', '');

  pageSchema.statics.fixToCreatableName = (path) => path.replace(/\/\//g, '/');

  pageSchema.statics.updateRevision = function (pageId, revisionId, cb) {
    this.update({ _id: pageId }, { revision: revisionId }, {}, (err, data) => {
      cb(err, data);
    });
  };

  /**
   * return whether the user is accessible to the page
   * @param {string} id ObjectId
   * @param {User} user
   */
  pageSchema.statics.isAccessiblePageByViewer = async function (id, user) {
    const baseQuery = this.findOne({ _id: id }).select('path');

    const userGroups =
      user != null
        ? [
            ...(await UserGroupRelation.findAllUserGroupIdsRelatedToUser(user)),
            ...(await ExternalUserGroupRelation.findAllUserGroupIdsRelatedToUser(
              user,
            )),
          ]
        : [];

    const queryBuilder = new this.PageQueryBuilder(baseQuery);
    queryBuilder.addConditionToFilteringByViewer(user, userGroups, true);

    const page = await queryBuilder.query.exec();

    if (!page) {
      return false;
    }

    const disabledUserPages = configManager.getConfig(
      'security:disableUserPages',
    );

    if (disabledUserPages && isUserPage(page.path)) {
      return false;
    }

    return true;
  };

  // find page by path
  pageSchema.statics.findByPath = function (path, includeEmpty = false) {
    if (path == null) {
      return null;
    }

    const builder = new this.PageQueryBuilder(
      this.findOne({ path }),
      includeEmpty,
    );

    return builder.query.exec();
  };

  /**
   * @param {string} path Page path
   * @param {User} user User instance
   * @param {UserGroup[]} userGroups List of UserGroup instances
   */
  pageSchema.statics.findAncestorByPathAndViewer = async function (
    path,
    user,
    userGroups,
    includeEmpty = false,
  ) {
    if (path == null) {
      throw new Error('path is required.');
    }

    if (path === '/') {
      return null;
    }

    const ancestorsPaths = extractToAncestorsPaths(path);

    // pick the longest one
    const baseQuery = this.findOne({ path: { $in: ancestorsPaths } }).sort({
      path: -1,
    });

    const relatedUserGroups =
      user != null && userGroups == null
        ? [
            ...(await UserGroupRelation.findAllUserGroupIdsRelatedToUser(user)),
            ...(await ExternalUserGroupRelation.findAllUserGroupIdsRelatedToUser(
              user,
            )),
          ]
        : userGroups;

    const queryBuilder = new this.PageQueryBuilder(baseQuery, includeEmpty);
    queryBuilder.addConditionToFilteringByViewer(user, relatedUserGroups);

    return queryBuilder.query.exec();
  };

  /**
   * find pages that is match with `path` and its descendants
   */
  pageSchema.statics.findListWithDescendants = async function (
    path,
    user,
    option = {},
    includeEmpty = false,
  ) {
    const builder = new this.PageQueryBuilder(this.find(), includeEmpty);

    if (option.disableUserPages) {
      builder.addConditionToListByNotMatchPathAndChildren('/user');
    }

    builder.addConditionToListWithDescendants(path, option);

    return findListFromBuilderAndViewer(builder, user, false, option);
  };

  /**
   * find pages that is match with `path` and its descendants which user is able to manage
   */
  pageSchema.statics.findManageableListWithDescendants = async function (
    page,
    user,
    option = {},
    includeEmpty = false,
  ) {
    if (user == null) {
      return null;
    }

    const builder = new this.PageQueryBuilder(this.find(), includeEmpty);
    builder.addConditionToListWithDescendants(page.path, option);

    // add grant conditions
    await addConditionToFilteringByViewerToEdit(builder, user);

    const { pages } = await findListFromBuilderAndViewer(
      builder,
      user,
      false,
      option,
    );

    // add page if 'grant' is GRANT_RESTRICTED
    // because addConditionToListWithDescendants excludes GRANT_RESTRICTED pages
    if (page.grant === GRANT_RESTRICTED) {
      pages.push(page);
    }

    return pages;
  };

  /**
   * find pages that start with `path`
   */
  pageSchema.statics.findListByStartWith = async function (
    path,
    user,
    option,
    includeEmpty = false,
  ) {
    const builder = new this.PageQueryBuilder(this.find(), includeEmpty);
    builder.addConditionToListByStartWith(path, option);

    return findListFromBuilderAndViewer(builder, user, false, option);
  };

  /**
   * find pages that is created by targetUser
   *
   * @param {User} targetUser
   * @param {User} currentUser
   * @param {any} option
   */
  pageSchema.statics.findListByCreator = async function (
    targetUser,
    currentUser,
    option,
  ) {
    const opt = Object.assign({ sort: 'createdAt', desc: -1 }, option);
    const builder = new this.PageQueryBuilder(
      this.find({ creator: targetUser._id }),
    );

    let showAnyoneKnowsLink = null;
    if (targetUser != null && currentUser != null) {
      showAnyoneKnowsLink = targetUser._id.equals(currentUser._id);
    }

    return await findListFromBuilderAndViewer(
      builder,
      currentUser,
      showAnyoneKnowsLink,
      opt,
    );
  };

  /**
   * find pages by PageQueryBuilder
   * @param {PageQueryBuilder} builder
   * @param {User} user
   * @param {boolean} showAnyoneKnowsLink
   * @param {any} option
   */
  async function findListFromBuilderAndViewer(
    builder,
    user,
    showAnyoneKnowsLink,
    option,
  ) {
    validateCrowi();

    const opt = Object.assign({ sort: 'updatedAt', desc: -1 }, option);
    const sortOpt = {};
    sortOpt[opt.sort] = opt.desc;

    // exclude trashed pages
    if (!opt.includeTrashed) {
      builder.addConditionToExcludeTrashed();
    }

    // add grant conditions
    await addConditionToFilteringByViewerForList(
      builder,
      user,
      showAnyoneKnowsLink,
    );

    // count
    const totalCount = await builder.query.exec('count');

    // find
    builder.addConditionToPagenate(opt.offset, opt.limit, sortOpt);
    builder.populateDataToList(USER_FIELDS_EXCEPT_CONFIDENTIAL);
    const pages = await builder.query.lean().clone().exec('find');
    const result = {
      pages,
      totalCount,
      offset: opt.offset,
      limit: opt.limit,
    };
    return result;
  }

  /**
   * Add condition that filter pages by viewer
   *  by considering Config
   *
   * @param {PageQueryBuilder} builder
   * @param {User} user
   * @param {boolean} showAnyoneKnowsLink
   */
  async function addConditionToFilteringByViewerForList(
    builder,
    user,
    showAnyoneKnowsLink,
  ) {
    validateCrowi();

    // determine User condition
    const hidePagesRestrictedByOwner = configManager.getConfig(
      'security:list-policy:hideRestrictedByOwner',
    );
    const hidePagesRestrictedByGroup = configManager.getConfig(
      'security:list-policy:hideRestrictedByGroup',
    );

    // determine UserGroup condition
    const userGroups =
      user != null
        ? [
            ...(await UserGroupRelation.findAllUserGroupIdsRelatedToUser(user)),
            ...(await ExternalUserGroupRelation.findAllUserGroupIdsRelatedToUser(
              user,
            )),
          ]
        : null;

    return builder.addConditionToFilteringByViewer(
      user,
      userGroups,
      showAnyoneKnowsLink,
      !hidePagesRestrictedByOwner,
      !hidePagesRestrictedByGroup,
    );
  }

  /**
   * Add condition that filter pages by viewer
   *  by considering Config
   *
   * @param {PageQueryBuilder} builder
   * @param {User} user
   * @param {boolean} showAnyoneKnowsLink
   */
  async function addConditionToFilteringByViewerToEdit(builder, user) {
    // determine UserGroup condition
    const userGroups =
      user != null
        ? [
            ...(await UserGroupRelation.findAllUserGroupIdsRelatedToUser(user)),
            ...(await ExternalUserGroupRelation.findAllUserGroupIdsRelatedToUser(
              user,
            )),
          ]
        : null;

    return builder.addConditionToFilteringByViewer(
      user,
      userGroups,
      false,
      false,
      false,
    );
  }

  /**
   * export addConditionToFilteringByViewerForList as static method
   */
  pageSchema.statics.addConditionToFilteringByViewerForList =
    addConditionToFilteringByViewerForList;

  /**
   * export addConditionToFilteringByViewerToEdit as static method
   */
  pageSchema.statics.addConditionToFilteringByViewerToEdit =
    addConditionToFilteringByViewerToEdit;

  /**
   * Throw error for growi-lsx-plugin (v1.x)
   */
  pageSchema.statics.generateQueryToListByStartWith = function (
    path,
    user,
    option,
  ) {
    const dummyQuery = this.find();
    dummyQuery.exec = async () => {
      throw new Error(
        'Plugin version mismatch. Upgrade growi-lsx-plugin to v2.0.0 or above.',
      );
    };
    return dummyQuery;
  };
  pageSchema.statics.generateQueryToListWithDescendants =
    pageSchema.statics.generateQueryToListByStartWith;

  /**
   * find all templates applicable to the new page
   */
  pageSchema.statics.findTemplate = async function (path) {
    const templatePath = nodePath.posix.dirname(path);
    const pathList = generatePathsOnTree(path, []);
    const regexpList = pathList.map((path) => {
      const pathWithTrailingSlash = pathUtils.addTrailingSlash(path);
      return new RegExp(
        `^${escapeStringRegexp(pathWithTrailingSlash)}_{1,2}template$`,
      );
    });

    // biome-ignore lint/plugin: allow populate for backward compatibility
    const templatePages = await this.find({ path: { $in: regexpList } })
      .populate({ path: 'revision', model: 'Revision' })
      .exec();

    return fetchTemplate(templatePages, templatePath);
  };

  const generatePathsOnTree = (path, pathList) => {
    pathList.push(path);

    if (path === '/') {
      return pathList;
    }

    const newPath = nodePath.posix.dirname(path);

    return generatePathsOnTree(newPath, pathList);
  };

  const assignTemplateByType = (templates, path, type) => {
    const targetTemplatePath = urljoin(path, `${type}template`);

    return templates.find((template) => {
      return template.path === targetTemplatePath;
    });
  };

  const assignDecendantsTemplate = (decendantsTemplates, path) => {
    const decendantsTemplate = assignTemplateByType(
      decendantsTemplates,
      path,
      '__',
    );
    if (decendantsTemplate) {
      return decendantsTemplate;
    }

    if (path === '/') {
      return;
    }

    const newPath = nodePath.posix.dirname(path);
    return assignDecendantsTemplate(decendantsTemplates, newPath);
  };

  const fetchTemplate = async (templates, templatePath) => {
    let templateBody;
    let templateTags;
    /**
     * get children template
     * __tempate: applicable only to immediate decendants
     */
    const childrenTemplate = assignTemplateByType(templates, templatePath, '_');

    /**
     * get decendants templates
     * _tempate: applicable to all pages under
     */
    const decendantsTemplate = assignDecendantsTemplate(
      templates,
      templatePath,
    );

    if (childrenTemplate) {
      templateBody = childrenTemplate.revision.body;
      templateTags = await childrenTemplate.findRelatedTagsById();
    } else if (decendantsTemplate) {
      templateBody = decendantsTemplate.revision.body;
      templateTags = await decendantsTemplate.findRelatedTagsById();
    }

    return { templateBody, templateTags };
  };

  pageSchema.statics.findListByPathsArray = async function (
    paths,
    includeEmpty = false,
  ) {
    const queryBuilder = new this.PageQueryBuilder(this.find(), includeEmpty);
    queryBuilder.addConditionToListByPathsArray(paths);

    return await queryBuilder.query.exec();
  };

  /**
   * transfer pages grant to specified user group
   * @param {Page[]} pages
   * @param {IGrantedGroup} transferToUserGroup
   */
  pageSchema.statics.transferPagesToGroup = async function (
    pages,
    transferToUserGroup,
  ) {
    const userGroupModel =
      transferToUserGroup.type === GroupType.userGroup
        ? UserGroup
        : ExternalUserGroup;

    if ((await userGroupModel.count({ _id: transferToUserGroup.item })) === 0) {
      throw Error(
        'Cannot find the group to which private pages belong to. _id: ',
        transferToUserGroup.item,
      );
    }

    await this.updateMany(
      { _id: { $in: pages.map((p) => p._id) } },
      { grantedGroups: [transferToUserGroup] },
    );
  };

  pageSchema.statics.getHistories = () => {
    // TODO
  };

  pageSchema.statics.STATUS_PUBLISHED = STATUS_PUBLISHED;
  pageSchema.statics.STATUS_DELETED = STATUS_DELETED;
  pageSchema.statics.GRANT_PUBLIC = GRANT_PUBLIC;
  pageSchema.statics.GRANT_RESTRICTED = GRANT_RESTRICTED;
  pageSchema.statics.GRANT_SPECIFIED = GRANT_SPECIFIED;
  pageSchema.statics.GRANT_OWNER = GRANT_OWNER;
  pageSchema.statics.GRANT_USER_GROUP = GRANT_USER_GROUP;
  pageSchema.statics.PAGE_GRANT_ERROR = PAGE_GRANT_ERROR;

  return pageSchema;
};