Method delete

api/server/models/Chat.ts:185–234

({ userId, chatId })

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

    const existingChat = await this.findById(chatId).setOptions({ lean: true });

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

    await this.checkPermission({
      userId,
      teamId: existingChat.teamId,
      chat: existingChat,
    });

    const messagesToBeRemoved = await Message.find({
      chatId: existingChat._id.toString(),
    }).setOptions({ lean: true });

    const messageIdsToBeRemoved = messagesToBeRemoved.map((m) => {
      return m['_id'].toString();
    });

    // remove all messages and files if any
    for (const messageId of messageIdsToBeRemoved) {
      await Message.delete({ userId, id: messageId });
    }

    // remove chat document
    await this.deleteOne({ _id: chatId });

    // remove messageId from each user's unreadByUserMessageIds
    for (const id of existingChat.chatParticipantIds.filter((id) => id !== userId)) {
      const user = await User.findOne({ _id: id }).setOptions({ lean: true });

      const unreadByUserMessageIds = user.unreadByUserMessageIds.filter((uci) => {
        return !messageIdsToBeRemoved.includes(uci);
      });

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

    return { teamId: existingChat.teamId };
  }

  public static async clearHistory({ userId, chatId }): Promise<{ teamId: string }> {
    if (!chatId) {