RocketChat/Rocket.Chat

File Subscriptions.ts has 1466 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import type {
    AtLeast,
    IRole,
    IRoom,
    ISubscription,

SubscriptionsRaw has 120 functions (exceeds 20 allowed). Consider refactoring.

Open

export class SubscriptionsRaw extends BaseRaw<ISubscription> implements ISubscriptionsModel {
    constructor(db: Db, trash?: Collection<RocketChatRecordDeleted<ISubscription>>) {
        super(db, 'subscription', trash);
    }

Function findConnectedUsersExcept has 94 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async findConnectedUsersExcept(
        userId: string,
        searchTerm: string,
        exceptions: string[],
        searchFields: string[],

Function createWithRoomAndUser has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async createWithRoomAndUser(room: IRoom, user: IUser, extraData: Record<string, any> = {}): Promise<InsertOneResult<ISubscription>> {
        const subscription = {
            open: false,
            alert: false,
            unread: 0,

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        const subscription = {
            open: false,
            alert: false,
            unread: 0,
            userMentions: 0,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        const subscriptions = users.map(({ user, extraData }) => ({
            open: false,
            alert: false,
            unread: 0,
            userMentions: 0,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    async getLastSeen(options: FindOptions<ISubscription> = { projection: { _id: 0, ls: 1 } }): Promise<Date | undefined> {
        options.sort = { ls: -1 };
        options.limit = 1;
        const [subscription] = await this.find({}, options).toArray();
        return subscription?.ls;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    setAlertForRoomIdExcludingUserId(roomId: IRoom['_id'], userId: IUser['_id']): Promise<UpdateResult | Document> {
        const query = {
            'rid': roomId,
            'u._id': {
                $ne: userId,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    setOpenForRoomIdExcludingUserId(roomId: IRoom['_id'], userId: IUser['_id']): Promise<UpdateResult | Document> {
        const query = {
            'rid': roomId,
            'u._id': {
                $ne: userId,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    setAlertForRoomIdAndUserIds(roomId: string, uids: string[]): Promise<UpdateResult | Document> {
        const query = {
            'rid': roomId,
            'u._id': { $in: uids },
            'alert': { $ne: true },

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    setOpenForRoomIdAndUserIds(roomId: string, uids: string[]): Promise<UpdateResult | Document> {
        const query = {
            'rid': roomId,
            'u._id': { $in: uids },
            'open': { $ne: true },

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    updateUnreadAlertById(_id: string, unreadAlert: ISubscription['unreadAlert']): Promise<UpdateResult> {
        const query = {
            _id,
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    incUserMentionsAndUnreadForRoomIdAndUserIds(
        roomId: IRoom['_id'],
        userIds: IUser['_id'][],
        incUser = 1,
        incUnread = 1,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    incGroupMentionsAndUnreadForRoomIdExcludingUserId(
        roomId: IRoom['_id'],
        userId: IUser['_id'],
        incGroup = 1,
        incUnread = 1,

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

    updateAudioNotificationValueById(_id: string, audioNotificationValue: string): Promise<UpdateResult> {
        const query = {
            _id,
        };

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

    updateAutoTranslateLanguageById(_id: string, autoTranslateLanguage: string): Promise<UpdateResult> {
        const query = {
            _id,
        };

• Read up
  Read up

Similar blocks of code found in 5 locations. Consider refactoring.

Open

    changeDepartmentByRoomId(rid: string, department: string): Promise<UpdateResult> {
        const query = {
            rid,
        };
        const update: UpdateFilter<ISubscription> = {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    updateMuteGroupMentions(_id: string, muteGroupMentions: boolean): Promise<UpdateResult> {
        const query = {
            _id,
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    updateDisableNotificationsById(_id: string, disableNotifications: boolean): Promise<UpdateResult> {
        const query = {
            _id,
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByLivechatRoomIdAndNotUserId(roomId: string, userId: string, options: FindOptions<ISubscription> = {}): FindCursor<ISubscription> {
        const query = {
            'rid': roomId,
            'servedBy._id': {
                $ne: userId,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByRoomIdAndNotUserId(roomId: string, userId: string, options: FindOptions<ISubscription> = {}): FindCursor<ISubscription> {
        const query = {
            'rid': roomId,
            'u._id': {
                $ne: userId,

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    setGroupE2ESuggestedKey(_id: string, key: string): Promise<UpdateResult | Document> {
        const query = { _id };
        const update = { $set: { E2ESuggestedKey: key } };
        return this.updateOne(query, update);
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByRoomIdWhenUsernameExists(rid: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query = { rid, 'u.username': { $exists: true } };

        return this.find(query, options);
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByUserIdWithoutE2E(userId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query = {
            'u._id': userId,
            'E2EKey': {
                $exists: false,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByRoomIdWhenUserIdExists(rid: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query = { rid, 'u._id': { $exists: true } };

        return this.find(query, options);
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByRoomWithUserHighlights(roomId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query = {
            'rid': roomId,
            'userHighlights.0': { $exists: true },
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    archiveByRoomId(roomId: string): Promise<UpdateResult | Document> {
        const query = { rid: roomId };

        const update: UpdateFilter<ISubscription> = {
            $set: {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    unarchiveByRoomId(roomId: string): Promise<UpdateResult | Document> {
        const query = { rid: roomId };

        const update: UpdateFilter<ISubscription> = {
            $set: {

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    findDontNotifyMobileUsersByRoomId(roomId: string): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            rid: roomId,
            mobilePushNotifications: 'nothing',
        };

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    findDontNotifyDesktopUsersByRoomId(roomId: string): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            rid: roomId,
            desktopNotifications: 'nothing',
        };

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    findAlwaysNotifyMobileUsersByRoomId(roomId: string): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            rid: roomId,
            mobilePushNotifications: 'all',
        };

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

    findAlwaysNotifyDesktopUsersByRoomId(roomId: string): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            rid: roomId,
            desktopNotifications: 'all',
        };

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    updateDisplayNameByRoomId(roomId: string, fname: string): Promise<UpdateResult | Document> {
        const query = { rid: roomId };

        const update: UpdateFilter<ISubscription> = {
            $set: {

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    updateNameAndFnameById(_id: string, name: string, fname: string): Promise<UpdateResult | Document> {
        const query = { _id };

        const update: UpdateFilter<ISubscription> = {
            $set: {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByUserId(userId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query = { 'u._id': userId };

        return this.find(query, options);
    }

• Read up
  Read up

Similar blocks of code found in 6 locations. Consider refactoring.

Open

    unsetOnHoldByRoomId(rid: string): Promise<UpdateResult> {
        return this.updateOne({ rid }, { $unset: { onHold: 1 } });
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    setOnHoldByRoomId(rid: string): Promise<UpdateResult> {
        return this.updateOne({ rid }, { $set: { onHold: true } });
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

        if (!Array.isArray(roles)) {
            roles = [roles];
            process.env.NODE_ENV === 'development' && console.warn('[WARN] Subscriptions.addRolesByUserId: roles should be an array');
        }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    removeByVisitorToken(token: string): Promise<DeleteResult> {
        const query = {
            'v.token': token,
        };

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    findByType(types: ISubscription['t'][], options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            t: {
                $in: types,
            },

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    findByTypeAndUserId(type: ISubscription['t'], userId: string, options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            't': type,
            'u._id': userId,
        };

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

    findByUserIdAndType(userId: string, type: ISubscription['t'], options?: FindOptions<ISubscription>): FindCursor<ISubscription> {
        const query: Filter<ISubscription> = {
            'u._id': userId,
            't': type,
        };

• Read up
  Read up