feat: indicate self apply on candidate match

Author: capJavert

__tests__/schema/opportunity.ts

@@ -3029,7 +3029,9 @@ describe('mutation opportunityApply', () => {
       description: {},
       screening: [],
       feedback: [],
-      applicationRank: {},
+      applicationRank: {
+        selfApplied: true,
+      },
     });
   });
 

__tests__/workers/opportunity/storeCandidateApplicationScore.ts

@@ -60,7 +60,11 @@ describe('storeCandidateApplicationScore worker', () => {
     await con.getRepository(OpportunityMatch).save({
       userId: '1',
       opportunityId: '550e8400-e29b-41d4-a716-446655440001',
-      applicationRank: { score: 60, description: 'Previous score' },
+      applicationRank: {
+        score: 60,
+        description: 'Previous score',
+        selfApplied: true,
+      },
     });
 
     const updatedScoreData = new ApplicationScored({
@@ -86,6 +90,7 @@ describe('storeCandidateApplicationScore worker', () => {
     expect(match?.applicationRank).toEqual({
       score: 90,
       description: 'Updated score after review',
+      selfApplied: true,
     });
   });
 

src/common/schema/opportunities.ts

@@ -28,6 +28,7 @@ export const applicationScoreSchema = z.object({
   score: z.number().min(0).max(100).optional(),
   description: z.string().optional(),
   warmIntro: z.string().optional(),
+  selfApplied: z.boolean().optional(),
 });
 
 export const opportunityContentSchema = z.object({

src/schema/opportunity.ts

@@ -3063,7 +3063,9 @@ export const resolvers: IResolvers<unknown, BaseContext> = traceResolvers<
           description: {},
           screening: [],
           feedback: [],
-          applicationRank: {},
+          applicationRank: {
+            selfApplied: true,
+          },
         }),
       );
 

src/workers/candidateReviewOpportunitySlack.ts

@@ -110,6 +110,13 @@ const worker: TypedWorker<'gondul.v1.candidate-application-scored'> = {
             text: `*Skills:*\n${keywords.map((k) => k.keyword).join(', ') || 'N/A'}`,
           },
         },
+        {
+          type: 'section',
+          text: {
+            type: 'mrkdwn',
+            text: `*Self applied:*\n${match.applicationRank?.selfApplied ? 'Yes' : 'No'}`,
+          },
+        },
         {
           type: 'section',
           text: {

src/workers/opportunity/storeCandidateApplicationScore.ts

@@ -30,17 +30,28 @@ export const storeCandidateApplicationScore: TypedWorker<'gondul.v1.candidate-ap
         description,
       });
 
-      await con.getRepository(OpportunityMatch).upsert(
-        {
+      const matchExists = await con.getRepository(OpportunityMatch).exists({
+        where: { userId, opportunityId },
+      });
+
+      if (matchExists) {
+        await con.getRepository(OpportunityMatch).update(
+          {
+            userId,
+            opportunityId,
+          },
+          {
+            applicationRank: () =>
+              `"applicationRank" || '${JSON.stringify(applicationRank)}'`,
+          },
+        );
+      } else {
+        await con.getRepository(OpportunityMatch).insert({
           userId,
           opportunityId,
           applicationRank,
-        },
-        {
-          conflictPaths: ['userId', 'opportunityId'],
-          skipUpdateIfNoValuesChanged: true,
-        },
-      );
+        });
+      }
     },
     parseMessage: (message) => ApplicationScored.fromBinary(message.data),
   };