Method delete

api/server/models/Message.ts:369–431

({ userId, id })

  }

  public static async delete({ userId, id }) {
    if (!id) {
      throw new Error('Bad data');
    }

    const messageToBeDeleted = await this.findOne({ _id: id }).setOptions({ lean: true });

    if (!messageToBeDeleted) {
      throw new Error(id);
    }

    const { chat } = await this.checkPermission({ userId, chatId: messageToBeDeleted.chatId });

    //
    await User.markMessageAsReadForParticipantsOfChatAfterMessageIsDeletedByUser({
      userIdsToNotify: chat.chatParticipantIds.filter((id) => id !== userId),
      messageId: id,
    });

    // call markMessageAsReadBySomeoneAfterMessageIsDeletedByUser
    await User.updateOne(
      { _id: userId },
      {
        $pull: {
          unreadBySomeoneMessageIds: id,
        },
      },
    );

    const allThreadMessages = await this.find({
      parentMessageId: id,
    }).setOptions({ lean: true });

    if (allThreadMessages.length > 0) {
      for (const threadMessage of allThreadMessages) {
        await this.deleteOne({ _id: threadMessage._id.toString() });

        const arrayOfFileUrls = threadMessage.files.map((f) => {
          return f['fileUrl'];
        });

        if (arrayOfFileUrls.length > 0) {
          deleteFiles(arrayOfFileUrls).catch((err) => console.log(err));
        }
      }
    }

    await this.deleteOne({ _id: id });

    const arrayOfFileUrls = messageToBeDeleted.files.map((f) => {
      return f['fileUrl'];
    });

    if (arrayOfFileUrls.length > 0) {
      deleteFiles(arrayOfFileUrls).catch((err) => console.log(err));
    }

    // 2 browsers, same user fix