Hook up sending verification email

Author: Lan2u

src/authentication/start-magic-link-email-pub-sub.ts

@@ -7,6 +7,8 @@ import {EmailAddressCodec, failure} from '../types';
 import {Dependencies} from '../dependencies';
 import {sendLogInLink} from './send-log-in-link';
 import {Config} from '../configuration';
+import * as t from 'io-ts';
+import { sendEmailVerification } from './send-email-verification';
 
 const validateEmail = (input: unknown) =>
   pipe(
@@ -16,6 +18,19 @@ const validateEmail = (input: unknown) =>
     E.mapLeft(failure('Invalid Email'))
   );
 
+const validateEmailVerificationCodec = t.strict({
+  memberNumber: t.Integer,
+  emailAddress: EmailAddressCodec,
+});
+
+const validateEmailVerification = (input: unknown) =>
+  pipe(
+    input,
+    validateEmailVerificationCodec.decode,
+    E.mapLeft(formatValidationErrors),
+    E.mapLeft(failure('Invalid validation request'))
+  );
+
 export const startMagicLinkEmailPubSub = (deps: Dependencies, conf: Config) => {
   PubSub.subscribe(
     'send-log-in-link',
@@ -33,4 +48,22 @@ export const startMagicLinkEmailPubSub = (deps: Dependencies, conf: Config) => {
         )
       )()
   );
+
+  PubSub.subscribe(
+    'send-email-verification',
+    // eslint-disable-next-line @typescript-eslint/no-misused-promises
+    async (topic, payload) => {
+      await pipe(
+        payload,
+        validateEmailVerification,
+        TE.fromEither,
+        TE.chain(({memberNumber, emailAddress}) => sendEmailVerification(deps, conf)(memberNumber, emailAddress)),
+        TE.match(
+          failure =>
+            deps.logger.error({topic, failure}, 'Failed to process message'),
+          successMsg => deps.logger.info({topic, result: successMsg})
+        )
+      )()
+    }
+  )
 };

src/commands/members/send-email-verification.ts

@@ -37,15 +37,18 @@ const process: Command<SendMemberEmailVerification>['process'] = input => {
   }
 
   publish('send-email-verification', {
-    member: input.command.memberNumber,
-    email: input.command.email,
+    memberNumber: input.command.memberNumber,
+
+    // We use the emailAddress we actually matched rather than the email input
+    // This prevents weirdness around the normalised vs raw address
+    emailAddress, 
   });
 
   return O.some(
     constructEvent('MemberEmailVerificationRequested')({
       actor: input.command.actor,
       memberNumber: input.command.memberNumber,
-      email: input.command.email,
+      email: emailAddress,
     })
   );
 };

tests/queries/me/render.test.ts

@@ -28,16 +28,19 @@ describe('/me render', () => {
           emailAddress: primaryEmail,
           verifiedAt: O.some(new Date('2025-01-01T00:00:00.000Z')),
           addedAt: new Date('2025-01-01T00:00:00.000Z'),
+          verificationLastSent: O.none,
         },
         {
           emailAddress: unverifiedEmail,
           verifiedAt: O.none,
           addedAt: new Date('2025-01-02T00:00:00.000Z'),
+          verificationLastSent: O.none,
         },
         {
           emailAddress: verifiedSecondaryEmail,
           verifiedAt: O.some(new Date('2025-01-03T00:00:00.000Z')),
           addedAt: new Date('2025-01-03T00:00:00.000Z'),
+          verificationLastSent: O.none,
         },
       ],
       name: O.none,
@@ -57,15 +60,15 @@ describe('/me render', () => {
 
   it('shows the primary email and all email addresses', () => {
     const page = renderPage(viewModel);
-    expect(page.textContent).toContain('Primary email');
+    expect(page.textContent).toContain('Primary');
     expect(page.textContent).toContain(primaryEmail);
     expect(page.textContent).toContain(unverifiedEmail);
     expect(page.textContent).toContain(verifiedSecondaryEmail);
   });
 
   it('shows the right actions for unverified and verified non-primary emails', () => {
     const page = renderPage(viewModel);
-    expect(page.textContent).toContain('Send verification email');
-    expect(page.textContent).toContain('Make primary');
+    expect(page.textContent).toContain('Send Verification Email');
+    expect(page.textContent).toContain('Set Primary Email');
   });
 });