feat(inactive-accts): use one task queue per email type

Because:
 - we want to simplify email cloud task scheduling and rate limiting by
   using one Google cloud task queue per email notification type

This commit:
 - uses one cloud task queue per email type
 - renames numerous things to make it clear that these queues and tasks
   are for inactive deletion emails only
 - updates route handler and InactiveAccountManager

Author: chenba

_scripts/cloud-tasks-emulator.sh

@@ -3,4 +3,4 @@
 docker run --rm \
     --name cloud-tasks-emulator \
     -p 8123:8123 \
-    ghcr.io/aertje/cloud-tasks-emulator:latest -host "0.0.0.0" -port "8123" -queue "projects/test/locations/test/queues/delete-accounts-queue" -queue "projects/test/locations/test/queues/notification-emails-queue"
+    ghcr.io/aertje/cloud-tasks-emulator:latest -host "0.0.0.0" -port "8123" -queue "projects/test/locations/test/queues/delete-accounts-queue" -queue "projects/test/locations/test/queues/inactive-first-email" -queue "projects/test/locations/test/queues/inactive-second-email" -queue "projects/test/locations/test/queues/inactive-third-email"

libs/shared/cloud-tasks/src/index.ts

@@ -3,6 +3,6 @@ export * from './lib/cloud-tasks.factories';
 export * from './lib/cloud-tasks.types';
 
 export * from './lib/delete-account-tasks';
-export * from './lib/send-email-tasks';
+export * from './lib/inactive-account-email-tasks';
 export * from './lib/account-tasks.factories';
 export * from './lib/account-tasks.types';

libs/shared/cloud-tasks/src/lib/account-tasks.factories.ts

@@ -5,11 +5,11 @@
 import { StatsD } from 'hot-shots';
 import {
   DeleteAccountCloudTaskConfig,
-  SendEmailCloudTaskConfig,
+  InactiveAccountEmailCloudTaskConfig,
 } from './account-tasks.types';
 import { CloudTaskClientFactory } from './cloud-tasks.factories';
 import { DeleteAccountTasks } from './delete-account-tasks';
-import { SendEmailTasks } from './send-email-tasks';
+import { InactiveAccountEmailTasks } from './inactive-account-email-tasks';
 
 /** Produces a DeleteAccountCloudTask instance */
 export function DeleteAccountTasksFactory(
@@ -20,10 +20,10 @@ export function DeleteAccountTasksFactory(
   return new DeleteAccountTasks(config, client, statsd);
 }
 
-export function SendEmailTasksFactory(
-  config: SendEmailCloudTaskConfig,
+export function InactiveAccountEmailTasksFactory(
+  config: InactiveAccountEmailCloudTaskConfig,
   statsd: Pick<StatsD, 'increment'>
 ) {
   const client = CloudTaskClientFactory(config);
-  return new SendEmailTasks(config, client, statsd);
+  return new InactiveAccountEmailTasks(config, client, statsd);
 }

libs/shared/cloud-tasks/src/lib/account-tasks.types.ts

@@ -3,7 +3,7 @@
  * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
 
 import { CloudTasksConfig } from './cloud-tasks.types';
-import { CloudTaskEmailType } from './send-email-tasks';
+import { CloudTaskEmailType } from './inactive-account-email-tasks';
 
 export type FxACloudTaskHeaders = {
   'fxa-cloud-task-delivery-time'?: string;
@@ -24,6 +24,7 @@ export enum ReasonForDeletion {
   UserRequested = 'fxa_user_requested_account_delete',
   Unverified = 'fxa_unverified_account_delete',
   Cleanup = 'fxa_cleanup_account_delete',
+  InactiveAccount = 'fxa_inactive_account_delete',
 }
 
 /** Task payload requesting an account deletion */
@@ -36,11 +37,15 @@ export type DeleteAccountTask = {
   reason: ReasonForDeletion;
 };
 
-export type SendEmailCloudTaskConfig = CloudTasksConfig & {
+export type InactiveAccountEmailCloudTaskConfig = CloudTasksConfig & {
   cloudTasks: {
-    sendEmails: {
+    inactiveAccountEmails: {
       taskUrl: string;
-      queueName: string;
+      firstEmailQueueName: string;
+      secondEmailQueueName: string;
+      thirdEmailQueueName: string;
+      firstToSecondEmailIntervalMs: number;
+      secondToThirdEmailIntervalMs: number;
     };
   };
 };
@@ -49,3 +54,7 @@ export type SendEmailTaskPayload = {
   uid: string;
   emailType: CloudTaskEmailType;
 };
+export type InactiveAccountEmailTaskPayloadParam = Omit<
+  SendEmailTaskPayload,
+  'emailType'
+>;

libs/shared/cloud-tasks/src/lib/cloud-tasks.factories.ts

@@ -67,19 +67,43 @@ export function CloudTasksConvictConfigFactory() {
         format: String,
       },
     },
-    sendEmails: {
+    inactiveAccountEmails: {
       taskUrl: {
         default: '',
         doc: 'URL that sends the email',
         env: 'AUTH_CLOUDTASKS_NOTIFICATION_EMAILS_TASK_URL',
         format: String,
       },
-      queueName: {
-        default: 'notification-emails-queue',
-        doc: 'The name of the queue.  It should match the x-cloudtasks-queuename header value sent to the target.',
-        env: `AUTH_CLOUDTASKS_NOTIFICATION_EMAILS_QUEUENAME`,
+      firstEmailQueueName: {
+        default: 'inactives-first-email',
+        doc: 'The name of the queue for the first email.  It should match the x-cloudtasks-queuename header value sent to the target.',
+        env: 'AUTH_CLOUDTASKS_INACTIVE_ACCT_FIRST_EMAIL_QUEUENAME',
+        format: String,
+      },
+      secondEmailQueueName: {
+        default: 'inactives-second-email',
+        doc: 'The name of the queue for the second email.  It should match the x-cloudtasks-queuename header value sent to the target.',
+        env: 'AUTH_CLOUDTASKS_INACTIVE_ACCT_SECOND_EMAIL_QUEUENAME',
         format: String,
       },
+      thirdEmailQueueName: {
+        default: 'inactives-third-email',
+        doc: 'The name of the queue for the third email.  It should match the x-cloudtasks-queuename header value sent to the target.',
+        env: 'AUTH_CLOUDTASKS_INACTIVE_ACCT_THIRD_EMAIL_QUEUENAME',
+        format: String,
+      },
+      firstToSecondEmailIntervalMs: {
+        default: 53 * 24 * 60 * 60 * 1000,
+        doc: 'The interval between the first and second email in milliseconds.',
+        env: 'AUTH_CLOUDTASKS_INACTIVE_ACCT_FIRST_TO_SECOND_EMAIL_INTERVAL',
+        format: Number,
+      },
+      secondToThirdEmailIntervalMs: {
+        default: 6 * 24 * 60 * 60 * 1000,
+        doc: 'The interval between the second and third email in milliseconds.',
+        env: 'AUTH_CLOUDTASKS_INACTIVE_ACCT_SECOND_TO_THIRD_EMAIL_INTERVAL',
+        format: Number,
+      },
     },
   };
 }