refactor: simplify user service methods and enhance queue handling

Author: kastov

src/modules/users/commands/bulk-all-extend-expiration-date/bulk-all-extend-expiration-date.command.ts

@@ -0,0 +1,7 @@
+import { Command } from '@nestjs/cqrs';
+
+export class BulkAllExtendExpirationDateCommand extends Command<void> {
+    constructor(public readonly extendDays: number) {
+        super();
+    }
+}

src/modules/users/commands/bulk-all-extend-expiration-date/bulk-all-extend-expiration-date.handler.ts

@@ -0,0 +1,23 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { Logger } from '@nestjs/common';
+
+import { BulkAllExtendExpirationDateCommand } from './bulk-all-extend-expiration-date.command';
+import { UsersRepository } from '../../repositories/users.repository';
+
+@CommandHandler(BulkAllExtendExpirationDateCommand)
+export class BulkAllExtendExpirationDateHandler implements ICommandHandler<BulkAllExtendExpirationDateCommand> {
+    public readonly logger = new Logger(BulkAllExtendExpirationDateHandler.name);
+
+    constructor(private readonly usersRepository: UsersRepository) {}
+
+    async execute(command: BulkAllExtendExpirationDateCommand) {
+        try {
+            await this.usersRepository.bulkAllExtendExpirationDate(command.extendDays);
+
+            return;
+        } catch (error: unknown) {
+            this.logger.error(error);
+            return;
+        }
+    }
+}

src/modules/users/commands/bulk-all-extend-expiration-date/index.ts

@@ -0,0 +1,2 @@
+export * from './bulk-all-extend-expiration-date.command';
+export * from './bulk-all-extend-expiration-date.handler';

src/modules/users/commands/bulk-sync-users/bulk-sync-users.command.ts

@@ -0,0 +1,9 @@
+import { Command } from '@nestjs/cqrs';
+
+type TBulkSyncUsers = 'limited' | 'expired';
+
+export class BulkSyncUsersCommand extends Command<void> {
+    constructor(public readonly type: TBulkSyncUsers) {
+        super();
+    }
+}

src/modules/users/commands/bulk-sync-users/bulk-sync-users.handler.ts

@@ -0,0 +1,27 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { Logger } from '@nestjs/common';
+
+import { UsersRepository } from '../../repositories/users.repository';
+import { BulkSyncUsersCommand } from './bulk-sync-users.command';
+
+@CommandHandler(BulkSyncUsersCommand)
+export class BulkSyncUsersHandler implements ICommandHandler<BulkSyncUsersCommand> {
+    public readonly logger = new Logger(BulkSyncUsersHandler.name);
+
+    constructor(private readonly usersRepository: UsersRepository) {}
+
+    async execute(command: BulkSyncUsersCommand) {
+        try {
+            if (command.type === 'limited') {
+                await this.usersRepository.bulkSyncLimitedUsers();
+            } else if (command.type === 'expired') {
+                await this.usersRepository.bulkSyncExpiredUsers();
+            }
+
+            return;
+        } catch (error: unknown) {
+            this.logger.error(error);
+            return;
+        }
+    }
+}

src/modules/users/commands/bulk-sync-users/index.ts

@@ -0,0 +1,2 @@
+export * from './bulk-sync-users.command';
+export * from './bulk-sync-users.handler';

src/modules/users/commands/bulk-update-all-users/bulk-update-all-users.command.ts

@@ -0,0 +1,9 @@
+import { Command } from '@nestjs/cqrs';
+
+import { BaseUserEntity } from '@modules/users/entities';
+
+export class BulkUpdateAllUsersCommand extends Command<void> {
+    constructor(public readonly fields: Partial<BaseUserEntity>) {
+        super();
+    }
+}

src/modules/users/commands/bulk-update-all-users/bulk-update-all-users.handler.ts

@@ -0,0 +1,25 @@
+import { CommandHandler, ICommandHandler } from '@nestjs/cqrs';
+import { Logger } from '@nestjs/common';
+
+import { BulkUpdateAllUsersCommand } from './bulk-update-all-users.command';
+import { UsersRepository } from '../../repositories/users.repository';
+
+@CommandHandler(BulkUpdateAllUsersCommand)
+export class BulkUpdateAllUsersHandler implements ICommandHandler<BulkUpdateAllUsersCommand> {
+    public readonly logger = new Logger(BulkUpdateAllUsersHandler.name);
+
+    constructor(private readonly usersRepository: UsersRepository) {}
+
+    async execute(command: BulkUpdateAllUsersCommand) {
+        try {
+            await this.usersRepository.bulkUpdateAllUsersByRange({
+                fields: command.fields,
+            });
+
+            return;
+        } catch (error: unknown) {
+            this.logger.error(error);
+            return;
+        }
+    }
+}

src/modules/users/commands/bulk-update-all-users/index.ts

@@ -0,0 +1,2 @@
+export * from './bulk-update-all-users.command';
+export * from './bulk-update-all-users.handler';

src/modules/users/commands/index.ts

@@ -1,14 +1,17 @@
 import { UpdateSubLastOpenedAndUserAgentHandler } from './update-sub-last-opened-and-user-agent';
 import { BatchResetLimitedUsersTrafficHandler } from './batch-reset-limited-users-traffic';
 import { TriggerThresholdNotificationHandler } from './trigger-threshold-notification';
+import { BulkAllExtendExpirationDateHandler } from './bulk-all-extend-expiration-date';
 import { BulkIncrementUsedTrafficHandler } from './bulk-increment-used-traffic';
 import { UpdateExceededTrafficUsersHandler } from './update-exceeded-users';
 import { RevokeUserSubscriptionHandler } from './revoke-user-subscription';
 import { BatchResetUserTrafficHandler } from './batch-reset-user-traffic';
 import { UpdateUserWithServiceHandler } from './update-user-with-service';
 import { BulkDeleteByStatusHandler } from './bulk-delete-by-status';
+import { BulkUpdateAllUsersHandler } from './bulk-update-all-users';
 import { UpdateExpiredUsersHandler } from './update-expired-users';
 import { ResetUserTrafficHandler } from './reset-user-traffic';
+import { BulkSyncUsersHandler } from './bulk-sync-users';
 
 export const COMMANDS = [
     UpdateSubLastOpenedAndUserAgentHandler,
@@ -22,4 +25,7 @@ export const COMMANDS = [
     UpdateUserWithServiceHandler,
     TriggerThresholdNotificationHandler,
     BulkDeleteByStatusHandler,
+    BulkUpdateAllUsersHandler,
+    BulkSyncUsersHandler,
+    BulkAllExtendExpirationDateHandler,
 ];