merge: GDPR Data export for users (#143)

feat: GDPR Data export for users
transfem-org · Nov 7, 2023 · 739f958 · 739f958
2 parents f17f630 + e409abd
commit 739f958
Show file tree

Hide file tree

Showing 12 changed files with 876 additions and 0 deletions.
diff --git a/locales/en-US.yml b/locales/en-US.yml
@@ -2401,3 +2401,9 @@ _animatedMFM:
   _alert:
     text: "Animated MFMs could include flashing lights and fast moving text/emojis."
     confirm: "Animate"
+
+_dataRequest:
+  title: "Request Data"
+  warn: "Data requests are only possible every 3 days."
+  text: "Once the data is ready to download, an email will be sent to the email address registered to this account."
+  button: "Request"
diff --git a/locales/index.d.ts b/locales/index.d.ts
@@ -2509,6 +2509,12 @@ export interface Locale {
             "confirm": string;
         };
     };
+    "_dataRequest": {
+        "title": string;
+        "warn": string;
+        "text": string;
+        "button": string;
+    };
 }
 declare const locales: {
     [lang: string]: Locale;

diff --git a/locales/ja-JP.yml b/locales/ja-JP.yml
@@ -2395,3 +2395,9 @@ _animatedMFM:
   _alert:
     text: "アニメーションMFMには、点滅するライトや高速で動くテキスト／絵文字を含めることができる。"
     confirm: "アニメイト"
+
+_dataRequest:
+  title: "リクエストデータ"
+  warn: "データのリクエストは3日ごとにしかできない。"
+  text: "データのダウンロードが完了すると、このアカウントに登録されているEメールアドレスにEメールが送信されます。"
+  button: "リクエスト"
diff --git a/packages/backend/src/core/QueueService.ts b/packages/backend/src/core/QueueService.ts
@@ -164,6 +164,16 @@ export class QueueService {
 		});
 	}
 
+	@bindThis
+	public createExportAccountDataJob(user: ThinUser) {
+		return this.dbQueue.add('exportAccountData', {
+			user: { id: user.id },
+		}, {
+			removeOnComplete: true,
+			removeOnFail: true,
+		});
+	}
+
 	@bindThis
 	public createExportNotesJob(user: ThinUser) {
 		return this.dbQueue.add('exportNotes', {

diff --git a/packages/backend/src/queue/QueueProcessorModule.ts b/packages/backend/src/queue/QueueProcessorModule.ts
@@ -19,6 +19,7 @@ import { CleanRemoteFilesProcessorService } from './processors/CleanRemoteFilesP
 import { DeleteAccountProcessorService } from './processors/DeleteAccountProcessorService.js';
 import { DeleteDriveFilesProcessorService } from './processors/DeleteDriveFilesProcessorService.js';
 import { DeleteFileProcessorService } from './processors/DeleteFileProcessorService.js';
+import { ExportAccountDataProcessorService } from './processors/ExportAccountDataProcessorService.js';
 import { ExportBlockingProcessorService } from './processors/ExportBlockingProcessorService.js';
 import { ExportCustomEmojisProcessorService } from './processors/ExportCustomEmojisProcessorService.js';
 import { ExportFollowingProcessorService } from './processors/ExportFollowingProcessorService.js';
@@ -51,6 +52,7 @@ import { RelationshipProcessorService } from './processors/RelationshipProcessor
 		CheckExpiredMutingsProcessorService,
 		CleanProcessorService,
 		DeleteDriveFilesProcessorService,
+		ExportAccountDataProcessorService,
 		ExportCustomEmojisProcessorService,
 		ExportNotesProcessorService,
 		ExportFavoritesProcessorService,

diff --git a/packages/backend/src/queue/QueueProcessorService.ts b/packages/backend/src/queue/QueueProcessorService.ts
@@ -14,6 +14,7 @@ import { EndedPollNotificationProcessorService } from './processors/EndedPollNot
 import { DeliverProcessorService } from './processors/DeliverProcessorService.js';
 import { InboxProcessorService } from './processors/InboxProcessorService.js';
 import { DeleteDriveFilesProcessorService } from './processors/DeleteDriveFilesProcessorService.js';
+import { ExportAccountDataProcessorService } from './processors/ExportAccountDataProcessorService.js';
 import { ExportCustomEmojisProcessorService } from './processors/ExportCustomEmojisProcessorService.js';
 import { ExportNotesProcessorService } from './processors/ExportNotesProcessorService.js';
 import { ExportFollowingProcessorService } from './processors/ExportFollowingProcessorService.js';
@@ -89,6 +90,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
 		private deliverProcessorService: DeliverProcessorService,
 		private inboxProcessorService: InboxProcessorService,
 		private deleteDriveFilesProcessorService: DeleteDriveFilesProcessorService,
+		private exportAccountDataProcessorService: ExportAccountDataProcessorService,
 		private exportCustomEmojisProcessorService: ExportCustomEmojisProcessorService,
 		private exportNotesProcessorService: ExportNotesProcessorService,
 		private exportFavoritesProcessorService: ExportFavoritesProcessorService,
@@ -162,6 +164,7 @@ export class QueueProcessorService implements OnApplicationShutdown {
 		this.dbQueueWorker = new Bull.Worker(QUEUE.DB, (job) => {
 			switch (job.name) {
 				case 'deleteDriveFiles': return this.deleteDriveFilesProcessorService.process(job);
+				case 'exportAccountData': return this.exportAccountDataProcessorService.process(job);
 				case 'exportCustomEmojis': return this.exportCustomEmojisProcessorService.process(job);
 				case 'exportNotes': return this.exportNotesProcessorService.process(job);
 				case 'exportFavorites': return this.exportFavoritesProcessorService.process(job);