current draft

Author: isabelle huang

backend/typescript/graphql/resolvers/reviewedApplicantRecordResolver.ts

@@ -0,0 +1,61 @@
+import ReviewedApplicantRecordService from "../../services/implementations/reviewedApplicantRecordService";
+import { ReviewedApplicantRecordDTO, CreateReviewedApplicantRecordDTO } from "../../types";
+import { getErrorMessage } from "../../utilities/errorUtils";
+
+const reviewedApplicantRecordService = new ReviewedApplicantRecordService();
+
+const reviewedApplicantRecordResolvers = {
+  Mutation: {
+    createReviewedApplicantRecord: async (
+      _parent: undefined,
+      args: { input: CreateReviewedApplicantRecordDTO },
+    ): Promise<ReviewedApplicantRecordDTO> => {
+      try {
+        return await reviewedApplicantRecordService.createReviewedApplicantRecord(args.input);
+      } catch (error) {
+        throw new Error(getErrorMessage(error));
+      }
+    },
+
+    bulkCreateReviewedApplicantRecord: async (
+      _parent: undefined,
+      args: { inputs: CreateReviewedApplicantRecordDTO[] },
+    ): Promise<ReviewedApplicantRecordDTO[]> => {
+      try {
+        return await reviewedApplicantRecordService.bulkCreateReviewedApplicantRecord(args.inputs);
+      } catch (error) {
+        throw new Error(getErrorMessage(error));
+      }
+    },
+
+    deleteReviewedApplicantRecord: async (
+      _parent: undefined,
+      args: { applicantRecordId: string; reviewerId: number },
+    ): Promise<ReviewedApplicantRecordDTO> => {
+      try {
+        return await reviewedApplicantRecordService.deleteReviewedApplicantRecord(
+          args.applicantRecordId,
+          args.reviewerId,
+        );
+      } catch (error) {
+        throw new Error(getErrorMessage(error));
+      }
+    },
+
+    bulkDeleteReviewedApplicantRecord: async (
+      _parent: undefined,
+      args: { applicantRecordIds: string[]; reviewerId: number },
+    ): Promise<ReviewedApplicantRecordDTO[]> => {
+      try {
+        return await reviewedApplicantRecordService.bulkDeleteReviewedApplicantRecord(
+          args.applicantRecordIds,
+          args.reviewerId,
+        );
+      } catch (error) {
+        throw new Error(getErrorMessage(error));
+      }
+    },
+  },
+};
+
+export default reviewedApplicantRecordResolvers;

backend/typescript/graphql/types/reviewedApplicantRecordTypes.ts

@@ -0,0 +1,41 @@
+import { gql } from "apollo-server-express";
+
+const reviewedApplicantRecordTypes = gql`
+  type ReviewedApplicantRecord {
+    applicantRecordId: ID!
+    reviewerId: Int!
+    review: JSON
+    status: String
+    score: Int
+    reviewerHasConflict: Boolean
+  }
+
+  input CreateReviewedApplicantRecordInput {
+    applicantRecordId: ID!
+    reviewerId: Int!
+    review: JSON
+    status: String
+  }
+
+  type Mutation {
+    createReviewedApplicantRecord(
+      input: CreateReviewedApplicantRecordInput!
+    ): ReviewedApplicantRecord!
+
+    bulkCreateReviewedApplicantRecord(
+      inputs: [CreateReviewedApplicantRecordInput!]!
+    ): [ReviewedApplicantRecord!]!
+
+    deleteReviewedApplicantRecord(
+      applicantRecordId: ID!
+      reviewerId: Int!
+    ): ReviewedApplicantRecord!
+
+    bulkDeleteReviewedApplicantRecord(
+      applicantRecordIds: [ID!]!
+      reviewerId: Int!
+    ): [ReviewedApplicantRecord!]!
+  }
+`;
+
+export default reviewedApplicantRecordTypes;

backend/typescript/services/implementations/reviewedApplicantRecordService.ts

@@ -0,0 +1,64 @@
+import { sequelize } from "../../models";
+import ReviewedApplicantRecord from "../../models/reviewedApplicantRecord.model";
+import { 
+    ReviewedApplicantRecordDTO, 
+    CreateReviewedApplicantRecordDTO 
+} from "../../types";
+
+import IReviewApplicantRecordService from "../interfaces/reviewedApplicantRecordService";
+
+class ReviewedApplicantRecordService implements IReviewApplicantRecordService {
+
+    async createReviewedApplicantRecord(
+        dto: CreateReviewedApplicantRecordDTO
+    ): Promise<ReviewedApplicantRecordDTO> {
+        const record = await ReviewedApplicantRecord.create(dto);
+        return record.toJSON() as ReviewedApplicantRecordDTO;
+    }
+
+    async bulkCreateReviewedApplicantRecord(
+        createReviewedApplicantRecordDTOs: CreateReviewedApplicantRecordDTO[]
+    ): Promise<ReviewedApplicantRecordDTO[]> {
+        const reviewedApplicantRecords = await sequelize.transaction(async (t) => {
+            const records = await ReviewedApplicantRecord.bulkCreate(
+                createReviewedApplicantRecordDTOs,
+                { transaction: t }
+            );
+            return records;
+        });
+
+        return reviewedApplicantRecords.map((record) =>
+            record.toJSON() as ReviewedApplicantRecordDTO
+        );
+    }
+
+    // Methods deleteReviewedApplicantRecord and bulkDeleteReviewedApplicantRecord would be implemented here
+    async deleteReviewedApplicantRecord(applicantRecordId: string, reviewerId: number): Promise<ReviewedApplicantRecordDTO> {
+        const record = await ReviewedApplicantRecord.findOne({ where: { applicantRecordId, reviewerId } });
+
+        if (!record) {
+            throw new Error("ReviewedApplicantRecord not found");
+        }
+
+        await record.destroy();
+        return record.toJSON() as ReviewedApplicantRecordDTO;   
+    }
+
+    async bulkDeleteReviewedApplicantRecord(applicantRecordIds: string[], reviewerId: number): Promise<ReviewedApplicantRecordDTO[]> {
+        const deletedRecords = await sequelize.transaction(async (t) => {
+            const records = await ReviewedApplicantRecord.findAll({
+                where: { applicantRecordId: applicantRecordIds, reviewerId },
+                transaction: t,
+            });
+
+            if (records.length === 0) return [];
+
+            await Promise.all(records.map((r) => r.destroy({ transaction: t })));
+            return records;
+        });
+
+        return deletedRecords.map((r) => r.toJSON() as ReviewedApplicantRecordDTO);
+    }
+}
+
+export default ReviewedApplicantRecordService;

backend/typescript/services/interfaces/reviewedApplicantRecordService.ts

@@ -0,0 +1,44 @@
+import { 
+    ReviewedApplicantRecordDTO, 
+    CreateReviewedApplicantRecordDTO 
+} from "../../types";
+
+interface IReviewApplicantRecordService {
+  /**
+   * Creates a single reviewed applicant record entry
+   * @Param createReviewedApplicantRecordDTO data to create reviewed applicant record
+   */
+  createReviewedApplicantRecord(
+    createReviewedApplicantRecordDTO: CreateReviewedApplicantRecordDTO
+  ): Promise<ReviewedApplicantRecordDTO>;
+
+  /**
+   * Creates multiple reviewed applicant record entries in bulk
+   * @Param createReviewedApplicantRecordDTOs array of data to create reviewed applicant records
+   */
+  bulkCreateReviewedApplicantRecord(
+    createReviewedApplicantRecordDTOs: CreateReviewedApplicantRecordDTO[]
+  ): Promise<ReviewedApplicantRecordDTO[]>;
+
+  /**
+   * Deletes a single reviewed applicant record entry
+   * @Param applicantRecordId the ID of applicant record to delete
+   * @Param reviewerId the ID of the reviewer
+   */
+  deleteReviewedApplicantRecord(
+    applicantRecordId: string,
+    reviewerId: number
+  ): Promise<ReviewedApplicantRecordDTO>;
+
+  /**
+   * Deletes multiple reviewed applicant record entries in bulk
+   * @Param applicantRecordIds array of applicant record IDs to delete
+   * @Param reviewerId the ID of the reviewer
+   */
+  bulkDeleteReviewedApplicantRecord(
+    applicantRecordIds: string[],
+    reviewerId: number
+  ): Promise<ReviewedApplicantRecordDTO[]>;
+}
+
+export default IReviewApplicantRecordService;

backend/typescript/types.ts

@@ -255,3 +255,10 @@ export type ReviewedApplicantRecordDTO = {
   score?: number | null;
   reviewerHasConflict: boolean;
 };
+
+export type CreateReviewedApplicantRecordDTO = {
+  applicantRecordId: string;
+  reviewerId: number;
+  review?: Review;
+  reviewerHasConflict?: boolean;
+}