Feat/issue 4476

migration/1723764281125-add_email_verification_columns.ts

@@ -0,0 +1,21 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class AddEmailVerificationColumns1723764281125
+  implements MigrationInterface
+{
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    queryRunner.query(`
+            ALTER TABLE "user"
+            ADD COLUMN IF NOT EXISTS "verificationCode" VARCHAR,
+            ADD COLUMN IF NOT EXISTS "isEmailVerified" BOOLEAN DEFAULT false;
+        `);
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    queryRunner.query(`
+            ALTER TABLE "user"
+            DROP COLUMN IF EXISTS "verificationCode",
+            DROP COLUMN IF EXISTS "isEmailVerified";
+        `);
+  }
+}

src/adapters/notifications/MockNotificationAdapter.ts

@@ -35,6 +35,14 @@ export class MockNotificationAdapter implements NotificationAdapterInterface {
     return Promise.resolve(undefined);
   }
 
+  sendEmailConfirmationCodeFlow(params: { email: string }): Promise<void> {
+    logger.debug(
+      'MockNotificationAdapter sendEmailConfirmationCodeFlow',
+      params,
+    );
+    return Promise.resolve(undefined);
+  }
+
   userSuperTokensCritical(): Promise<void> {
     return Promise.resolve(undefined);
   }

src/adapters/notifications/NotificationAdapterInterface.ts

@@ -63,6 +63,11 @@ export interface NotificationAdapterInterface {
     token: string;
   }): Promise<void>;
 
+  sendEmailConfirmationCodeFlow(params: {
+    email: string;
+    user: User;
+  }): Promise<void>;
+
   userSuperTokensCritical(params: {
     user: User;
     eventName: UserStreamBalanceWarning;

src/adapters/notifications/NotificationCenterAdapter.ts

@@ -94,6 +94,27 @@ export class NotificationCenterAdapter implements NotificationAdapterInterface {
     }
   }
 
+  async sendEmailConfirmationCodeFlow(params: {
+    email: string;
+    user: User;
+  }): Promise<void> {
+    const { email, user } = params;
+    try {
+      await callSendNotification({
+        eventName: NOTIFICATIONS_EVENT_NAMES.SEND_EMAIL_CONFIRMATION_CODE_FLOW,
+        segment: {
+          payload: {
+            email,
+            verificationCode: user.verificationCode,
+            userId: user.id,
+          },
+        },
+      });
+    } catch (e) {
+      logger.error('sendEmailConfirmationCodeFlow >> error', e);
+    }
+  }
+
   async userSuperTokensCritical(params: {
     user: User;
     eventName: UserStreamBalanceWarning;

src/analytics/analytics.ts

@@ -49,4 +49,5 @@ export enum NOTIFICATIONS_EVENT_NAMES {
   SUBSCRIBE_ONBOARDING = 'Subscribe onboarding',
   CREATE_ORTTO_PROFILE = 'Create Ortto profile',
   SEND_EMAIL_CONFIRMATION = 'Send email confirmation',
+  SEND_EMAIL_CONFIRMATION_CODE_FLOW = 'Send email confirmation code flow',
 }

src/entities/user.ts

@@ -34,6 +34,7 @@ export const publicSelectionFields = [
   'user.totalReceived',
   'user.passportScore',
   'user.passportStamps',
+  'user.isEmailVerified',
 ];
 
 export enum UserRole {
@@ -156,6 +157,13 @@ export class User extends BaseEntity {
   @Column('bool', { default: false })
   segmentIdentified: boolean;
 
+  @Field(_type => Boolean, { nullable: true })
+  @Column('bool', { default: false })
+  isEmailVerified: boolean;
+
+  @Column('varchar', { nullable: true, default: null })
+  verificationCode?: string | null;
+
   // Admin Reviewing Forms
   @Field(_type => [ProjectVerificationForm], { nullable: true })
   @OneToMany(

src/resolvers/types/userResolver.ts

@@ -5,4 +5,8 @@ import { User } from '../../entities/user';
 export class UserByAddressResponse extends User {
   @Field(_type => Boolean, { nullable: true })
   isSignedIn?: boolean;
+  @Field(_type => Boolean, { nullable: true })
+  isEmailSent?: boolean;
+  @Field(_type => Boolean, { nullable: true })
+  useHasProject?: boolean;
 }