monkee.ch/monkeeShark
1
0
Fork 0
Code Pull requests Activity

upd: send email on export completion

Browse source
This commit is contained in:
Mar0xy 2023-11-07 11:31:11 +01:00
parent e9b6ed941b
commit fabb876256
No known key found for this signature in database
GPG key ID: 56569BBE47D2C828
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
packages/backend/src/queue/processors/ExportAccountDataProcessorService.ts
View file

@ -21,6 +21,7 @@ import { UtilityService } from '@/core/UtilityService.js';
import { DownloadService } from '@/core/DownloadService.js'; import { DownloadService } from '@/core/DownloadService.js';
import { QueueLoggerService } from '../QueueLoggerService.js'; import { QueueLoggerService } from '../QueueLoggerService.js';
import type * as Bull from 'bullmq'; import type * as Bull from 'bullmq';
import { EmailService } from '@/core/EmailService.js';
@Injectable() @Injectable()
export class ExportAccountDataProcessorService { export class ExportAccountDataProcessorService {
@ -71,6 +72,7 @@ export class ExportAccountDataProcessorService {
private idService: IdService, private idService: IdService,
private driveFileEntityService: DriveFileEntityService, private driveFileEntityService: DriveFileEntityService,
private downloadService: DownloadService, private downloadService: DownloadService,
private emailService: EmailService,
private queueLoggerService: QueueLoggerService, private queueLoggerService: QueueLoggerService,
) { ) {
this.logger = this.queueLoggerService.logger.createSubLogger('export-account-data'); this.logger = this.queueLoggerService.logger.createSubLogger('export-account-data');
@ -709,6 +711,13 @@ export class ExportAccountDataProcessorService {
this.logger.succ(`Exported to: ${driveFile.id}`); this.logger.succ(`Exported to: ${driveFile.id}`);
cleanup(); cleanup();
archiveCleanup(); archiveCleanup();
if (profile.email) {
this.emailService.sendEmail(profile.email,
'Your data archive is ready',
`Click the following link to download the archive: ${driveFile.url}<br/>It is also available in your drive.`,
`Click the following link to download the archive: ${driveFile.url}\r\n\r\nIt is also available in your drive.`,
);
}
resolve(); resolve();
}); });
archive.pipe(archiveStream); archive.pipe(archiveStream);