fix: send recruiter to match accepted (#3187)

Author: rebelchris

__tests__/workers/cdc/primary.ts

@@ -172,7 +172,10 @@ import {
 } from '../../../src/entity/contentPreference/types';
 import { OpportunityMatch } from '../../../src/entity/OpportunityMatch';
 import { UserCandidatePreference } from '../../../src/entity/user/UserCandidatePreference';
-import { OpportunityMatchStatus } from '../../../src/entity/opportunities/types';
+import {
+  OpportunityMatchStatus,
+  OpportunityUserType,
+} from '../../../src/entity/opportunities/types';
 import { OpportunityJob } from '../../../src/entity/opportunities/OpportunityJob';
 import {
   opportunitiesFixture,
@@ -185,6 +188,7 @@ import {
   ContentPreferenceOrganization,
   ContentPreferenceOrganizationStatus,
 } from '../../../src/entity/contentPreference/ContentPreferenceOrganization';
+import { OpportunityUser } from '../../../src/entity/opportunities/user';
 
 jest.mock('../../../src/common', () => ({
   ...(jest.requireActual('../../../src/common') as Record<string, unknown>),
@@ -5643,6 +5647,13 @@ describe('opportunity match', () => {
 
   beforeEach(async () => {
     await saveFixtures(con, User, usersFixture);
+    await con.getRepository(User).update(
+      { id: usersFixture[0].id },
+      {
+        title: 'CTO',
+        bio: 'Here to break things',
+      },
+    );
     await saveFixtures(con, Organization, organizationsFixture);
     await saveFixtures(con, Opportunity, opportunitiesFixture);
     await con.getRepository(UserCandidatePreference).save({
@@ -5659,6 +5670,11 @@ describe('opportunity match', () => {
       screening: [],
       applicationRank: {},
     });
+    await con.getRepository(OpportunityUser).save({
+      userId: usersFixture[0].id,
+      opportunityId: opportunitiesFixture[0].id,
+      type: OpportunityUserType.Recruiter,
+    });
   });
 
   describe('candidate accepted', () => {
@@ -5800,6 +5816,11 @@ describe('opportunity match', () => {
         expect.objectContaining({
           opportunityId: opportunitiesFixture[0].id,
           userId: '1',
+          recruiter: {
+            name: 'Ido',
+            role: 'CTO',
+            bio: 'Here to break things',
+          },
         }),
       );
     });

package.json

@@ -36,7 +36,7 @@
     "@connectrpc/connect-fastify": "^1.6.1",
     "@connectrpc/connect-node": "^1.6.1",
     "@dailydotdev/graphql-redis-subscriptions": "^2.4.3",
-    "@dailydotdev/schema": "0.2.40",
+    "@dailydotdev/schema": "0.2.47",
     "@dailydotdev/ts-ioredis-pool": "^1.0.2",
     "@fastify/cookie": "^11.0.2",
     "@fastify/cors": "^11.1.0",

pnpm-lock.yaml

@@ -24,6 +24,8 @@ import {
   ContentPreferenceType,
 } from '../../entity/contentPreference/types';
 import { ContentPreferenceOrganization } from '../../entity/contentPreference/ContentPreferenceOrganization';
+import { OpportunityUser } from '../../entity/opportunities/user';
+import { OpportunityUserType } from '../../entity/opportunities/types';
 
 const fetchCandidateKeywords = async (
   manager: EntityManager,
@@ -171,14 +173,32 @@ export const notifyRecruiterCandidateMatchAccepted = async ({
     return;
   }
 
-  const match = await queryReadReplica(con, async ({ queryRunner }) => {
-    return queryRunner.manager.getRepository(OpportunityMatch).findOne({
-      select: ['opportunityId', 'userId'],
-      where: { opportunityId: data.opportunityId, userId: data.userId },
-    });
-  });
+  /**
+   * TODO: For now this will simply fetch the first recruiter.
+   * Ideally this should maintain which recruiter accepted the match
+   */
+  const [match, opportunityUser] = await queryReadReplica(
+    con,
+    ({ queryRunner }) =>
+      Promise.all([
+        queryRunner.manager.getRepository(OpportunityMatch).findOne({
+          select: ['opportunityId', 'userId'],
+          where: { opportunityId: data.opportunityId, userId: data.userId },
+        }),
+        queryRunner.manager.getRepository(OpportunityUser).findOne({
+          select: ['userId', 'opportunityId', 'type'],
+          relations: ['user'],
+          where: {
+            opportunityId: data.opportunityId,
+            type: OpportunityUserType.Recruiter,
+          },
+        }),
+      ]),
+  );
 
-  if (!match) {
+  const recruiter = await opportunityUser?.user;
+
+  if (!match || !recruiter) {
     logger.warn(
       { opportunityId: data.opportunityId, userId: data.userId },
       'Opportunity match not found for recruiter accepted candidate notification',
@@ -191,6 +211,11 @@ export const notifyRecruiterCandidateMatchAccepted = async ({
     userId: match.userId,
     createdAt: getSecondsTimestamp(match.createdAt),
     updatedAt: getSecondsTimestamp(match.updatedAt),
+    recruiter: {
+      name: recruiter.name,
+      role: recruiter?.title,
+      bio: recruiter?.bio,
+    },
   });
 
   try {