Method deleteForClearHistory

api/server/models/Message.ts:305–367

({ userId, id })

  }

  public static async deleteForClearHistory({ 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