feat: add lastActiveAt field to user (#475)

src/api/crisp/crisp-api.interfaces.ts

@@ -1,5 +1,6 @@
 export interface CrispProfileCustomFields {
   signed_up_at?: string;
+  last_active_at?: string;
   language?: string;
   marketing_permission?: boolean;
   service_emails_permission?: boolean;

src/api/mailchimp/mailchimp-api.interfaces.ts

@@ -15,6 +15,7 @@ export enum MAILCHIMP_MERGE_FIELD_TYPES {
 export interface ListMemberCustomFields {
   NAME?: string;
   SIGNUPD?: string;
+  LACTIVED?: string;
   PARTNERS?: string;
   FEATTHER?: string;
   FEATCHAT?: string;

src/entities/user.entity.ts

@@ -36,6 +36,9 @@ export class UserEntity extends BaseBloomEntity {
   @Column({ type: Boolean, default: true })
   isActive: boolean;
 
+  @Column({ type: 'timestamptz', nullable: true })
+  lastActiveAt: Date; // set each time user record is fetched
+
   @OneToMany(() => PartnerAccessEntity, (partnerAccess) => partnerAccess.user, { cascade: true })
   partnerAccess: PartnerAccessEntity[];
 

src/migrations/1718300621138-bloom-backend.ts

@@ -0,0 +1,16 @@
+import { MigrationInterface, QueryRunner } from "typeorm";
+
+export class BloomBackend1718300621138 implements MigrationInterface {
+    name = 'BloomBackend1718300621138'
+
+    public async up(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "user" DROP COLUMN "lastActiveAt"`);
+        await queryRunner.query(`ALTER TABLE "user" ADD "lastActiveAt" TIMESTAMP WITH TIME ZONE`);
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "user" DROP COLUMN "lastActiveAt"`);
+        await queryRunner.query(`ALTER TABLE "user" ADD "lastActiveAt" date`);
+    }
+
+}

src/partner-admin/partner-admin-auth.guard.spec.ts

@@ -22,6 +22,7 @@ const userEntity: UserEntity = {
   partnerAccess: [],
   partnerAdmin: { id: 'partnerAdminId', active: true, partner: {} } as PartnerAdminEntity,
   isActive: true,
+  lastActiveAt: new Date(),
   courseUser: [],
   signUpLanguage: 'en',
   subscriptionUser: [],

src/typeorm.config.ts

@@ -44,6 +44,7 @@ import { bloomBackend1696994943309 } from './migrations/1696994943309-bloom-back
 import { bloomBackend1697818259254 } from './migrations/1697818259254-bloom-backend';
 import { bloomBackend1698136145516 } from './migrations/1698136145516-bloom-backend';
 import { bloomBackend1706174260018 } from './migrations/1706174260018-bloom-backend';
+import { BloomBackend1718300621138 } from './migrations/1718300621138-bloom-backend';
 
 config();
 const configService = new ConfigService();
@@ -108,6 +109,7 @@ export const dataSourceOptions = {
     bloomBackend1697818259254,
     bloomBackend1698136145516,
     bloomBackend1706174260018,
+    BloomBackend1718300621138,
   ],
   subscribers: [],
   ssl: isProduction,

src/user/dtos/update-user.dto.ts

@@ -1,5 +1,5 @@
 import { ApiProperty } from '@nestjs/swagger';
-import { IsBoolean, IsOptional, IsString } from 'class-validator';
+import { IsBoolean, IsDate, IsOptional, IsString } from 'class-validator';
 
 export class UpdateUserDto {
   @IsString()
@@ -21,4 +21,9 @@ export class UpdateUserDto {
   @IsOptional()
   @ApiProperty({ type: String })
   signUpLanguage: string;
+
+  @IsDate()
+  @IsOptional()
+  @ApiProperty({ type: 'date' })
+  lastActiveAt: Date;
 }

src/user/user.controller.ts

@@ -44,13 +44,15 @@ export class UserController {
   @Get('/me')
   @UseGuards(FirebaseAuthGuard)
   async getUserByFirebaseId(@Req() req: Request): Promise<GetUserDto> {
-    return req['user'];
+    const user = req['user'];
+    this.userService.updateUser({ lastActiveAt: new Date() }, user);
+    return user;
   }
 
   /**
    * This POST endpoint deviates from REST patterns.
    * Please use `getUserByFirebaseId` above which is a GET endpoint.
-   * Do not delete this until frontend usage is migrated.
+   * Safe to delete function below from July 2024 - allowing for caches to clear
    */
   @ApiBearerAuth('access-token')
   @ApiOperation({

src/user/user.interface.ts

@@ -6,6 +6,7 @@ export interface IUser {
   name: string;
   email: string;
   isActive: boolean;
+  lastActiveAt: Date | string;
   crispTokenId: string;
   isSuperAdmin: boolean;
   signUpLanguage: string;

src/user/user.service.spec.ts

@@ -42,17 +42,7 @@ const createUserDto: CreateUserDto = {
   signUpLanguage: 'en',
 };
 
-const createUserRepositoryDto = {
-  email: '[email protected]',
-  password: 'password',
-  name: 'name',
-  contactPermission: false,
-  serviceEmailsPermission: true,
-  signUpLanguage: 'en',
-  firebaseUid: mockUserRecord.uid,
-};
-
-const updateUserDto: UpdateUserDto = {
+const updateUserDto: Partial<UpdateUserDto> = {
   name: 'new name',
   contactPermission: true,
   serviceEmailsPermission: false,
@@ -123,7 +113,12 @@ describe('UserService', () => {
       const repoSaveSpy = jest.spyOn(repo, 'save');
 
       const user = await service.createUser(createUserDto);
-      expect(repoSaveSpy).toHaveBeenCalledWith(createUserRepositoryDto);
+      expect(repoSaveSpy).toHaveBeenCalledWith({
+        ...createUserDto,
+        firebaseUid: mockUserRecord.uid,
+        lastActiveAt: user.user.lastActiveAt,
+      });
+
       expect(user.user.email).toBe('[email protected]');
       expect(user.partnerAdmin).toBeNull();
       expect(user.partnerAccesses).toBeNull();
@@ -135,6 +130,7 @@ describe('UserService', () => {
         segments: ['public'],
       });
       expect(updateCrispProfile).toHaveBeenCalled();
+      expect(createMailchimpProfile).toHaveBeenCalled();
     });
 
     it('when supplied with user dto and partner access code, it should return a new partner user', async () => {
@@ -169,6 +165,7 @@ describe('UserService', () => {
       expect(updateCrispProfile).toHaveBeenCalledWith(
         {
           signed_up_at: user.user.createdAt,
+          last_active_at: (user.user.lastActiveAt as Date).toISOString(),
           marketing_permission: true,
           service_emails_permission: true,
           partners: 'bumble',
@@ -179,6 +176,7 @@ describe('UserService', () => {
         },
         '[email protected]',
       );
+      expect(createMailchimpProfile).toHaveBeenCalled();
     });
 
     it('when supplied with user dto and partner access that has already been used, it should return an error', async () => {
@@ -228,7 +226,7 @@ describe('UserService', () => {
       ]);
     });
 
-    it('should not fail on crisp api call errors', async () => {
+    it('should not fail create on crisp api call errors', async () => {
       const mocked = jest.mocked(createCrispProfile);
       mocked.mockRejectedValue(new Error('Crisp API call failed'));
 
@@ -240,7 +238,7 @@ describe('UserService', () => {
       mocked.mockReset();
     });
 
-    it('should not fail on mailchimp api call errors', async () => {
+    it('should not fail create on mailchimp api call errors', async () => {
       const mocked = jest.mocked(createMailchimpProfile);
       mocked.mockRejectedValue(new Error('Mailchimp API call failed'));
 
@@ -290,25 +288,25 @@ describe('UserService', () => {
       expect(repoSaveSpy).toHaveBeenCalled();
     });
 
-    it('should not fail on crisp api call errors', async () => {
+    it('should not fail update on crisp api call errors', async () => {
       const mocked = jest.mocked(updateCrispProfile);
       mocked.mockRejectedValue(new Error('Crisp API call failed'));
 
       const user = await service.updateUser(updateUserDto, { user: mockUserEntity });
-
+      await new Promise(process.nextTick); // wait for async funcs to resolve
       expect(mocked).toHaveBeenCalled();
       expect(user.name).toBe('new name');
       expect(user.email).toBe('[email protected]');
 
       mocked.mockReset();
     });
 
-    it('should not fail on mailchimp api call errors', async () => {
+    it('should not fail update on mailchimp api call errors', async () => {
       const mocked = jest.mocked(updateMailchimpProfile);
       mocked.mockRejectedValue(new Error('Mailchimp API call failed'));
 
       const user = await service.updateUser(updateUserDto, { user: mockUserEntity });
-
+      await new Promise(process.nextTick); // wait for async funcs to resolve
       expect(mocked).toHaveBeenCalled();
       expect(user.name).toBe('new name');
       expect(user.email).toBe('[email protected]');

src/user/user.service.ts

@@ -67,6 +67,7 @@ export class UserService {
 
       const user = await this.userRepository.save({
         ...createUserDto,
+        lastActiveAt: new Date(),
         firebaseUid: firebaseUser.uid,
       });
 
@@ -190,7 +191,7 @@ export class UserService {
     return await this.deleteUser(user);
   }
 
-  public async updateUser(updateUserDto: UpdateUserDto, { user: { id } }: GetUserDto) {
+  public async updateUser(updateUserDto: Partial<UpdateUserDto>, { user: { id } }: GetUserDto) {
     const user = await this.userRepository.findOneBy({ id });
 
     if (!user) {
@@ -203,9 +204,10 @@ export class UserService {
     };
     const updatedUser = await this.userRepository.save(newUserData);
 
-    const isNameOrLanguageUpdated =
-      user.signUpLanguage !== updateUserDto.signUpLanguage && user.name !== updateUserDto.name;
-    updateServiceUserProfilesUser(user, isNameOrLanguageUpdated, user.email);
+    const isCrispBaseUpdateRequired =
+      (user.signUpLanguage !== updateUserDto.signUpLanguage && user.name !== updateUserDto.name) ||
+      user.lastActiveAt !== updateUserDto.lastActiveAt;
+    updateServiceUserProfilesUser(user, isCrispBaseUpdateRequired, user.email);
 
     return updatedUser;
   }

src/utils/serialize.ts

@@ -87,6 +87,7 @@ export const formatUserObject = (userObject: UserEntity): GetUserDto => {
       email: userObject.email,
       firebaseUid: userObject.firebaseUid,
       isActive: userObject.isActive,
+      lastActiveAt: userObject.lastActiveAt,
       crispTokenId: userObject.crispTokenId,
       isSuperAdmin: userObject.isSuperAdmin,
       signUpLanguage: userObject.signUpLanguage,
@@ -122,6 +123,7 @@ export const formatGetUsersObject = (userObject: UserEntity): GetUserDto => {
       email: userObject.email,
       firebaseUid: userObject.firebaseUid,
       isActive: userObject.isActive,
+      lastActiveAt: userObject.lastActiveAt,
       crispTokenId: userObject.crispTokenId,
       isSuperAdmin: userObject.isSuperAdmin,
       signUpLanguage: userObject.signUpLanguage,

src/utils/serviceUserProfiles.spec.ts

@@ -45,11 +45,15 @@ describe('Service user profiles', () => {
         segments: ['public'],
       });
 
+      const createdAt = mockUserEntity.createdAt.toISOString();
+      const lastActiveAt = mockUserEntity.lastActiveAt.toISOString();
+
       expect(updateCrispProfile).toHaveBeenCalledWith(
         {
           marketing_permission: mockUserEntity.contactPermission,
           service_emails_permission: mockUserEntity.serviceEmailsPermission,
-          signed_up_at: mockUserEntity.createdAt.toISOString(),
+          signed_up_at: createdAt,
+          last_active_at: lastActiveAt,
           feature_live_chat: true,
           feature_therapy: false,
           partners: '',
@@ -71,7 +75,8 @@ describe('Service user profiles', () => {
           },
         ],
         merge_fields: {
-          SIGNUPD: mockUserEntity.createdAt.toISOString(),
+          SIGNUPD: createdAt,
+          LACTIVED: lastActiveAt,
           NAME: mockUserEntity.name,
           FEATCHAT: 'true',
           FEATTHER: 'false',
@@ -86,6 +91,8 @@ describe('Service user profiles', () => {
       await createServiceUserProfiles(mockUserEntity, mockPartnerEntity, mockPartnerAccessEntity);
 
       const partnerName = mockPartnerEntity.name.toLowerCase();
+      const createdAt = mockUserEntity.createdAt.toISOString();
+      const lastActiveAt = mockUserEntity.lastActiveAt.toISOString();
 
       expect(createCrispProfile).toHaveBeenCalledWith({
         email: mockUserEntity.email,
@@ -95,10 +102,11 @@ describe('Service user profiles', () => {
 
       expect(updateCrispProfile).toHaveBeenCalledWith(
         {
-          signed_up_at: mockUserEntity.createdAt.toISOString(),
+          signed_up_at: createdAt,
           marketing_permission: mockUserEntity.contactPermission,
           service_emails_permission: mockUserEntity.serviceEmailsPermission,
           partners: partnerName,
+          last_active_at: lastActiveAt,
           feature_live_chat: mockPartnerAccessEntity.featureLiveChat,
           feature_therapy: mockPartnerAccessEntity.featureTherapy,
           therapy_sessions_remaining: mockPartnerAccessEntity.therapySessionsRemaining,
@@ -120,6 +128,7 @@ describe('Service user profiles', () => {
         ],
         merge_fields: {
           SIGNUPD: mockUserEntity.createdAt.toISOString(),
+          LACTIVED: lastActiveAt,
           NAME: mockUserEntity.name,
           PARTNERS: partnerName,
           FEATCHAT: String(mockPartnerAccessEntity.featureLiveChat),
@@ -142,10 +151,13 @@ describe('Service user profiles', () => {
     it('should update crisp and mailchimp profile user data', async () => {
       await updateServiceUserProfilesUser(mockUserEntity, false, mockUserEntity.email);
 
+      const lastActiveAt = mockUserEntity.lastActiveAt.toISOString();
+
       expect(updateCrispProfile).toHaveBeenCalledWith(
         {
           marketing_permission: mockUserEntity.contactPermission,
           service_emails_permission: mockUserEntity.serviceEmailsPermission,
+          last_active_at: lastActiveAt,
         },
         mockUserEntity.email,
       );
@@ -161,7 +173,7 @@ describe('Service user profiles', () => {
               enabled: mockUserEntity.contactPermission,
             },
           ],
-          merge_fields: { NAME: mockUserEntity.name },
+          merge_fields: { NAME: mockUserEntity.name, LACTIVED: lastActiveAt },
         },
         mockUserEntity.email,
       );
@@ -173,13 +185,15 @@ describe('Service user profiles', () => {
         contactPermission: false,
         serviceEmailsPermission: false,
       };
+      const lastActiveAt = mockUserEntity.lastActiveAt.toISOString();
 
       await updateServiceUserProfilesUser(mockUser, false, mockUser.email);
 
       expect(updateCrispProfile).toHaveBeenCalledWith(
         {
           marketing_permission: false,
           service_emails_permission: false,
+          last_active_at: lastActiveAt,
         },
         mockUser.email,
       );
@@ -195,7 +209,7 @@ describe('Service user profiles', () => {
               enabled: false,
             },
           ],
-          merge_fields: { NAME: mockUser.name },
+          merge_fields: { NAME: mockUser.name, LACTIVED: lastActiveAt },
         },
         mockUser.email,
       );

src/utils/serviceUserProfiles.ts

@@ -214,11 +214,13 @@ const serializeCrispPartnerSegments = (partners: PartnerEntity[]) => {
 };
 
 const serializeUserData = (user: UserEntity) => {
-  const { name, signUpLanguage, contactPermission, serviceEmailsPermission } = user;
+  const { name, signUpLanguage, contactPermission, serviceEmailsPermission, lastActiveAt } = user;
+  const lastActiveAtString = lastActiveAt?.toISOString() || '';
 
   const crispSchema = {
     marketing_permission: contactPermission,
     service_emails_permission: serviceEmailsPermission,
+    last_active_at: lastActiveAtString,
     // Name and language handled on base level profile for crisp
   };
 
@@ -232,7 +234,7 @@ const serializeUserData = (user: UserEntity) => {
       },
     ],
     language: signUpLanguage || 'en',
-    merge_fields: { NAME: name },
+    merge_fields: { NAME: name, LACTIVED: lastActiveAtString },
   } as ListMemberPartial;
 
   return { crispSchema, mailchimpSchema };