feat: add opportunities to user object in cio (#3269)

Author: idoshamun

__tests__/workers/cdc/primary.ts

@@ -246,6 +246,11 @@ jest.mock('../../../src/temporal/notifications/utils', () => ({
   cancelEntityReminderWorkflow: jest.fn(),
 }));
 
+jest.mock('../../../src/cio', () => ({
+  ...(jest.requireActual('../../../src/cio') as Record<string, unknown>),
+  identifyUserOpportunities: jest.fn(),
+}));
+
 let con: DataSource;
 
 beforeAll(async () => {

src/cio.ts

@@ -46,6 +46,8 @@ import type { UserCompany } from './entity/UserCompany';
 import type { Company } from './entity/Company';
 import { DataSource, In } from 'typeorm';
 import { logger } from './logger';
+import { OpportunityMatch } from './entity/OpportunityMatch';
+import { OpportunityMatchStatus } from './entity/opportunities/types';
 
 export const cio = new TrackClient(
   process.env.CIO_SITE_ID,
@@ -149,6 +151,29 @@ export async function identifyUserStreak({
   }
 }
 
+export const identifyUserOpportunities = async ({
+  cio,
+  con,
+  userId,
+}: {
+  cio: TrackClient;
+  con: ConnectionManager;
+  userId: string;
+}): Promise<void> => {
+  const opportunities = await con.getRepository(OpportunityMatch).find({
+    where: {
+      userId,
+      status: OpportunityMatchStatus.Pending,
+    },
+    select: ['opportunityId'],
+  });
+  await cio.identify(userId, {
+    opportunities: opportunities.map(
+      (opportunity) => opportunity.opportunityId,
+    ),
+  });
+};
+
 export const generateIdentifyObject = async (
   con: ConnectionManager,
   user: ChangeObject<User>,

src/workers/cdc/primary.ts

@@ -162,6 +162,7 @@ import { PollPost } from '../../entity/posts/PollPost';
 import { UserExperienceWork } from '../../entity/user/experiences/UserExperienceWork';
 import { UserExperience } from '../../entity/user/experiences/UserExperience';
 import { UserExperienceType } from '../../entity/user/experiences/types';
+import { cio, identifyUserOpportunities } from '../../cio';
 
 const isFreeformPostLongEnough = (
   freeform: ChangeMessage<FreeformPost>,
@@ -1292,6 +1293,11 @@ const onOpportunityMatchChange = async (
   logger: FastifyBaseLogger,
   data: ChangeMessage<OpportunityMatch>,
 ) => {
+  await identifyUserOpportunities({
+    con,
+    cio,
+    userId: data.payload.after?.userId ?? data.payload.before?.userId ?? '',
+  });
   if (data.payload.op === 'u') {
     if (
       data.payload.after?.status === OpportunityMatchStatus.CandidateAccepted &&