feat(submission): wip- legacy submission

Author: hamidre13

package.json

@@ -16,8 +16,8 @@
   "license": "ISC",
   "dependencies": {
     "@grpc/grpc-js": "^1.7.1",
-    "@topcoder-framework/client-relational": "^0.4.24-ci.0",
-    "@topcoder-framework/lib-common": "^0.4.24-ci.0",
+    "@topcoder-framework/client-relational": "^0.5.1-ci.0",
+    "@topcoder-framework/lib-common": "^0.5.1-ci.0",
     "dayjs": "^1.11.5",
     "dotenv": "^16.0.3",
     "grpc-server-reflection": "^0.1.5",
@@ -37,4 +37,4 @@
     "node": "18.13.0",
     "yarn": "1.22.19"
   }
-}
+}

src/config.ts

@@ -0,0 +1,13 @@
+import * as dotenv from "dotenv";
+import assert from "assert";
+dotenv.config();
+
+export const ENV = <string>process.env.ENV || "local";
+export const GRPC_SERVER_HOST = process.env.GRPC_SERVER_HOST || "";
+export const GRPC_SERVER_PORT = process.env.GRPC_SERVER_PORT || 9091;
+
+export const GRPC_RDB_SERVER_HOST = process.env.GRPC_RDB_SERVER_HOST;
+export const GRPC_RDB_SERVER_PORT = process.env.GRPC_RDB_SERVER_PORT;
+
+assert(GRPC_RDB_SERVER_HOST, "GRPC_RDB_SERVER_HOST is required");
+assert(GRPC_RDB_SERVER_PORT, "GRPC_RDB_SERVER_PORT is required");

src/domain/LegacySubmission.ts

@@ -0,0 +1,98 @@
+import { Operator, QueryBuilder } from "@topcoder-framework/client-relational";
+import { queryRunner } from "../helper/QueryRunner";
+import {
+  CreateSubmissionInput,
+} from "../models/domain-layer/legacy/submission";
+import { ProjectSchema } from "../schema/project/Project";
+
+class LegacySubmissionDomain {
+  public async checkSubmissionExists(
+    legacySubmissionId: number
+  ): Promise<any> {
+    const { projectId } = ProjectSchema.columns;
+
+    const query = new QueryBuilder(ProjectSchema)
+      .select(projectId)
+      .where(projectId, Operator.OPERATOR_EQUAL, {
+        value: {
+          $case: "intValue",
+          intValue: legacySubmissionId,
+        },
+      })
+      .limit(1)
+      .build();
+
+    const { rows } = await queryRunner.run(query);
+
+    return {
+      exists: rows?.length == 1,
+    };
+  }
+
+  public async createLegacySubmission(input: CreateSubmissionInput): Promise<number> {
+    const transaction = queryRunner.beginTransaction();
+
+    const createLegacySubmissionQuery = new QueryBuilder(ProjectSchema)
+      .insert({
+        submissionStatusId: input.submissionStatusId,
+        submissionTypeId: input.submissionTypeId,
+        uploadId: input.uploadId,
+        createUser: input.createUser,
+        modifyUser: input.modifyUser,
+        createDate: input.createDate,
+        modifyDate: input.modifyDate,
+      })
+      .build();
+
+    const createLegacySubmissionQueryResult = await transaction.add(createLegacySubmissionQuery);
+    if (createLegacySubmissionQueryResult instanceof Error) {
+      transaction.rollback();
+      return Promise.reject({
+        message: "Failed to create legacy submission",
+      });
+    }
+
+    const { lastInsertId: legacySubmissionId } = createLegacySubmissionQueryResult;
+
+    return Promise.resolve(legacySubmissionId!);
+  }
+
+  // public async listAvailableSubmissionInfoTypes(key: string): Promise<number> {
+  //   const queryRequest: QueryRequest = {
+  //     query: {
+  //       query: {
+  //         $case: "select",
+  //         select: {
+  //           table: "project_info_type_lu",
+  //           join: [],
+  //           column: [
+  //             {
+  //               name: "",
+  //               type: ColumnType.COLUMN_TYPE_INT,
+  //             },
+  //           ],
+  //           where: [
+  //             {
+  //               key: "name",
+  //               operator: Operator.OPERATOR_EQUAL,
+  //               value: {
+  //                 value: {
+  //                   $case: "stringValue",
+  //                   stringValue: key,
+  //                 },
+  //               },
+  //             },
+  //           ],
+  //           groupBy: [],
+  //           orderBy: [],
+  //           limit: 1,
+  //           offset: 0,
+  //         },
+  //       },
+  //     },
+  //   };
+  //   return Promise.resolve(10);
+  // }
+}
+
+export default new LegacySubmissionDomain();

src/helper/QueryRunner.ts

@@ -1,4 +1,4 @@
-const { GRPC_RDB_SERVER_HOST, GRPC_RDB_SERVER_PORT } = process.env;
+import { GRPC_RDB_SERVER_HOST, GRPC_RDB_SERVER_PORT } from '../config'
 
 import { QueryRunner } from "@topcoder-framework/client-relational";