summaryrefslogtreecommitdiff
path: root/packages/backend/src/core/DeleteAccountService.ts
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-09-18 03:27:08 +0900
committerGitHub <noreply@github.com>2022-09-18 03:27:08 +0900
commitb75184ec8e3436200bacdcd832e3324702553d20 (patch)
tree8b7e316f29e95df921db57289c8b8da476d18f07 /packages/backend/src/core/DeleteAccountService.ts
parentUpdate ROADMAP.md (diff)
downloadsharkey-b75184ec8e3436200bacdcd832e3324702553d20.tar.gz
sharkey-b75184ec8e3436200bacdcd832e3324702553d20.tar.bz2
sharkey-b75184ec8e3436200bacdcd832e3324702553d20.zip
なんかもうめっちゃ変えた
Diffstat (limited to 'packages/backend/src/core/DeleteAccountService.ts')
-rw-r--r--packages/backend/src/core/DeleteAccountService.ts38
1 files changed, 38 insertions, 0 deletions
diff --git a/packages/backend/src/core/DeleteAccountService.ts b/packages/backend/src/core/DeleteAccountService.ts
new file mode 100644
index 0000000000..ba67bc499e
--- /dev/null
+++ b/packages/backend/src/core/DeleteAccountService.ts
@@ -0,0 +1,38 @@
+import { Inject, Injectable } from '@nestjs/common';
+import { UsersRepository } from '@/models/index.js';
+import { QueueService } from '@/core/QueueService.js';
+import { UserSuspendService } from '@/core/UserSuspendService.js';
+import { GlobalEventService } from '@/core/GlobalEventService.js';
+import { DI } from '@/di-symbols.js';
+
+@Injectable()
+export class DeleteAccountService {
+ constructor(
+ @Inject(DI.usersRepository)
+ private usersRepository: UsersRepository,
+
+ private userSuspendService: UserSuspendService,
+ private queueService: QueueService,
+ private globalEventServie: GlobalEventService,
+ ) {
+ }
+
+ public async deleteAccount(user: {
+ id: string;
+ host: string | null;
+ }): Promise<void> {
+ // 物理削除する前にDelete activityを送信する
+ await this.userSuspendService.doPostSuspend(user).catch(e => {});
+
+ this.queueService.createDeleteAccountJob(user, {
+ soft: false,
+ });
+
+ await this.usersRepository.update(user.id, {
+ isDeleted: true,
+ });
+
+ // Terminate streaming
+ this.globalEventServie.publishUserEvent(user.id, 'terminate', {});
+ }
+}