feat: add mutation to reject opportunity match (#3251)

Author: omBratteng

__tests__/schema/opportunity.ts

@@ -1180,6 +1180,90 @@ describe('mutation acceptOpportunityMatch', () => {
   });
 });
 
+describe('mutation rejectOpportunityMatch', () => {
+  const MUTATION = /* GraphQL */ `
+    mutation RejectOpportunityMatch($id: ID!) {
+      rejectOpportunityMatch(id: $id) {
+        _
+      }
+    }
+  `;
+
+  it('should require authentication', async () => {
+    await testMutationErrorCode(
+      client,
+      {
+        mutation: MUTATION,
+        variables: {
+          id: '550e8400-e29b-41d4-a716-446655440001',
+        },
+      },
+      'UNAUTHENTICATED',
+    );
+  });
+
+  it('should accept opportunity match for authenticated user', async () => {
+    loggedUser = '1';
+
+    expect(
+      await con.getRepository(OpportunityMatch).countBy({
+        opportunityId: '550e8400-e29b-41d4-a716-446655440001',
+        userId: '1',
+        status: OpportunityMatchStatus.Pending,
+      }),
+    ).toEqual(1);
+
+    const res = await client.mutate(MUTATION, {
+      variables: {
+        id: '550e8400-e29b-41d4-a716-446655440001',
+      },
+    });
+
+    expect(res.errors).toBeFalsy();
+    expect(res.data.rejectOpportunityMatch).toEqual({ _: true });
+
+    expect(
+      await con.getRepository(OpportunityMatch).countBy({
+        opportunityId: '550e8400-e29b-41d4-a716-446655440001',
+        userId: '1',
+        status: OpportunityMatchStatus.CandidateRejected,
+      }),
+    ).toEqual(1);
+  });
+
+  it('should return error when the match is not pending', async () => {
+    loggedUser = '2';
+
+    await testMutationErrorCode(
+      client,
+      {
+        mutation: MUTATION,
+        variables: {
+          id: '550e8400-e29b-41d4-a716-446655440001',
+        },
+      },
+      'FORBIDDEN',
+      'Access denied! Match is not pending',
+    );
+  });
+
+  it('should return error when the opportunity is not live', async () => {
+    loggedUser = '1';
+
+    await testMutationErrorCode(
+      client,
+      {
+        mutation: MUTATION,
+        variables: {
+          id: '550e8400-e29b-41d4-a716-446655440003',
+        },
+      },
+      'FORBIDDEN',
+      'Access denied! Opportunity is not live',
+    );
+  });
+});
+
 describe('mutation candidateAddKeywords', () => {
   const MUTATION = /* GraphQL */ `
     mutation CandidateAddKeywords($keywords: [String!]!) {

src/schema/opportunity.ts

@@ -302,6 +302,13 @@ export const typeDefs = /* GraphQL */ `
       id: ID!
     ): EmptyResponse @auth
 
+    rejectOpportunityMatch(
+      """
+      Id of the Opportunity
+      """
+      id: ID!
+    ): EmptyResponse @auth
+
     candidateAddKeywords(
       """
       Keywords to add to candidate profile
@@ -602,6 +609,58 @@ export const resolvers: IResolvers<unknown, BaseContext> = traceResolvers<
 
       return { _: true };
     },
+    rejectOpportunityMatch: async (
+      _,
+      { id }: { id: string },
+      { userId, con, log }: AuthContext,
+    ): Promise<GQLEmptyResponse> => {
+      const match = await con.getRepository(OpportunityMatch).findOne({
+        where: {
+          opportunityId: id,
+          userId,
+        },
+        relations: {
+          opportunity: true,
+        },
+      });
+
+      if (!match) {
+        log.error(
+          { opportunityId: id, userId },
+          'No match found for opportunity',
+        );
+        throw new ForbiddenError('Access denied! No match found');
+      }
+
+      if (match.status !== OpportunityMatchStatus.Pending) {
+        log.error(
+          { opportunityId: id, userId, status: match.status },
+          'Match is not pending',
+        );
+        throw new ForbiddenError(`Access denied! Match is not pending`);
+      }
+
+      const opportunity = await match.opportunity;
+      if (opportunity.state !== OpportunityState.LIVE) {
+        log.error(
+          { opportunityId: id, userId, state: opportunity.state },
+          'Opportunity is not live',
+        );
+        throw new ForbiddenError(`Access denied! Opportunity is not live`);
+      }
+
+      await con.getRepository(OpportunityMatch).update(
+        {
+          opportunityId: id,
+          userId,
+        },
+        {
+          status: OpportunityMatchStatus.CandidateRejected,
+        },
+      );
+
+      return { _: true };
+    },
     candidateAddKeywords: async (
       _,
       payload: z.infer<typeof userCandidateToggleKeywordSchema>,