update

Author: eisbilir

src/domain/Sync.ts

@@ -2,26 +2,38 @@
 /* eslint-disable @typescript-eslint/no-unsafe-argument */
 /* eslint-disable @typescript-eslint/no-unsafe-member-access */
 /* eslint-disable @typescript-eslint/no-unsafe-assignment */
-import { Operator, QueryBuilder } from "@topcoder-framework/client-relational";
+import { QueryBuilder } from "@topcoder-framework/client-relational";
 import { ChallengeDomain } from "@topcoder-framework/domain-challenge";
 import _ from "lodash";
 import { queryRunner } from "../helper/QueryRunner";
 
+import { Challenge } from "@topcoder-framework/domain-challenge/dist-es/models/domain-layer/challenge/challenge";
+import { Operator } from "@topcoder-framework/lib-common";
 import LegacyChallengeDomain from "../domain/LegacyChallenge";
 import { LegacyChallenge, LegacyChallengeId } from "../models/domain-layer/legacy/challenge";
 import { SyncInput, Table } from "../models/domain-layer/legacy/sync";
 
+const challengeDomain = new ChallengeDomain(
+  process.env.GRPC_CHALLENGE_DOMAIN_SERVER_HOST!,
+  process.env.GRPC_CHALLENGE_DOMAIN_SERVER_PORT!
+);
+
 class LegacySyncDomain {
   public async syncLegacy(input: SyncInput): Promise<void> {
     const legacyId = input.projectId;
     const payload = {};
     const legacyChallenge = await LegacyChallengeDomain.getLegacyChallenge(
       LegacyChallengeId.create({ legacyChallengeId: legacyId })
     );
+    const { items } = await challengeDomain.scan({
+      criteria: [{ key: "legacyId", operator: Operator.OPERATOR_EQUAL, value: legacyId }],
+    });
+    const v5Challenge: Challenge = items[0];
+
     for (const table of input.updatedTables) {
       switch (table.table) {
         case "project":
-          _.assign(payload, this.handleProjectUpdate(table.value, legacyChallenge));
+          _.assign(payload, this.handleProjectUpdate(table.value, legacyChallenge, v5Challenge));
           break;
         case "project_phase":
           break;
@@ -42,12 +54,16 @@ class LegacySyncDomain {
     }
   }
 
-  private handleProjectUpdate(columnNames: string[], legacyChallenge: LegacyChallenge) {
+  private handleProjectUpdate(
+    columnNames: string[],
+    legacyChallenge: LegacyChallenge,
+    v5Challenge: Challenge
+  ) {
     const payload = {};
     for (const columnName of columnNames) {
       switch (columnName) {
         case "project_status_id":
-          _.assign(payload, this.handleStatusChange(legacyChallenge, {}));
+          _.assign(payload, this.handleStatusChange(legacyChallenge, v5Challenge));
           break;
         case "project_category_id":
           break;
@@ -58,30 +74,51 @@ class LegacySyncDomain {
     }
   }
 
-  private handleStatusChange(legacyChallenge: LegacyChallenge, v5Challenge) {
-    const challengeStatusOrders = {
+  private handleStatusChange(legacyChallenge: LegacyChallenge, v5Challenge: Challenge) {
+    interface IchallengeStatusOrders {
+      Draft: number;
+      Active: number;
+      Completed: number;
+      Deleted: number;
+      Cancelled: number;
+    }
+    const challengeStatusOrders: IchallengeStatusOrders = {
       Draft: 1,
       Active: 2,
       Completed: 3,
       Deleted: 3,
       Cancelled: 3,
     };
-    const challengeStatusMap = {
+    interface IchallengeStatusMap {
+      1: string;
+      2: string;
+      3: string;
+      7: string;
+    }
+    const challengeStatusMap: IchallengeStatusMap = {
       1: "Active",
       2: "Draft",
       3: "Deleted",
       7: "Completed",
     };
-    /*
-    const v4StatusNumber = challengeStatusOrders[challengeStatusMap[legacyChallenge.projectStatusId]] || challengeStatusOrders.Cancelled
-    const v5StatusNumber = challengeStatusOrders[v5Challenge.status] || challengeStatusOrders.Cancelled
+
+    const v4StatusNumber =
+      challengeStatusOrders[
+        challengeStatusMap[
+          legacyChallenge.projectStatusId as keyof IchallengeStatusMap
+        ] as keyof IchallengeStatusOrders
+      ] || challengeStatusOrders.Cancelled;
+    const v5StatusNumber =
+      challengeStatusOrders[v5Challenge.status as keyof IchallengeStatusOrders] ||
+      challengeStatusOrders.Cancelled;
 
     if (v4StatusNumber >= v5StatusNumber) {
-      return { status: challengeStatusMap[legacyChallenge.projectStatusId] }
+      return {
+        status: challengeStatusMap[legacyChallenge.projectStatusId as keyof IchallengeStatusMap],
+      };
     } else {
-      return {}
+      return {};
     }
-    */
   }
 }