Method addOrEdit

api/server/models/Message.ts:181–268

({ content, chatId, teamId, userId, id, files, parentMessageId })

  // done: add parentMessageId
  public static async addOrEdit({ content, chatId, teamId, userId, id, files, parentMessageId }) {
    if (!content || !teamId) {
      throw new Error('Bad data');
    }

    const { isSubscriptionActiveForAccount, isTrialPeriodOverForAccount } =
      await User.getSubscriptionStatus(userId);

    if (isTrialPeriodOverForAccount && !isSubscriptionActiveForAccount) {
      throw new Error('This team is not subscribed to a paid plan and free trial period is over.');
    }

    await Chat.updateOne({ _id: chatId }, { lastUpdatedAt: new Date() });

    if (id) {
      const editedMessage = await this.edit({
        content,
        chatId,
        userId,
        id,
      });

      // no realtime update for editing message
      return { message: editedMessage, userIdsToNotify: [] };
    } else {
      const { chat } = await this.checkPermission({ userId, chatId });

      const htmlContent = markdownToHtml(content);

      const newMessage = await this.create({
        createdUserId: userId,
        chatId,
        content,
        htmlContent,
        isEdited: false,
        createdAt: new Date(),
        lastEditedAt: new Date(),
        parentMessageId: parentMessageId || null,
      });

      // add messageId to all participants of Chat except actor user

      await User.markMessageAsUnreadForParticipantsOfChatAfterMessageIsAddedByUser({
        userIdsToNotify: chat.chatParticipantIds.filter((id) => id !== userId),
        messageId: newMessage._id.toString(),
      });

      // call markMessageAsUneadBySomeoneAfterMessageIsAddedByUser
      await User.updateOne(
        { _id: userId },
        {
          $addToSet: {
            unreadBySomeoneMessageIds: newMessage._id.toString(),
          },
        },
      );

      // update moveFile