Merge pull request #12 from topcoder-platform/feature/plat-2427

Feature/plat 2427

Author: ThomasKranitsas

src/domain/LegacySubmission.ts

@@ -1,8 +1,12 @@
-import { QueryBuilder, QueryResult } from "@topcoder-framework/client-relational";
+import { Query, QueryBuilder, QueryResult } from "@topcoder-framework/client-relational";
+import { UpdateResult } from "@topcoder-framework/lib-common";
+import { Util } from "../common/Util";
 import SubmissionQueryHelper from "../helper/query-helper/SubmissionQueryHelper";
 import { queryRunner } from "../helper/QueryRunner";
-import { CreateSubmissionInput } from "../models/domain-layer/legacy/submission";
-import { SubmissionSchema } from "../schema/project/Submission";
+import {
+  CreateSubmissionInput, UpdateSubmissionInput
+} from "../models/domain-layer/legacy/submission";
+import { LegacySubmissionSchema } from "../schema/submission/Submission";
 
 const submissionTypes = {
   'Contest Submission': { id: 1, roleId: 1 },
@@ -97,6 +101,18 @@ class LegacySubmissionDomain {
   //   };
   //   return Promise.resolve(10);
   // }
+
+  public async update(input: UpdateSubmissionInput): Promise<UpdateResult> {   
+    const query: Query = new QueryBuilder(LegacySubmissionSchema)
+      .update({ ...input })
+      .where(...Util.toScanCriteria({ ...input } as { [key: string]: number|string|undefined }))
+      .build();
+
+    const { affectedRows } = await queryRunner.run(query);
+    return {
+      updatedCount: affectedRows || 0,
+    }
+  }
 }
 
 export default new LegacySubmissionDomain();

src/domain/LegacyUpload.ts

@@ -0,0 +1,24 @@
+import { Query, QueryBuilder } from "@topcoder-framework/client-relational";
+import { UpdateResult } from "@topcoder-framework/lib-common";
+import { Util } from "../common/Util";
+import { queryRunner } from "../helper/QueryRunner";
+import {
+  UpdateUploadInput,
+} from "../models/domain-layer/legacy/upload";
+import { UploadSchema } from "../schema/submission/Upload";
+
+class LegacySubmissionDomain {
+  public async update(input: UpdateUploadInput): Promise<UpdateResult> {   
+    const query: Query = new QueryBuilder(UploadSchema)
+      .update({ ...input })
+      .where(...Util.toScanCriteria({ ...input } as { [key: string]: number|string|undefined }))
+      .build();
+
+    const { affectedRows } = await queryRunner.run(query);
+    return {
+      updatedCount: affectedRows || 0,
+    }
+  }
+}
+
+export default new LegacySubmissionDomain();

src/schema/submission/Submission.ts

@@ -0,0 +1,21 @@
+import { ColumnType, Schema } from "@topcoder-framework/client-relational";
+import { LegacySubmission } from "../../models/domain-layer/legacy/submission";
+import { AuditColumns } from "../common/AuditColumns";
+
+export const LegacySubmissionSchema: Schema<LegacySubmission> = {
+  dbSchema: "tcs_catalog",
+  tableName: "submission",
+  idColumn: "submission_id",
+  idSequence: "submission_id_seq",
+  idTable: "submission",
+  columns: {
+    submissionId: { name: "submission_id", type: ColumnType.COLUMN_TYPE_INT },
+    submissionStatusId: { name: "submission_status_id", type: ColumnType.COLUMN_TYPE_INT },
+    submissionTypeId: { name: "submission_type_id", type: ColumnType.COLUMN_TYPE_INT },
+    uploadId: { name: "upload_id", type: ColumnType.COLUMN_TYPE_INT },
+    screeningScore: { name: "screening_score", type: ColumnType.COLUMN_TYPE_INT },
+    initialScore: { name: "initial_score", type: ColumnType.COLUMN_TYPE_INT },
+    finalScore: { name: "final_score", type: ColumnType.COLUMN_TYPE_INT },
+    ...AuditColumns,
+  },
+};

src/schema/submission/Upload.ts

@@ -0,0 +1,22 @@
+import { ColumnType, Schema } from "@topcoder-framework/client-relational";
+import { Upload } from "../../models/domain-layer/legacy/upload";
+import { AuditColumns } from "../common/AuditColumns";
+
+export const UploadSchema: Schema<Upload> = {
+  dbSchema: "tcs_catalog",
+  tableName: "upload",
+  idColumn: "upload_id",
+  idSequence: "upload_id_seq",
+  idTable: "upload",
+  columns: {
+    uploadId: { name: "upload_id", type: ColumnType.COLUMN_TYPE_INT },
+    projectId: { name: "project_id", type: ColumnType.COLUMN_TYPE_INT },
+    resourceId: { name: "resource_id", type: ColumnType.COLUMN_TYPE_INT },
+    projectPhaseId: { name: "project_phase_id", type: ColumnType.COLUMN_TYPE_INT },
+    uploadTypeId: { name: "upload_type_id", type: ColumnType.COLUMN_TYPE_INT },
+    url: { name: "url", type: ColumnType.COLUMN_TYPE_STRING },
+    uploadStatusId: { name: "upload_status_id", type: ColumnType.COLUMN_TYPE_INT },
+    parameter: { name: "parameter", type: ColumnType.COLUMN_TYPE_STRING },
+    ...AuditColumns,
+  },
+};

src/server.ts

@@ -29,6 +29,7 @@ import { LegacyResourceServer, LegacyResourceService } from "./service/Resource"
 import { LegacyReviewServer, LegacyReviewService } from "./service/Review";
 import { LegacySyncServer, LegacySyncService } from "./service/Sync";
 import { LegacyTermServer, LegacyTermService } from "./service/Term";
+import { LegacyUploadServer, LegacyUploadService } from "./service/LegacyUpload";
 
 const server = new Server({
   "grpc.max_send_message_length": -1,
@@ -51,6 +52,7 @@ server.addService(LegacyResourceService, new LegacyResourceServer());
 server.addService(LegacyGroupContestEligibilityService, new LegacyGroupContestEligibilityServer());
 server.addService(LegacyChallengePaymentService, new LegacyChallengePaymentServer());
 server.addService(LegacyPrizeServiceService, new LegacyPrizeServer());
+server.addService(LegacyUploadService, new LegacyUploadServer());
 server.addService(LegacySyncService, new LegacySyncServer());
 
 server.bindAsync(

src/service/LegacySubmission.ts

@@ -47,7 +47,11 @@ class LegacySubmissionServerImpl implements LegacySubmissionServer {
   update: handleUnaryCall<UpdateSubmissionInput, UpdateResult> = (
     call: ServerUnaryCall<UpdateSubmissionInput, UpdateResult>,
     callback: sendUnaryData<UpdateResult>
-  ) => { };
+  ) => {
+    LegacySubmissionDomain.update(call.request)
+      .then((response) => callback(null, response))
+      .catch((err) => callback(err, null));
+  };
 }
 
-export { LegacySubmissionServerImpl as LegacySubmissionServer, LegacySubmissionService };
+export { LegacySubmissionServerImpl as LegacySubmissionServer, LegacySubmissionService };

src/service/LegacyUpload.ts

@@ -0,0 +1,52 @@
+import { handleUnaryCall, sendUnaryData, ServerUnaryCall, UntypedHandleCall } from "@grpc/grpc-js";
+import { CreateResult, Empty, LookupCriteria, ScanRequest, ScanResult, UpdateResult
+} from "@topcoder-framework/lib-common";
+import LegacyUploadDomain from '../domain/LegacyUpload'
+
+import { LegacyUploadServer, LegacyUploadService } from '../models/domain-layer/legacy/services/upload';
+import { Upload, CreateUploadInput, DeleteUploadInput, UploadList, UpdateUploadInput } from "../models/domain-layer/legacy/upload";
+
+class LegacyUploadServerImpl implements LegacyUploadServer {
+  [name: string]: UntypedHandleCall;
+
+  scan: handleUnaryCall<ScanRequest, ScanResult> = (
+    call: ServerUnaryCall<ScanRequest, ScanResult>,
+    callback: sendUnaryData<ScanResult>
+  ) => {
+    // not implemented
+  };
+
+  lookup: handleUnaryCall<LookupCriteria, Upload>
+  = (
+    call: ServerUnaryCall<LookupCriteria, Upload>,
+    callback: sendUnaryData<Upload>
+  ) => {
+    // not implemented
+  };
+
+  create: handleUnaryCall<CreateUploadInput, CreateResult> = (
+    call: ServerUnaryCall<CreateUploadInput, CreateResult>,
+    callback: sendUnaryData<CreateResult>
+  ) => {
+    // not implemented
+  };
+
+  delete: handleUnaryCall<DeleteUploadInput, UploadList> = (
+    call: ServerUnaryCall<DeleteUploadInput, UploadList>,
+    callback: sendUnaryData<UploadList>
+  ) => {
+    // not implemented
+  };
+
+
+  update: handleUnaryCall<UpdateUploadInput, UpdateResult> = (
+    call: ServerUnaryCall<UpdateUploadInput, UpdateResult>,
+    callback: sendUnaryData<UpdateResult>
+  ) => {
+    LegacyUploadDomain.update(call.request)
+      .then((response) => callback(null, response))
+      .catch((err) => callback(err, null));
+  };
+}
+
+export { LegacyUploadServerImpl as LegacyUploadServer, LegacyUploadService };