Method delete

api/server/models/Discussion.ts:233–282

({ userId, discussionId })

  // review
  public static async delete({ userId, discussionId }): Promise<any> {
    if (!discussionId) {
      throw new Error('Bad data');
    }

    const existingDiscussion = await this.findById(discussionId).setOptions({ lean: true });

    if (!existingDiscussion) {
      throw new Error('Not found');
    }

    await this.checkPermission({
      userId,
      teamId: existingDiscussion.teamId,
      discussion: existingDiscussion,
    });

    const commentsToBeRemoved = await Comment.find({
      discussionId: existingDiscussion._id.toString(),
    }).setOptions({ lean: true });

    const commentIdsToBeRemoved = commentsToBeRemoved.map((c) => {
      return c['_id'].toString();
    });

    // remove all comments and files if any
    for (const commentId of commentIdsToBeRemoved) {
      await Comment.delete({ userId, id: commentId, isDiscussionBeingDeleted: true });
    }

    // remove discussion document
    await this.deleteOne({ _id: discussionId });

    // remove commentId from each user's unreadCommentIds
    for (const id of existingDiscussion.discussionMemberIds.filter((id) => id !== userId)) {
      const user = await User.findOne({ _id: id }).setOptions({ lean: true });

      const unreadCommentIds = user.unreadCommentIds.filter((uci) => {
        return !commentIdsToBeRemoved.includes(uci);
      });

      await User.findOneAndUpdate(
        { _id: id },
        { $set: { unreadCommentIds } },
        { runValidators: true },
      ).setOptions({ lean: true });
    }

    return { teamId: existingDiscussion.teamId };
  }

  // inside `app`, make sure that Comment cannot be added to the Archived Discussion
  public static async archive({ userId, discussionId, action }): Promise<any> {