Zeeshan Khan
fe4b307fe6
* delete and restore user from admin UI * addressed review comments and fix e2e test * added cron job to delete user, and some formatting changes * addressed review comments * adding missing queue registration
36 lines
1.3 KiB
TypeScript
36 lines
1.3 KiB
TypeScript
import { APP_UPLOAD_LOCATION, userUtils } from '@app/common';
|
|
import { AssetEntity } from '@app/database/entities/asset.entity';
|
|
import { UserEntity } from '@app/database/entities/user.entity';
|
|
import { QueueNameEnum, userDeletionProcessorName } from '@app/job';
|
|
import { IUserDeletionJob } from '@app/job/interfaces/user-deletion.interface';
|
|
import { Process, Processor } from '@nestjs/bull';
|
|
import { InjectRepository } from '@nestjs/typeorm';
|
|
import { Job } from 'bull';
|
|
import { join } from 'path';
|
|
import fs from 'fs';
|
|
import { Repository } from 'typeorm';
|
|
|
|
@Processor(QueueNameEnum.USER_DELETION)
|
|
export class UserDeletionProcessor {
|
|
constructor(
|
|
@InjectRepository(UserEntity)
|
|
private userRepository: Repository<UserEntity>,
|
|
|
|
@InjectRepository(AssetEntity)
|
|
private assetRepository: Repository<AssetEntity>,
|
|
) {}
|
|
|
|
@Process(userDeletionProcessorName)
|
|
async processUserDeletion(job: Job<IUserDeletionJob>) {
|
|
const { user } = job.data;
|
|
// just for extra protection here
|
|
if (userUtils.isReadyForDeletion(user)) {
|
|
const basePath = APP_UPLOAD_LOCATION;
|
|
const userAssetDir = join(basePath, user.id)
|
|
fs.rmSync(userAssetDir, { recursive: true, force: true })
|
|
await this.assetRepository.delete({ userId: user.id })
|
|
await this.userRepository.remove(user);
|
|
}
|
|
}
|
|
}
|